Java中Stomp WebSocket客户端如何订阅两个不同主题？

嘿，这事儿其实超简单的！你只需要在afterConnected方法里多调用几次session.subscribe()就搞定了——每个主题配一个自己的StompFrameHandler来处理对应消息就行。

核心思路 #

StompSession的subscribe方法支持重复调用，每一次调用都会建立一个新的订阅关系。你只需要为每个不同的主题编写独立的消息处理逻辑（也就是对应的StompFrameHandler），就能分别接收和处理不同主题的消息。

代码示例 #

假设你现在要订阅/topic/greetings（就是你原来的主题）和新增的/topic/announcements两个主题，代码可以这么写：

@Override
public void afterConnected(StompSession session, StompHeaders connectedHeaders) {
    // 订阅第一个主题：/topic/greetings
    session.subscribe("/topic/greetings", new StompFrameHandler() {
        @Override
        public Type getPayloadType(StompHeaders headers) {
            // 指定该主题消息的类型，对应你的Greeting实体类
            return Greeting.class;
        }

        @Override
        public void handleFrame(StompHeaders headers, Object payload) {
            Greeting receivedGreeting = (Greeting) payload;
            // 这里写处理问候消息的逻辑
            System.out.println("收到来自greetings的消息：" + receivedGreeting.getContent());
        }
    });

    // 订阅第二个主题：/topic/announcements
    session.subscribe("/topic/announcements", new StompFrameHandler() {
        @Override
        public Type getPayloadType(StompHeaders headers) {
            // 假设这个主题的消息是Announcement类型，你需要提前定义这个实体类
            return Announcement.class;
        }

        @Override
        public void handleFrame(StompHeaders headers, Object payload) {
            Announcement receivedAnnouncement = (Announcement) payload;
            // 这里写处理公告消息的逻辑
            System.out.println("收到来自announcements的消息：" + receivedAnnouncement.getContent());
        }
    });
}

额外注意事项 #

• 每个StompFrameHandler都是独立的，这样不同主题的消息处理逻辑完全隔离，后续维护起来更方便。
• 如果两个主题的消息类型完全一致，你也可以复用同一个StompFrameHandler实例，但除非逻辑完全相同，否则还是建议分开实现。
• 别忘了确认服务端已经配置了对应的主题哦！比如新增的/topic/announcements，你需要在服务端添加对应的消息发送逻辑（比如用@SendTo("/topic/announcements")的方法，或者通过SimpMessagingTemplate主动推送消息）。

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