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

在一个服务器端，为了支持多个客户端通过Socket连接并共享消息队列，你可以采用多线程结合队列的方式来实现。下面是一个基本的步骤和伪代码示例：

1. 创建服务器套接字 (ServerSocket) 和消息队列 (通常用 List 或者生产消费模型的 BlockingQueue 实现，如 Java 中的 `ArrayBlockingQueue`):

import java.io.*;
import java.net.*;
import java.util.concurrent.*;

public class SocketServer {
    private ServerSocket serverSocket;
    private BlockingQueue<String> messageQueue;

    public SocketServer(int port, int queueSize) {
        try {
            serverSocket = new ServerSocket(port);
            messageQueue = new ArrayBlockingQueue<>(queueSize);
        } catch (IOException e) {
            // handle exception
        }
    }

    // ...其他方法...
}

2. 定义一个处理客户端请求的接受线程 (AcceptThread):

class AcceptThread implements Runnable {
    private SocketServer server;

    public AcceptThread(SocketServer server) {
        this.server = server;
    }

    @Override
    public void run() {
        while (true) {
            try {
                Socket clientSocket = server.serverSocket.accept();
                ClientHandler clientHandler = new ClientHandler(clientSocket, server.messageQueue);
                new Thread(clientHandler).start();
            } catch (IOException e) {
                // handle exception and close connection
            }
        }
    }
}

3. 客户端连接处理器 (ClientHandler):

class ClientHandler extends Thread {
    private Socket clientSocket;
    private BlockingQueue<String> messageQueue;

    public ClientHandler(Socket clientSocket, BlockingQueue<String> queue) {
        this.clientSocket = clientSocket;
        this.messageQueue = queue;
    }

    @Override
    public void run() {
        try {
            BufferedReader reader = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
            PrintWriter writer = new PrintWriter(clientSocket.getOutputStream(), true);

            String messageFromClient;
            while ((messageFromClient = reader.readLine()) != null) {
                messageQueue.add(messageFromClient); // 收到消息入队
                sendReplyToClient(messageFromClient); // 可能需要根据消息内容回复
            }

            clientSocket.close();
        } catch (IOException e) {
            // handle exceptions
        }
    }

    private void sendReplyToClient(String message) throws IOException {
        // 根据消息队列处理结果，向客户端发送回复
    }
}

4. 客户端可以连接后向消息队列发送消息，同时从队列读取其他客户端的消息。