【参考】spring整合activemq

约定不等于承诺〃 2022-08-21 07:47 53阅读 0赞

activemq的pom依赖：

<dependency>
    			<groupId>org.apache.activemq</groupId>
    			<artifactId>activemq-all</artifactId>
    		</dependency>
    		<dependency>
    			<groupId>org.apache.activemq</groupId>
    			<artifactId>activemq-pool</artifactId>
    		</dependency>

</pre><pre code_snippet_id="1658506" snippet_file_name="blog_20160423_4_1122630" name="code" class="java">消息提供方:

<bean id="activeMQConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
    			
    			<property name="brokerURL" value="tcp://192.168.200.128:61616"/>
    			
    			<property name="userName" value="admin"/>
    			<property name="password" value="admin"/>
    		</bean>
    		
    		<bean id="pooledConnectionFactoryBean" class="org.apache.activemq.pool.PooledConnectionFactoryBean">
    			
    			<property name="connectionFactory" ref="activeMQConnectionFactory"/>
    			
    			<property name="maxConnections" value="2"/>
    		</bean>
    		
    		
    		<bean id="singleConnectionFactory" class="org.springframework.jms.connection.SingleConnectionFactory">
    			
    			<property name="targetConnectionFactory" ref="pooledConnectionFactoryBean"/>
    		</bean>
    		
    		
    		<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
    			
    			<property name="connectionFactory" ref="singleConnectionFactory"/>
    			
    			<property name="defaultDestinationName" value="pId"/>
    		</bean>
    		
    </beans>

消息消费方:

![Image 1][]

![Center][]

保存商品信息:

![Center 1][]

![Image 1][]

商品上架更新solr索引:

![Image 1][]![Center 2][]

[Image 1]: 
[Center]: /images/20220724/d6caeb8a15064614a348bc9d0f11d942.png
[Center 1]: /images/20220724/1da38cfee823433383921ffe782a4ee6.png
[Center 2]: /images/20220724/4bf85bb737024ec7b54a38bc3c621429.png