如何在StompJS中将原生Header传递至Disconnect事件？

我明白你想在Stomp客户端断开连接时传递自定义Header，并且希望和Connect事件的处理逻辑保持一致，下面一步步教你实现：

第一步：客户端（StompJS）传递Disconnect Header #

StompJS的disconnect方法其实支持传入自定义Header参数，你只需要在调用时把Header作为第二个参数传入就行（针对v5+版本的StompJS，回调函数在前，Header在后）：

// 假设你已经初始化了stompClient
stompClient.disconnect(
  () => {
    console.log('客户端已断开连接');
  },
  {
    'X-User-ID': 'user123',
    'Authorization': 'Bearer your-token-here'
    // 这里可以添加你需要传递的任意原生Header
  }
);

如果是旧版本的StompJS，参数顺序可能是Header在前、回调在后，你可以根据实际版本调整。

第二步：服务端（Spring）获取Disconnect Header #

你的SessionDisconnectEvent监听器可以通过StompHeaderAccessor来解析断开连接帧里的Header，注意要使用getFirstNativeHeader方法来获取原生Header（避免Spring对Header名称的自动转换）。另外，你的代码里同时使用了ApplicationListener接口和@EventListener注解，这是重复的，选一种方式即可，下面是优化后的代码：

@Component
public class DocumentStompDisconnectEvent implements ApplicationListener<SessionDisconnectEvent> {

    @Override
    public void onApplicationEvent(SessionDisconnectEvent event) {
        // 包装事件消息，获取Stomp头部访问器
        StompHeaderAccessor headerAccessor = StompHeaderAccessor.wrap(event.getMessage());
        
        // 获取自定义Header
        String userId = headerAccessor.getFirstNativeHeader("X-User-ID");
        String authToken = headerAccessor.getFirstNativeHeader("Authorization");
        
        // 这里处理你的业务逻辑，比如记录断开日志、清理用户会话资源等
        if (userId != null) {
            System.out.println("用户 " + userId + " 已断开WebSocket连接");
        }
    }
}

或者如果你更喜欢用@EventListener注解的方式，可以改成这样：

@Component
public class DocumentStompDisconnectEvent {

    @EventListener
    public void handleSessionDisconnect(SessionDisconnectEvent event) {
        StompHeaderAccessor headerAccessor = StompHeaderAccessor.wrap(event.getMessage());
        String userId = headerAccessor.getFirstNativeHeader("X-User-ID");
        // 业务逻辑...
    }
}

关键注意事项 #

• Stomp协议的DISCONNECT帧本身就支持携带Header，所以这个方案是符合协议规范的，和Connect事件的逻辑完全一致。
• 如果你的WebSocket连接经过了反向代理（比如Nginx），要确保代理配置允许这些自定义Header被传递到后端服务，避免被拦截。
• 如果你需要获取用户身份信息，也可以直接从headerAccessor.getUser()获取（前提是你在Connect时已经完成了用户认证，Spring会自动关联会话），不过自定义Header的方式更灵活。

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