0

我们正在使用 spring 集成/spring 批处理作业在连接到公共 ActiveMQ 队列的多个 jboss 节点中运行作业。对于监听队列/通道的入站网关,我们已将自动启动配置为 false。自动启动的问题是,如果入站网关具有更多并发消费者属性,那么即使在需要这些消费者线程的作业频率非常少的情况下,在服务器启动期间启动的所有节点中也会有这么多数量的消费者线程处于活动状态。在这种情况下,春季批处理作业在 4 个节点之一中触发。我们可以在作业启动时利用控制总线启动入站网关组件,它适用于同一个JVM。但是在工作节点中(运行在不同的 JVM 中),

4

1 回答 1

1

控制总线只是一个从其输入通道消费消息的端点。通道可以是内存中的通道,也可以是基于某些共享存储的分布式通道。例如,提到的 ActiveMQ 只是 JMS 供应商,因此您可以使用 JMS Inbound Endpoint 来使用来自 ActiveMQ 主题的命令消息并将其生成到该控制总线输入通道:https ://docs.spring.io/spring-integration /docs/current/reference/html/jms.html#jms-message-driven-channel-adapter

于 2021-11-10T02:59:41.537 回答