如何从Java服务器端主动关闭STOMP连接/会话？

以下针对Java生态最常用的两种STOMP服务器技术栈给出可直接落地的实现：

1. 基于Spring WebSocket（STOMP协议）的实现 #

这是目前Java项目搭建STOMP服务器最主流的方案，操作步骤如下：

• 第一步：先注入两个Spring WebSocket自带的核心Bean，用于获取会话信息和发送帧

@Autowired
private SimpUserRegistry simpUserRegistry;
@Autowired
private SimpMessagingTemplate simpMessagingTemplate;

• 第二步：遍历目标用户的所有会话，按需执行断开逻辑

// 替换为你要踢出的目标用户ID
String targetUserId = "xxx";
SimpUser user = simpUserRegistry.getUser(targetUserId);
if (user != null) {
    for (SimpSession session : user.getSessions()) {
        // 方案1：STOMP协议规范的优雅断开：先给客户端发DISCONNECT通知，客户端感知到后主动断开
        simpMessagingTemplate.convertAndSendToUser(
            targetUserId,
            "/queue/disconnect",
            "您的会话已过期，请重新登录",
            // 携带会话ID头，保证消息只发给目标会话，不会触达用户的其他登录终端
            Collections.singletonMap(SimpMessageHeaderAccessor.SESSION_ID_HEADER, session.getId())
        );
        // 方案2：强制断开底层WebSocket连接，适合不需要客户端感知的场景
        // 建议提前注册SessionConnectEvent监听器，在用户连接时将WebSocketSession存入自定义缓存，这里直接从缓存取
        WebSocketSession webSocketSession = customSessionCache.get(session.getId());
        if (webSocketSession != null && webSocketSession.isOpen()) {
            webSocketSession.close(CloseStatus.GOING_AWAY.withReason("服务端主动终止会话"));
        }
    }
}

注意：如果是集群部署的STOMP服务，需要先定位目标用户连接的节点，将断开指令路由到对应节点执行，无法跨节点直接操作会话。

2. 基于Netty等原生框架自研STOMP服务器的实现 #

如果是自己基于Netty等网络框架实现STOMP协议栈，实现逻辑更直接：

• 连接建立时，将每个客户端的Channel对象和对应用户ID、会话ID绑定，存入自定义的全局会话管理器
• 需要踢人时直接从会话管理器取出目标Channel执行关闭即可

// 从自定义会话管理器中取出目标会话的Channel
Channel targetChannel = globalSessionManager.getChannelBySessionId("目标会话ID");
if (targetChannel != null && targetChannel.isActive()) {
    // 先构造STOMP DISCONNECT帧通知客户端断开原因
    StompFrame disconnectFrame = new StompFrame(StompCommand.DISCONNECT);
    disconnectFrame.addHeader(StompHeaders.RECEIPT, "kicked-out");
    disconnectFrame.setPayload(Unpooled.copiedBuffer("您已被服务端踢出", CharsetUtil.UTF_8));
    // 帧发送完成后自动关闭连接
    targetChannel.writeAndFlush(disconnectFrame).addListener(ChannelFutureListener.CLOSE);
}

优先选择发送DISCONNECT帧的优雅断开方式，客户端可以捕获断开原因，做重定向、重连提示等自定义逻辑，直接断连可能导致客户端异常报错。

内容的提问来源于stack exchange，提问作者Arlo Guthrie