动力节点ActiveMQ笔记第三章 ActiveMQ 与 Spring 集成
3-1 ActiveMQ 与 Spring 集成配置
spring-jms
<!--spring-jms依赖 -->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-jms</artifactId>
<version>4.3.13.RELEASE</version>
</dependency>
<!-- JMS规范的jar依赖 -->
<dependency>
<groupId>javax.jms</groupId>
<artifactId>javax.jms-api</artifactId>
<version>2.0.1</version>
</dependency>
<!--activemq的jar依赖 -->
<dependency>
<groupId>org.apache.activemq</groupId>
<artifactId>activemq-client</artifactId>
<version>5.15.4</version>
</dependency>
connectionFactory
<!-- 配置一个连接工厂 -->
<bean id="connectionFactory"
class="org.apache.activemq.ActiveMQConnectionFactory">
<property name="brokerURL"
value="tcp://192.168.230.128:61616"/>
<property name="userName" value="system"/>
<property name="password" value="A123456"/>
</bean>
JmsTemplate
<!-- 配置JmsTemplate -->
<bean id="jmsTemplate"
class="org.springframework.jms.core.JmsTemplate">
<property name="connectionFactory" ref="connectionFactory" />
<property name="defaultDestinationName" value="myQueue" />
</bean>
3-2 ActiveMQ 与 Spring 集成点对点消息
同步接收
异步接收
3-3 ActiveMQ 与 Spring 集成发布订阅消息
同步接收
异步接收
3-4 ActiveMQ 与 Spring 集成同步/异步接收
<!-- 我们自定义的一个消息监听器 -->
<bean id="receiverListener"
class="com.bjpowernode.spring.jms.listener.MyMessageListener"
/>
<!-- 配置一个sping监听器的容器 -->
<bean
class="org.springframework.jms.listener.DefaultMessageListener
Container">
<property name="connectionFactory" ref="connectionFactory"/>
<property name="destinationName" value="jms.queue"/>
<property name="messageListener" ref="receiverListener" />
</bean>