动力节点ActiveMQ笔记-ActiveMQ与Spring 集成（三）

第三章 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>

0 条评论