在 ActiveMQ 中使用 Spring 集成 JMS 实现发布订阅

Question

我在 ActiveMQ 中使用 Spring 集成 API 的 PublishSubscribe Channel 开发了生产者和消费者。我可以使用该实现发布和接收消息，但只有一个服务激活器以循环方式使用消息。我需要确定它是否正确。以下是我的配置：

制作方：

<int:publish-subscribe-channel id="jmsPubSubChannel" />

<int-jms:outbound-channel-adapter channel="jmsPubSubChannel"
                                      destination-name="${jms.topic.name}"
                                      pub-sub-domain="true" 
                                      connection-factory="connectionFactory" />

<!-- Define the ActiveMQ connection factory -->
<bean id="connectionFactory" class="org.apache.activemq.spring.ActiveMQConnectionFactory">
        <property name="brokerURL" value="${jms.broker.url}"/>
        <property name="userName" value="${jms.username}" />
        <property name="password" value="${jms.password}" />
</bean>

消费者端：

<jms:message-driven-channel-adapter id="messageDrivenAdapter"
                                            channel="jmsPubSubChannel"
                                            destination-name="${jms.topic.name}"
                                            pub-sub-domain="true" />

<!-- Subscriber - offeringmsg -->
<int:service-activator id="offeringmsg1" input-channel="jmsPubSubChannel" ref="impl1" />

<int:service-activator id="offeringmsg2" input-channel="jmsPubSubChannel" ref="impl2" />

<bean id="impl1" class="com.intuit.imp.mql.MessageListenerImpl" />

<bean id="impl2" class="com.intuit.imp.mql.MessageListenerImpl2" />

<!-- Define the ActiveMQ connection factory -->
<bean id="connectionFactory" class="org.apache.activemq.spring.ActiveMQConnectionFactory">
            <property name="brokerURL" value="${jms.broker.url}"/>
            <property name="userName" value="${jms.username}" />
            <property name="password" value="${jms.password}" />
</bean>

Answer 1

您需要添加

<int:publish-subscribe-channel id="jmsPubSubChannel" />

在消费者方面。

如果未显式声明通道，则默认为具有循环语义的直接通道。

在生产者方面，由于只有一个消费者（出站通道适配器），因此它不需要是一个 pub/sub 通道。

在 ActiveMQ 中使用 Spring 集成 JMS 实现发布订阅

Implementing Publish Subscribe using Spring Integration JMS in ActiveMQ

java

activemq

spring-integration

spring-jms