[activeMQ]分布式开发中消息队列activeMQ和spring整合配置文件

不念不忘少年蓝@ 2022-01-24 00:25 164阅读 0赞

**搭配使用**  
dao层配置文件(applicationContext-dao.xml):  
[https://blog.csdn.net/a755199443/article/details/90272909][https_blog.csdn.net_a755199443_article_details_90272909]

service层配置文件(applicationContext-service.xml):  
[https://blog.csdn.net/a755199443/article/details/90272977][https_blog.csdn.net_a755199443_article_details_90272977]

事务管理配置文件(applicationContext-trans.xml):  
[https://blog.csdn.net/a755199443/article/details/90273049][https_blog.csdn.net_a755199443_article_details_90273049]

**消费者端activeMQ配置:**  
文件名:applicationContext-jms.xml

<?xml version="1.0" encoding="UTF-8"?>
    <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:jms="http://www.springframework.org/schema/jms" xmlns:amq="http://activemq.apache.org/schema/core" xsi:schemaLocation=" http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/jms http://www.springframework.org/schema/jms/spring-jms.xsd http://activemq.apache.org/schema/core http://activemq.apache.org/schema/core/activemq-core.xsd">
    	
    	
    	<amq:connectionFactory brokerURL="tcp://192.168.70.151:61616" userName="admin" password="admin" id="amqConnectionFactory"/>
    
    	
    	
    	<bean id="connectionFactory" class="org.springframework.jms.connection.CachingConnectionFactory">
    		<property name="targetConnectionFactory" ref="amqConnectionFactory"></property>
    		<property name="sessionCacheSize" value="3"></property>
    	</bean>
    	
    	
    	
    	<jms:listener-container acknowledge="auto" container-type="default" destination-type="queue" connection-factory="connectionFactory" >
    		
    		<jms:listener destination="test-spring" ref="myListener"/>
    	</jms:listener-container>
    	
    </beans>

**提供者端activeMQ配置:**  
文件名:applicationContext-jms.xml

<?xml version="1.0" encoding="UTF-8"?>
    <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:jms="http://www.springframework.org/schema/jms" xmlns:context="http://www.springframework.org/schema/context" xmlns:amq="http://activemq.apache.org/schema/core" xsi:schemaLocation=" http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/jms http://www.springframework.org/schema/jms/spring-jms.xsd http://activemq.apache.org/schema/core http://activemq.apache.org/schema/core/activemq-core.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd">
    
    
    	
    	
    	<amq:connectionFactory brokerURL="tcp://192.168.110.129:61616" userName="admin" password="admin" id="amqConnectionFactory" />
    		
    	
    	<bean id="pooledConnectionFactory" class="org.apache.activemq.pool.PooledConnectionFactoryBean">
    		<property name="connectionFactory" ref="amqConnectionFactory"></property>
    		<property name="maxConnections" value="10"></property>
    	</bean>
    	
    	
    	
    	<bean id="connectionFactory" class="org.springframework.jms.connection.CachingConnectionFactory">
    		<property name="targetConnectionFactory" ref="amqConnectionFactory"></property>
    		<property name="sessionCacheSize" value="3"></property>
    	</bean>
    
    	
    	<bean id="template" class="org.springframework.jms.core.JmsTemplate">
    		
    		<property name="connectionFactory" ref="connectionFactory"></property>
    		
    		<property name="defaultDestinationName" value="test-spring"></property>
    	</bean>
    </beans>

[https_blog.csdn.net_a755199443_article_details_90272909]: https://blog.csdn.net/a755199443/article/details/90272909
[https_blog.csdn.net_a755199443_article_details_90272977]: https://blog.csdn.net/a755199443/article/details/90272977
[https_blog.csdn.net_a755199443_article_details_90273049]: https://blog.csdn.net/a755199443/article/details/90273049