Spring Boot能否为各STOMP端点配置独立控制器与消息映射？

要实现你需要的基于连接端点的完全隔离，并为每个端点配置独立的Controller、MessageMapping和Jackson ObjectMapper，核心是为每个STOMP端点创建独立的WebSocket消息代理上下文，而不是在同一个配置里注册多个端点。具体实现步骤如下：

1. 拆分WebSocket配置类 #

每个端点对应一个独立的配置类，分别注册端点、配置消息代理路径、自定义ObjectMapper。

配置类1：对应/endpoint1 #

@Configuration
@EnableWebSocketMessageBroker
@Order(1)
public class WebSocketConfigEndpoint1 implements WebSocketMessageBrokerConfigurer {

    // 为endpoint1创建专属的ObjectMapper
    @Bean(name = "objectMapperEndpoint1")
    public ObjectMapper objectMapperEndpoint1() {
        ObjectMapper mapper = new ObjectMapper();
        // 这里添加endpoint1专属的序列化/反序列化规则
        mapper.setDateFormat(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"));
        mapper.enable(SerializationFeature.INDENT_OUTPUT);
        return mapper;
    }

    @Override
    public void registerStompEndpoints(StompEndpointRegistry registry) {
        // 仅注册当前端点
        registry.addEndpoint("/endpoint1")
                .setAllowedOriginPatterns("*")
                .withSockJS();
    }

    @Override
    public void configureMessageBroker(MessageBrokerRegistry config) {
        // 设置应用前缀：只有/app/endpoint1/开头的消息会被@MessageMapping处理
        config.setApplicationDestinationPrefixes("/app/endpoint1");
        // 启用内存消息代理，仅处理/topic/endpoint1和/queue/endpoint1开头的路径
        config.enableSimpleBroker("/topic/endpoint1", "/queue/endpoint1");
        // 配置用户目标前缀，配合@SendToUser使用
        config.setUserDestinationPrefix("/user/endpoint1");
    }

    @Override
    public void configureMessageConverters(List<MessageConverter> converters) {
        // 使用endpoint1专属的ObjectMapper处理消息转换
        MappingJackson2MessageConverter converter = new MappingJackson2MessageConverter();
        converter.setObjectMapper(objectMapperEndpoint1());
        converters.add(converter);
    }
}

配置类2：对应/endpoint2 #

@Configuration
@EnableWebSocketMessageBroker
@Order(2)
public class WebSocketConfigEndpoint2 implements WebSocketMessageBrokerConfigurer {

    @Bean(name = "objectMapperEndpoint2")
    public ObjectMapper objectMapperEndpoint2() {
        ObjectMapper mapper = new ObjectMapper();
        // endpoint2的专属配置（与endpoint1不同）
        mapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);
        mapper.setSerializationInclusion(JsonInclude.Include.NON_NULL);
        return mapper;
    }

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

    @Override
    public void configureMessageBroker(MessageBrokerRegistry config) {
        config.setApplicationDestinationPrefixes("/app/endpoint2");
        config.enableSimpleBroker("/topic/endpoint2", "/queue/endpoint2");
        config.setUserDestinationPrefix("/user/endpoint2");
    }

    @Override
    public void configureMessageConverters(List<MessageConverter> converters) {
        MappingJackson2MessageConverter converter = new MappingJackson2MessageConverter();
        converter.setObjectMapper(objectMapperEndpoint2());
        converters.add(converter);
    }
}

2. 创建端点专属Controller #

每个Controller只处理对应端点的消息请求，通过应用前缀自动隔离。

Endpoint1专属Controller #

@Controller
public class Endpoint1WebSocketController {

    // 对应客户端发送的/app/endpoint1/request路径
    @MessageMapping("/request")
    // 发送到当前用户的/queue/endpoint1/response队列
    @SendToUser("/queue/endpoint1/response")
    public MyResponse handleEndpoint1Request(MyRequest request) {
        // endpoint1的业务逻辑实现
        return new MyResponse("Response from endpoint1: " + request.getContent());
    }
}

Endpoint2专属Controller #

@Controller
public class Endpoint2WebSocketController {

    @MessageMapping("/request")
    @SendToUser("/queue/endpoint2/response")
    public MyResponse handleEndpoint2Request(MyRequest request) {
        // endpoint2的业务逻辑实现
        return new MyResponse("Response from endpoint2: " + request.getContent());
    }
}

3. 隔离效果说明 #

• 消息路径隔离：连接/endpoint1的客户端只能发送/app/endpoint1/request，仅会被Endpoint1的Controller处理；连接/endpoint2的客户端同理，无法跨端点访问。
• Topic/Queue隔离：两个端点的消息代理路径完全独立（如/topic/endpoint1和/topic/endpoint2），客户端无法订阅到对方的消息通道。
• ObjectMapper独立：每个配置类使用自己的ObjectMapper，序列化/反序列化规则互不影响。

补充注意事项 #

• 如果使用外部消息代理（如RabbitMQ、ActiveMQ），需为每个端点配置独立的虚拟主机或路径前缀，实现物理层面的隔离。
• 配置类上的@Order注解用于指定加载顺序，避免配置冲突。

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