同一StompSessionManager实例能否用于不同目标地址的Spring Integration流？

我有两个Spring Integration流：一个通过StompInboundChannelAdapter监听指定目标地址的消息，另一个通过StompMessageHandler向另一目标地址发送消息，两者连接同一STOMP服务器。请问是否可以为这两个流使用同一个StompSessionManager实例？还是每个流都需要单独的实例？我尝试采用单例实例配置（如下代码），目前运行正常，但不确定该方式是否正确或存在遗漏：

@Configuration
public class StompSessionManagerConfiguration {

  @Value("${host}")
  private String host;

  @Value("${port}")
  private Integer port;

  @Value("${login}")
  private String login;

  @Value("${passcode}")
  private String passcode;

  @Bean
  public StompSessionManager stompSessionManager() {
    ReactorNettyTcpStompClient stompClient = new ReactorNettyTcpStompClient(host, port);
    ReactorNettyTcpStompSessionManager stompSessionManager = 
        new ReactorNettyTcpStompSessionManager(stompClient);
    stompSessionManager.setConnectHeaders(connectHeaders());
    return stompSessionManager;
  }

  public StompHeaders connectHeaders() {
    StompHeaders connectHeaders = new StompHeaders();
    connectHeaders.setLogin(login);
    connectHeaders.setPasscode(passcode);
    return connectHeaders;
  }
}

@Configuration
public class IncomingMessageFlowConfiguration {

  @Autowired
  private StompSessionManager stompSessionManager;

  @Bean
  public IntegrationFlow incomingMessageFlow() {
    return IntegrationFlow.from(stompInboundChannelAdapter())
        .channel("incomingMessageChannel").get();
  }

  public StompInboundChannelAdapter stompInboundChannelAdapter() {
    StompInboundChannelAdapter adapter = 
        new StompInboundChannelAdapter(stompSessionManager, "incomingDestination");
    adapter.setPayloadType(byte[].class);
    return adapter;
  }
}

@Configuration
public class OutgoingMessageFlowConfiguration {

  @Autowired
  private StompSessionManager stompSessionManager;

  @Bean
  public IntegrationFlow outgoingMessageFlow() {
    return IntegrationFlow.from("outgoingMessageChannel")
        .handle(stompMessageHandler()).get();
  }

  public StompMessageHandler stompMessageHandler() {
    StompMessageHandler stompMessageHandler = new StompMessageHandler(stompSessionManager);
    stompMessageHandler.setDestination("outgoingDestination");
    return stompMessageHandler;
  }
}

完全可以为这两个流共用同一个StompSessionManager实例，你的单例配置方式是正确且推荐的。

原因如下：

• StompSessionManager本身是线程安全的，核心职责就是管理到STOMP服务器的连接会话，设计上支持多个客户端组件（如StompInboundChannelAdapter和StompMessageHandler）共享使用。
• 复用同一个实例能避免创建多个独立的TCP连接，减少服务器端和客户端的资源消耗，提升连接效率。
• 只要两个流连接的是同一STOMP服务器、使用相同的连接参数（登录凭证、心跳配置等），就不需要为每个流单独创建StompSessionManager。

补充说明：

• 若后续需要连接不同的STOMP服务器，或者需要使用不同的连接凭证/配置，此时才需要创建多个StompSessionManager实例。
• 你的配置中，connectHeaders()方法每次调用都会生成新的StompHeaders对象，但由于是在StompSessionManager初始化阶段一次性设置，且后续不会修改这些头信息，因此不存在线程安全问题，无需调整。

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