如何通过WebService复用同一ServerSocket并持久保存ClientSocket连接？

现有实现的核心问题 #

你当前的代码存在几个基础缺陷会直接导致需求无法实现：

• ServerSocket 每次调用/conect接口时重复创建会触发端口绑定冲突；accept()方法是阻塞方法，写在接口逻辑中会导致请求直接超时无法返回；JAX-RS资源默认是请求级作用域，类成员变量无法跨请求保存。

具体实现方案 #

1. 全局单例连接管理器 #

用单例模式统一管理ServerSocket初始化、连接监听、Socket实例存储、线程安全写入和保活逻辑，所有接口复用该管理器的实例：

// 全局Socket连接管理器，单例实现
public enum SocketConnectionManager {
    INSTANCE;

    private ServerSocket serverSocket;
    private Socket activeClientSocket;
    // 写操作锁，解决Socket OutputStream非线程安全问题
    private final ReentrantLock writeLock = new ReentrantLock();
    // 心跳检测线程池
    private final ScheduledExecutorService heartbeatExecutor = Executors.newSingleThreadScheduledExecutor();

    SocketConnectionManager() {
        // 应用启动时仅初始化一次ServerSocket
        try {
            serverSocket = new ServerSocket(3242);
            // 单独启动后台线程阻塞监听客户端连接，不阻塞接口请求
            new Thread(() -> {
                while (!serverSocket.isClosed()) {
                    try {
                        Socket newClient = serverSocket.accept();
                        // 关闭旧连接（若存在）
                        if (activeClientSocket != null) {
                            activeClientSocket.close();
                        }
                        activeClientSocket = newClient;
                        // 启动心跳检测，30秒一次校验连接存活
                        heartbeatExecutor.scheduleAtFixedRate(() -> {
                            try {
                                if (activeClientSocket.isConnected()) {
                                    activeClientSocket.getOutputStream().write("heartbeat\n".getBytes(StandardCharsets.UTF_8));
                                    activeClientSocket.getOutputStream().flush();
                                }
                            } catch (IOException e) {
                                // 连接异常时清空失效连接
                                closeActiveConnection();
                            }
                        }, 0, 30, TimeUnit.SECONDS);
                    } catch (IOException e) {
                        e.printStackTrace();
                    }
                }
            }).start();
        } catch (IOException e) {
            throw new RuntimeException("ServerSocket初始化失败", e);
        }
    }

    /**
     * 对外提供线程安全的消息发送方法
     */
    public boolean sendMessage(String content) {
        if (!isConnectionAlive()) {
            return false;
        }
        writeLock.lock();
        try {
            OutputStream outputStream = activeClientSocket.getOutputStream();
            PrintWriter writer = new PrintWriter(new OutputStreamWriter(outputStream, StandardCharsets.UTF_8), true);
            writer.println(content);
            writer.flush();
            return true;
        } catch (IOException e) {
            closeActiveConnection();
            return false;
        } finally {
            writeLock.unlock();
        }
    }

    /**
     * 查询连接存活状态校验
     */
    public boolean isConnectionAlive() {
        return activeClientSocket != null && activeClientSocket.isConnected() && !activeClientSocket.isClosed();
    }

    private void closeActiveConnection() {
        try {
            if (activeClientSocket != null) {
                activeClientSocket.close();
            }
        } catch (IOException e) {
            // 忽略关闭异常
        }
        activeClientSocket = null;
    }
}

2. 接口层调用改造 #

所有需要使用Socket的接口直接调用连接管理器封装好的能力即可，无需手动维护Socket实例：

@GET
@Path("/register-presence/{userId}")
public String registerPresence(@PathVariable("userId") Long userId){    
    boolean sendResult = SocketConnectionManager.INSTANCE.sendMessage("lUHXGbLOUaO4JczgkI2oXHTmuu/1Z0OYKQz6nYKyxw5xymw= ");
    return sendResult ? "ok" : "connection unavailable";
}

扩展优化点 #

• 如果需要支持多个客户端同时连接，可将activeClientSocket替换为Map<客户端唯一标识, Socket>结构，发送时按标识取用对应连接即可。
• 如果服务是多实例部署的场景，可引入消息中间件中转发送请求，目标消息由持有对应Socket连接的实例消费后发送到客户端。
• 消息传输时建议定义消息格式（比如固定长度、特殊分隔符），避免TCP粘包半包问题导致客户端解析异常。

内容的提问来源于stack exchange，提问作者Ronald Calazans