Spring WebSocket(ActiveMQ)：Stomp订阅Topic无法获取历史消息问题

1. 这是正常行为吗？ #

完全正常！Queue 和 Topic 在消息代理中的设计逻辑天生不同：

• Queue 是点对点模式，消息会被持久化存储，直到有消费者连接并消费，所以不管用户什么时候上线，都能拿到之前未被处理的排队消息。
• Topic 是发布订阅模式，默认是"即时推送"逻辑——只有当订阅者在线时，才能收到消息。如果订阅者断开或还未连接，这些消息不会被留存（除非配置了持久化订阅），所以首次连接只能收到之后产生的新消息。

2. 如何获取 Topic 中已排队的消息？ #

要让 Topic 能为后续连接的订阅者保存历史消息，你需要用到 ActiveMQ 的持久化主题订阅（Durable Topic Subscriptions），结合 Spring STOMP 配置来实现，具体步骤如下：

服务端配置

在你的 Spring WebSocket 配置类中，必须使用外部代理模式（而非内存代理）对接 ActiveMQ，才能启用持久化订阅能力：

@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfig implements WebSocketMessageBrokerConfigurer {

    @Override
    public void configureMessageBroker(MessageBrokerRegistry config) {
        // 启用 ActiveMQ 作为消息代理，指定 Topic/Queue 前缀
        config.enableStompBrokerRelay("/topic", "/queue")
              .setRelayHost("localhost")
              .setRelayPort(61613)
              .setClientLogin("admin")
              .setClientPasscode("admin");
        // 设置应用层消息前缀
        config.setApplicationDestinationPrefixes("/app");
    }

    @Override
    public void registerStompEndpoints(StompEndpointRegistry registry) {
        registry.addEndpoint("/ws").withSockJS();
    }
}

注意：enableSimpleBroker 是内存代理，不支持持久化订阅，必须用 enableStompBrokerRelay 对接 ActiveMQ 原生能力。

客户端订阅配置

客户端订阅 Topic 时，必须指定全局唯一的 clientId 和 subscriptionId，让 ActiveMQ 识别这是一个需要留存消息的持久化订阅者：

const stompClient = new Stomp.Client({
    brokerURL: 'ws://localhost:8080/ws'
});

stompClient.onConnect = function(frame) {
    // 订阅持久化 Topic，clientId 建议用用户唯一标识（如用户ID）
    stompClient.subscribe('/topic/your-topic', 
        (message) => {
            console.log('收到消息:', message.body);
        },
        { id: 'user-123-sub', clientId: 'user-123' }
    );
};

stompClient.activate();

确保消息持久化

发送 Topic 消息时，显式标记消息为持久化（ActiveMQ 对持久化订阅的消息默认会持久化，但显式设置更稳妥）：

@Autowired
private SimpMessagingTemplate messagingTemplate;

@Scheduled(fixedRate = 5000)
public void sendTopicMessage() {
    messagingTemplate.convertAndSend("/topic/your-topic", 
        "历史消息内容",
        message -> {
            message.getHeaders().set("persistent", true);
            return message;
        });
}

3. 有没有基于 Topic 的解决方案，而非为每个用户创建 Queue？ #

当然有！上面提到的持久化主题订阅就是最优方案，完全不需要为每个用户单独创建 Queue：

• 每个用户通过唯一的 clientId 注册为持久化订阅者，ActiveMQ 会为每个订阅者自动维护一个"虚拟消息队列"，留存未被消费的历史消息。
• 如果需要支持同一个用户多端登录（如手机、电脑同时在线），可以用共享持久化订阅（Shared Durable Subscriptions）——多个客户端共享同一个持久化订阅，消息会被负载均衡分配给在线客户端，避免重复消费。

共享持久化订阅的客户端写法只需加一个 shared: true 参数：

stompClient.subscribe('/topic/your-topic', 
    (message) => {
        console.log('收到消息:', message.body);
    },
    { id: 'shared-user-123-sub', clientId: 'user-123', shared: true }
);

注意事项 #

• 持久化订阅的 clientId 一旦注册，除非显式取消订阅，ActiveMQ 会一直为其留存消息，建议用户注销时调用 unsubscribe() 清理订阅关系。
• 确保 ActiveMQ 的持久化存储配置正常（默认用 KahaDB，无需额外修改），否则重启代理后历史消息会丢失。

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