简略servlet socket 整合

简单servlet socket 整合
package filter;

import java.io.IOException;

import javax.servlet.ServletConfig;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

import socket.SocketServer;

/*
初始化socket
*/
public class RFilter extends HttpServlet {
private static final long serialVersionUID = 1L;
SocketServer socket;
??? @Override
public void init(ServletConfig config) throws ServletException {
super.init(config);
socket=new SocketServer();
socket.start();
System.out.println("load on start!");
}


??? public RFilter() {
??????? super();
??? }

protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {

System.out.println("***************RFilter doGet");
socket.cc.handCom();

}


protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
// TODO Auto-generated method stub
System.out.println("***************RFilter doPost");
socket.cc.handCom();
}

}

/*?
* To change this template, choose Tools | Templates?
* and open the template in the editor.?
*/?
package socket;??
?
import java.io.IOException;
import java.net.InetSocketAddress;
import java.net.ServerSocket;
import java.net.Socket;
import java.nio.channels.ServerSocketChannel;
import java.nio.channels.SocketChannel;

import filter.ClientController;
?
/*
? socket服务端类
*/
public class SocketServer extends Thread{??
?
??? ServerSocket ss = null;???????????????????????? //socket连接??
??? public ClientController cc;
???
?
??? public SocketServer() {
super();
? try {
//
ss = new ServerSocket(9999);
? cc=new ClientController();

} catch (IOException e) {
e.printStackTrace();
}??
}
?
??? public void run() {??
???
??? ?? System.out.println("准备好接收数据！");
???????? try{
???????
??????????? while (true) {??
????????????? Socket? socket = ss.accept();??
??????????????? if(socket!=null){
??????????????? cc.addNewClient(socket);
??????????????? }
??????????? }??
?
??????? } catch (IOException ex) {??
??????????? System.out.println(ex.toString());??
??????? }??
?
?
??? }??
?
}?


package filter;

import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.Socket;
import java.nio.channels.SocketChannel;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.Map;
import java.util.zip.DeflaterOutputStream;

import flex.messaging.io.SerializationContext;
import flex.messaging.io.amf.Amf3Output;
/*
? 管理与客户端通讯的业务类
*/
public class ClientController {
private ArrayList<Socket> clients;
private SerializationContext context = new SerializationContext();
public ClientController(){

clients=new ArrayList<Socket>();
}



public void handCom(){
System.out.println("ClientController size:"+clients.size());
for(Socket inComing:clients){
? try {??
?
????????? DataOutputStream dos = new DataOutputStream(inComing.getOutputStream());??

????????? Amf3Output out = new Amf3Output(context);??
????????? DeflaterOutputStream stream = new DeflaterOutputStream(dos);??
????????? out.setOutputStream(stream);??

????????? Map map = new HashMap();??
????????? String[] arr = "1,2,3,4,5".split(",");??

????????? map.put("datas", arr);??
????????? map.put("userName", "mumuyu99");??
????????? map.put("fullName", "最新消息");??
??????????

????????? out.writeObject(map);??
????????? stream.finish();??

????????? out.flush();
?????????????
????????? dos.flush();??
????????????? System.out.println("clientController handCom");

????? } catch (IOException ex) {??
????????? ex.printStackTrace();
????? }??

}
}


public? void addNewClient(Socket socket){
clients.add(socket);
System.out.println("****************用户登录************");
System.out.println("******登录用户数："+clients.size()+"*****");

}

}