如何让Java IO Socket像ServerSocket一样监听第三方服务主动请求？

阿华AIGC实验室

2026-5-13

如何复用Java客户端Socket同时接收服务器响应和主动请求？

我正在做一个金融消息集成的需求，场景和遇到的问题如下：

背景与已实现功能

有一个第三方服务器，它在指定IP和端口监听客户端Socket请求，这个服务器的逻辑比较特殊：不仅会响应客户端发起的请求，还会主动通过同一个客户端Socket向我们发起请求。

目前我已经用Java IO的Socket对象实现了两个功能：

成功向服务器发送请求
能正常接收对应请求的响应

基础代码大致如下：

try {
    Socket clientSocket = new Socket("example.com", 8888);
    BufferedWriter output = new BufferedWriter(new OutputStreamWriter(clientSocket.getOutputStream()));
    output.write(data);
    output.flush();
    BufferedReader input = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
    // Read responses or new request from input
} catch (IOException e) {
    e.printStackTrace();
}

当前问题

当第三方服务器主动向我的客户端Socket发起请求时，我这边始终接收不到，但用tcpdump抓包能看到对应的流量确实已经到达客户端环境。而且我不能创建自己的ServerSocket，必须复用这个已经建立好的客户端Socket来监听服务器的响应和主动请求。

问题根源

你的核心问题在于输入流的读取逻辑是同步阻塞且没有持续监听。TCP Socket是全双工的，一旦连接建立，两端都可以随时收发数据，但你的代码里可能只在发送请求后读取了一次响应，之后就没有持续监听输入流，导致服务器主动发来的消息无法被捕获。

解决方案：用独立线程持续监听输入流

要复用同一个Socket接收所有来自服务器的消息（不管是响应还是主动请求），关键是把输入流的监听逻辑放到独立线程中，让它持续运行，实时捕获服务器发送的任何数据。

修改后的完整代码示例：

public class DualModeFinancialClient {
    private Socket clientSocket;
    private BufferedWriter output;
    private BufferedReader input;
    private volatile boolean isRunning = true;

    // 初始化连接并启动监听线程
    public void startConnection(String hostname, int port) throws IOException {
        clientSocket = new Socket(hostname, port);
        output = new BufferedWriter(new OutputStreamWriter(clientSocket.getOutputStream()));
        input = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));

        // 启动独立线程监听服务器消息
        Thread listenerThread = new Thread(this::listenForServerMessages);
        listenerThread.setDaemon(true); // 设置为守护线程，随主线程退出
        listenerThread.start();
    }

    // 发送消息到服务器
    public void sendClientRequest(String data) throws IOException {
        output.write(data);
        output.flush();
        // 无需在这里等待响应，监听线程会处理所有服务器发来的消息
    }

    // 持续监听服务器输入流
    private void listenForServerMessages() {
        try {
            String serverMessage;
            // 循环读取直到连接关闭或线程停止
            while (isRunning && (serverMessage = input.readLine()) != null) {
                // 统一处理服务器发来的消息，区分是响应还是主动请求
                handleServerMessage(serverMessage);
            }
        } catch (IOException e) {
            if (isRunning) { // 非主动停止时打印异常
                e.printStackTrace();
            }
        } finally {
            closeConnection();
        }
    }

    // 根据第三方规则区分消息类型并处理
    private void handleServerMessage(String message) {
        System.out.println("Received from server: " + message);
        if (isServerInitiatedRequest(message)) {
            // 处理服务器主动发起的请求
            processServerRequest(message);
        } else {
            // 处理客户端请求的响应
            processServerResponse(message);
        }
    }

    // 示例：根据消息前缀判断是否为服务器主动请求（需根据第三方规则修改）
    private boolean isServerInitiatedRequest(String message) {
        return message.startsWith("SERVER_INITIATED:");
    }

    // 处理服务器主动请求的逻辑
    private void processServerRequest(String request) {
        // 这里根据第三方规则返回对应的响应
        try {
            sendClientRequest("CLIENT_RESPONSE: " + request);
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    // 处理服务器响应的逻辑
    private void processServerResponse(String response) {
        System.out.println("Handled server response: " + response);
        // 这里可以添加业务逻辑，比如更新本地状态、通知上层系统等
    }

    // 关闭连接并清理资源
    public void closeConnection() {
        isRunning = false;
        try {
            if (input != null) input.close();
            if (output != null) output.close();
            if (clientSocket != null) clientSocket.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    // 测试入口
    public static void main(String[] args) throws IOException, InterruptedException {
        DualModeFinancialClient client = new DualModeFinancialClient();
        client.startConnection("example.com", 8888);
        client.sendClientRequest("CLIENT_REQUEST: Query Account Balance");

        // 保持主线程运行，模拟业务持续处理
        Thread.sleep(60000);
        client.closeConnection();
    }
}