如何在Spring Integration中使用Control bus跨JVM启停集成组件

核心思路 #

利用你们已经在用的公共ActiveMQ实例，专门建立一个控制指令队列，所有节点都监听这个低流量的控制队列，收到对应启动指令后就调用自身的Control bus启动本地入站网关。 #

具体实现步骤 #

• 第一步：在所有JBoss节点的Spring Integration配置里新增一个针对控制队列的入站适配器，并发数设为1即可，自动启动属性设为true（控制指令本身频率极低，1个消费者几乎不会占用额外资源）

  <!-- 控制队列入站适配器配置示例 -->
  <int-jms:inbound-channel-adapter id="controlCommandAdapter"
                                   destination="controlQueue"
                                   channel="controlBusChannel"
                                   concurrent-consumers="1"
                                   auto-startup="true"/>
  <!-- 适配器输出通道绑定到本地Control bus -->
  <int:control-bus input-channel="controlBusChannel"/>
  

• 第二步：统一控制指令格式，直接沿用你本地调用Control bus的指令规则即可，比如要启动ID为jobInboundGateway的入站网关，指令内容就是@'jobInboundGateway'.start()
• 第三步：在触发Spring Batch作业的节点，作业启动逻辑里新增发送控制指令的步骤：

  // 控制指令发送代码示例
  @Autowired
  private JmsTemplate jmsTemplate;
  
  public void sendStartGatewayCommand(String targetGatewayId) {
      jmsTemplate.convertAndSend("controlQueue", "@'" + targetGatewayId + "'.start()");
  }
  

• 可选优化：如果只需要运行作业的单个节点启动入站网关，可以在指令里带上当前作业运行节点的唯一标识（比如JBoss节点名、服务IP），各个节点收到指令后先判断标识是否匹配自身，匹配才执行启动指令，避免所有节点同时启动消费者造成资源浪费。

注意事项 #

• 控制队列建议设置为持久化，避免服务重启期间指令丢失
• 如果作业运行结束后不需要继续保留入站网关消费者，可以用同样的逻辑发送@'yourInboundGatewayId'.stop()指令关闭组件，进一步节省资源
• 可以给控制指令增加简单的鉴权规则，比如加约定的签名请求头，避免恶意指令随意触发组件启停

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