简单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()+"*****");

}

}