Java Socket一对多通信实现之并发处理方式

    //存放设备连接信息 eg: mac 登录状态 初始登录顺序等
    public static List<TcpObject> list = new LinkedList<TcpObject>();
    //存放设备初始登录顺序(累计排序)
    public static List<FileObject> fileInfo = new LinkedList<FileObject>();
    //存放 socket 连接对象，mac 为key 此处为线程安全的 map 集合
    public static Map<String,Socket> map = new ConcurrentHashMap<String, Socket>();

public class SocketThread  extends Thread{
	ServerSocket server;
	Socket client;
    public SocketThread(Socket socket){  
        this.client = socket;  
    }  
    @Override
    public void run() {
	try {
		reader = new BufferedReader(new InputStreamReader(client.getInputStream()));
        // 读取reader中的信息...
	  } catch (Exception e) {
		//捕获socket强制断开异常信息，移除socket
    }	
 }
}

public class TcpServer {
    public static void main(String[] args) {
        start();
    }
	 public void start() {
	        try {
	            //记录链接过的客户端个数
	            //1、创建一个服务器端Socket，即ServerSocket，绑定指定的端口，进行监听
	            ServerSocket serverSocket = new ServerSocket(9000);
	            log.info("服务器即将启动，等待客户端连接");
	            //2、循环监听等待客户端的连接
	            while(true){
	                //调用accept方法 等待客户端的连接
	                Socket socket = serverSocket.accept();
	                if(!GlobalCommonUtil.isStart) {
	                	 //创建一个新的线程
		                SocketThread serverThread = new SocketThread(socket);
		                //启动线程
		                serverThread.start();
		                GlobalCommonUtil.count++;
		                log.info("连接过的客户端数量为:" + GlobalCommonUtil.count);
	            	}
	            }
	        } catch (IOException e) {
	            e.printStackTrace();
	        }
	}
}

 for(TcpObject tcpObject : GlobalCommonUtil.list) {
 if(tcpObject.getMac().equals(mac)) {
	GlobalCommonUtil.list.remove(tcpObject);
	break;
   }
}
GlobalCommonUtil.count--;
log.info("远程客户端已关闭连接！");