Android 写一个socket服务端支持多个客户端接收和发送的消息队列

在Android中创建一个Socket服务端，支持多个客户端同时接收和发送消息，通常会涉及到ServerSocket、Socket对象以及消息队列的数据结构。以下是基本步骤：

1. **创建ServerSocket**:
首先，你需要创建一个ServerSocket，监听指定的端口。例如：

   ServerSocket serverSocket = new ServerSocket(port);

2. **接受连接**:
当有客户端连接时，通过`accept()`方法阻塞等待新连接：

   Socket clientSocket = serverSocket.accept();

3. **处理连接**:
对于每个客户端，创建一个新的线程或使用异步IO处理请求，比如`new Thread(new ClientHandler(clientSocket))`. `ClientHandler`类可以维护一个独立的消息队列。

4. **消息队列**:
使用`BlockingQueue`（如`ArrayBlockingQueue`）作为消息队列，存储从客户端接收到的消息。这样所有客户端的消息都能安全地存放在队列里，按顺序处理：

   BlockingQueue<String> messageQueue = new ArrayBlockingQueue<>(capacity);

5. **接收和发送消息**:
在`ClientHandler`类中，读取客户端输入并放入队列，然后从队列中取出消息发送给客户端：

   class ClientHandler implements Runnable {
       private Socket clientSocket;
       public ClientHandler(Socket socket) { ... }
       
       public void run() {
           // 接收客户端消息
           BufferedReader reader = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
           String msg;
           while ((msg = reader.readLine()) != null) {
               messageQueue.offer(msg);
           }
   
           // 发送消息到队列中的客户端
           PrintWriter writer = new PrintWriter(clientSocket.getOutputStream(), true);
           for (String queueMsg : messageQueue) {
               writer.println(queueMsg);
           }
       }
   }

6. **关闭连接**:
完成通信后，记得关闭套接字和服务器套接字：

   clientSocket.close();
   serverSocket.close();