java socket 进阶话题一： socket 客户端连接管理(二)

 public void run() {

            while (true) {
                Socket socketOut = null;
                try {
                    Thread.sleep(2000);
                    System.out.println("exec time: " + DateHelper.date2String(new Date()));
                    for (Socket socketTemp : socketList) {
                        socketOut = socketTemp;
                        System.out.println("ip: " + socketTemp.getInetAddress().getHostAddress() + " -- remote port: "
                            + socketTemp.getPort() + " is close: " + socketTemp.isClosed() + " -- is connected: "
                            + socketTemp.isConnected());
                        
                       
                       //心跳，发送消息用来真正的检验客户端是否存在
                       DataOutputStream dataOut = new DataOutputStream( socketTemp.getOutputStream());
                       dataOut.writeBytes("test");
                       dataOut.flush();
                       
                    }

                    System.out.println("\n");
                }
                catch (Exception e) {
                    //出现异常，删除掉出现错误的客户端
                    socketList.remove(socketOut);
                    System.out.println(e.getMessage());
                }
                    
            }

        }

public static void main(String[] args) {
        try {
            
            List
  
    listSocket = new ArrayList
   
    (); for(int i=0 ;i < 5 ;i++){ Socket socket = new Socket("localhost", 9912); listSocket.add(socket); } Thread.sleep(4000); Socket socket = listSocket.get(2); socket.close(); Socket socket1 = listSocket.get(3); socket1.close(); socket1 = null; System.out.println("Exec time: " + DateHelper.date2String(new Date()) + " 设置socket 连接为关闭状态"); Thread.sleep(8000); } catch (Exception e) { e.printStackTrace(); } }
   
  

exec time: 2014-01-23 18:14:55