Spring Boot集成STOMP时如何配置队列保留消息直至服务器重启

首先得明确两个框架层面的默认设计，是导致你没法留存/queue路径下消息的核心原因——这不是配置错了，是默认逻辑本来就和你的需求不匹配：

• Spring内置的内存SimpleBroker（简单STOMP代理）本身没有历史消息留存能力：它的核心逻辑就是收到消息后匹配对应的订阅者完成路由投递，投完消息就会被直接回收，从设计上就没有存历史消息的环节，不管调什么参数都不会自动保留发出去的消息。
• 默认的路径前缀映射规则有冲突：Spring默认把/queue作为用户专属点对点消息的根路径，发往这类路径的消息会被强制加上用户身份匹配规则，只会推送给对应身份的特定用户，不会全局暴露给所有连接的客户端，就算你存了消息，也没法让任意新客户端拿到。

具体配置步骤 #

1. 调整STOMP基础路由规则 #

首先写STOMP核心配置类，把上面两个默认的冲突点改掉，示例代码：

@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfig implements WebSocketMessageBrokerConfigurer {

    @Override
    public void registerStompEndpoints(StompEndpointRegistry registry) {
        // 注册前端连接的握手端点，根据实际跨域规则调整
        registry.addEndpoint("/ws-endpoint")
                .setAllowedOriginPatterns("*")
                .withSockJS();
    }

    @Override
    public void configureMessageBroker(MessageBrokerRegistry registry) {
        // 开启内置内存代理，指定支持全局路由的路径前缀
        // 要把留存路径放在/queue下的话，直接把/queue加到这个列表里就行
        registry.enableSimpleBroker("/topic", "/queue", "/retain");
        // 配置客户端发消息给后端接口的路径前缀
        registry.setApplicationDestinationPrefixes("/app");
        // 关键修改：把用户专属点对点消息的默认前缀从/queue改成不冲突的路径
        // 避免/queue下的消息被强制匹配用户身份，变成点对点专属消息
        registry.setUserDestinationPrefix("/user/private");
    }
}

改完这个配置之后，/queue路径下的所有消息就会走全局路由逻辑，不会再被当成给单个用户发的专属消息了，所有订阅了对应/queue路径的客户端都能收到推送，第一步解决路由冲突的问题。

2. 实现轻量内存留存逻辑 #

因为内置代理本身不存历史消息，你需要自己在JVM内存里维护消息存储——这个方案完全匹配你"不需要跨重启存续、只要运行期留存"的需求，不需要引入RabbitMQ、ActiveMQ这类外部中间件：

• 用线程安全的内存Map做存储，服务重启后内存清空，自然就满足"重启不保留消息"的要求
• 加两个核心监听逻辑：
  1. 所有发往指定留存路径的消息，收到后自动存入内存Map
  2. 新客户端订阅对应路径时，自动把内存里存的历史消息推送给该客户端

示例组件代码：

@Component
public class StompRetainedMessageHandler {
    // 内存存储结构：key是目的地路径，value是对应路径下的留存消息
    // 如果只需要存最新的状态、不需要全量历史，直接换成 ConcurrentHashMap<String, Object> 存最新值就行，省内存
    private final ConcurrentHashMap<String, CopyOnWriteArrayList<Object>> retainedStore = new ConcurrentHashMap<>();
    @Autowired
    private SimpMessagingTemplate messagingTemplate;

    // 监听所有发往留存路径的消息，自动存入内存
    @MessageMapping("/**")
    public void saveRetainedMessage(StompHeaderAccessor accessor, Object payload) {
        String destination = accessor.getDestination();
        // 只留存需要保留的路径下的消息，避免无关消息占内存
        if (destination.startsWith("/queue/") || destination.startsWith("/retain/")) {
            retainedStore.compute(destination, (key, oldList) -> {
                CopyOnWriteArrayList<Object> list = oldList == null ? new CopyOnWriteArrayList<>() : oldList;
                list.add(payload);
                return list;
            });
        }
    }

    // 监听客户端订阅事件，给新订阅的客户端推送存好的历史消息
    @EventListener
    public void handleSubscription(SessionSubscribeEvent event) {
        StompHeaderAccessor accessor = StompHeaderAccessor.wrap(event.getMessage());
        String subscribedDestination = accessor.getDestination();
        String sessionId = accessor.getSessionId();
        // 从存储里取对应路径的留存消息
        CopyOnWriteArrayList<Object> history = retainedStore.get(subscribedDestination);
        if (history != null && !history.isEmpty()) {
            // 把历史消息逐个推送给当前刚订阅的客户端
            history.forEach(msg -> {
                messagingTemplate.convertAndSendToUser(sessionId, subscribedDestination, msg);
            });
        }
    }
}

你的场景是推送服务启动后的状态数据，其实不需要留存全量历史——直接把存储改成ConcurrentHashMap<String, Object>就行，新的服务状态消息进来直接覆盖旧值，客户端订阅的时候只要把最新的状态推过去，内存占用更低，也更符合实际业务需求，毕竟旧的状态数据对新客户端来说没有价值。

3. 常见踩坑提醒 #

• 别浪费时间翻SimpleBroker的配置参数找"留存消息"的开关：内置简单代理从设计上就没有存历史的逻辑，所有路由完成后的消息都会被直接丢弃，纯改配置参数根本实现不了留存，必须自己做内存存储逻辑。
• 不要把用户专属消息的前缀和留存路径重叠：如果你没改默认的setUserDestinationPrefix，/queue下的消息永远是点对点发给特定用户的，不管你存多少，新的匿名客户端都拿不到，这个是最多人踩的坑。
• 因为是纯内存存储，根本不需要考虑磁盘持久化、服务重启后消息恢复的问题，服务器重启后存储自动清空，完全符合你提的需求。

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