創(chuàng)建2個工程，生產(chǎn)者和消費者

測試點對點和廣播

發(fā)送常見類型的消息

例如：文本(String)、對象(Object)
文本轉(zhuǎn)Long
String text = “123”;
Long.parseLong(text)
數(shù)組轉(zhuǎn)集合
Arrays.toArray(list)

引入依賴

<?xml version="1.0" encoding="UTF-8"?><project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><groupId>com.gblfy.activemq</groupId><artifactId>producer</artifactId><version>1.0-SNAPSHOT</version><packaging>war</packaging><name>producer Maven Webapp</name><url>http://www.gblfy.com</url><properties><!--全局編碼設(shè)置--><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding><!--全局maven編譯版本--><maven.compiler.source>1.8</maven.compiler.source><maven.compiler.target>1.8</maven.compiler.target><!--全局版本控制--><spring.version>4.2.4.RELEASE</spring.version></properties><dependencies><!-- Spring Start --><dependency><groupId>org.springframework</groupId><artifactId>spring-context</artifactId><version>${spring.version}</version></dependency><dependency><groupId>org.springframework</groupId><artifactId>spring-beans</artifactId><version>${spring.version}</version></dependency><dependency><groupId>org.springframework</groupId><artifactId>spring-webmvc</artifactId><version>${spring.version}</version></dependency><dependency><groupId>org.springframework</groupId><artifactId>spring-aspects</artifactId><version>${spring.version}</version></dependency><dependency><groupId>org.springframework</groupId><artifactId>spring-jms</artifactId><version>${spring.version}</version></dependency><dependency><groupId>org.springframework</groupId><artifactId>spring-context-support</artifactId><version>${spring.version}</version></dependency><dependency><groupId>org.springframework</groupId><artifactId>spring-test</artifactId><version>${spring.version}</version></dependency><!-- Spring End --><dependency><groupId>junit</groupId><artifactId>junit</artifactId></dependency><!--解析/反解析數(shù)據(jù)--><dependency><groupId>com.alibaba</groupId><artifactId>fastjson</artifactId></dependency><dependency><groupId>javassist</groupId><artifactId>javassist</artifactId></dependency><dependency><groupId>commons-codec</groupId><artifactId>commons-codec</artifactId></dependency><dependency><groupId>javax.servlet</groupId><artifactId>servlet-api</artifactId><scope>provided</scope></dependency><!--ActiveMQ Start--><dependency><groupId>org.apache.activemq</groupId><artifactId>activemq-client</artifactId><version>5.13.4</version></dependency><!--ActiveMQ End--></dependencies><build><plugins><!--Tomcat7插件--><plugin><groupId>org.apache.tomcat.maven</groupId><artifactId>tomcat7-maven-plugin</artifactId><version>2.2</version><configuration><!-- 指定端口 --><port>9004</port><!-- 請求路徑 --><path>/</path></configuration></plugin></plugins></build> </project>

消費者

引入配置文件

<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:context="http://www.springframework.org/schema/context" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:amq="http://activemq.apache.org/schema/core"xmlns:jms="http://www.springframework.org/schema/jms"xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsdhttp://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd"><!-- 真正可以產(chǎn)生Connection的ConnectionFactory，由對應(yīng)的 JMS服務(wù)廠商提供--> <bean id="targetConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory"> <property name="brokerURL" value="tcp://192.168.25.135:61616"/> </bean><!-- Spring用于管理真正的ConnectionFactory的ConnectionFactory --> <bean id="connectionFactory" class="org.springframework.jms.connection.SingleConnectionFactory"> <!-- 目標ConnectionFactory對應(yīng)真實的可以產(chǎn)生JMS Connection的ConnectionFactory --> <property name="targetConnectionFactory" ref="targetConnectionFactory"/> </bean> <!-- Spring提供的JMS工具類，它可以進行消息發(fā)送、接收等 --> <bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate"> <!-- 這個connectionFactory對應(yīng)的是我們定義的Spring提供的那個ConnectionFactory對象 --> <property name="connectionFactory" ref="connectionFactory"/> </bean> <!--這個是隊列目的地，導(dǎo)入索引庫--> <bean id="queueSolrDestination" class="org.apache.activemq.command.ActiveMQQueue"> <constructor-arg value="pinyougou_queue_solr"/> </bean> <!--這個是隊列目的地，導(dǎo)入索引庫--> <bean id="queueSolrDeleteDestination" class="org.apache.activemq.command.ActiveMQQueue"> <constructor-arg value="pinyougou_queue_solr_delete"/> </bean> <!--這個是訂閱模式 生成商品詳細頁--> <bean id="topicPageDestination" class="org.apache.activemq.command.ActiveMQTopic"> <constructor-arg value="pinyougou_topic_page"/> </bean> <!--這個是訂閱模式 刪除商品詳細頁--> <bean id="topicPageDeleteDestination" class="org.apache.activemq.command.ActiveMQTopic"> <constructor-arg value="pinyougou_topic_page_delete"/> </bean> </beans>

注：掃描包，如果spring的配置文件中有此配置可以省略
在需要發(fā)送消息的類中，注入2個對象：

@Autowired private Destination queueSolrDestination;//用于發(fā)送solr導(dǎo)入的消息 @Autowired private JmsTemplate jmsTemplate;

假設(shè)發(fā)送的數(shù)據(jù)是一個list，list沒有實現(xiàn)序列化，而發(fā)送的消息類型，如果是對象必須實現(xiàn)序列化

List<TbItem> itemList = goodsService.findItemListByGoodsIdandStatus(ids, status);

建議發(fā)送消息類型采用文本類型
利用fastjson工具類，將list轉(zhuǎn)換為json字符串，接收的時候，在轉(zhuǎn)回來是很方便的

final String jsonString = JSON.toJSONString(itemList); jmsTemplate.send(queueSolrDestination, new MessageCreator() { @Overridepublic Message createMessage(Session session) throws JMSException { return session.createTextMessage(jsonString);}});

消費者客戶端
引入依賴和生產(chǎn)者一樣
引入配置文件applicationContext-jms-consumer.xml

<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:context="http://www.springframework.org/schema/context" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:amq="http://activemq.apache.org/schema/core"xmlns:jms="http://www.springframework.org/schema/jms"xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsdhttp://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd"><!-- 真正可以產(chǎn)生Connection的ConnectionFactory，由對應(yīng)的 JMS服務(wù)廠商提供--> <bean id="targetConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory"> <property name="brokerURL" value="tcp://192.168.25.135:61616"/> </bean><!-- Spring用于管理真正的ConnectionFactory的ConnectionFactory --> <bean id="connectionFactory" class="org.springframework.jms.connection.SingleConnectionFactory"> <!-- 目標ConnectionFactory對應(yīng)真實的可以產(chǎn)生JMS Connection的ConnectionFactory --> <property name="targetConnectionFactory" ref="targetConnectionFactory"/> </bean> <!--這個是隊列目的地，導(dǎo)入索引庫--> <bean id="queueSolrDestination" class="org.apache.activemq.command.ActiveMQQueue"> <constructor-arg value="pinyougou_queue_solr"/> </bean> <!-- 消息監(jiān)聽容器 導(dǎo)入索引庫--><bean class="org.springframework.jms.listener.DefaultMessageListenerContainer"><property name="connectionFactory" ref="connectionFactory" /><property name="destination" ref="queueSolrDestination" /><property name="messageListener" ref="itemSearchListener" /></bean><!--這個是隊列目的地，導(dǎo)入索引庫--> <bean id="queueSolrDeleteDestination" class="org.apache.activemq.command.ActiveMQQueue"> <constructor-arg value="pinyougou_queue_solr_delete"/> </bean> <!-- 消息監(jiān)聽容器 導(dǎo)入索引庫--><bean class="org.springframework.jms.listener.DefaultMessageListenerContainer"><property name="connectionFactory" ref="connectionFactory" /><property name="destination" ref="queueSolrDeleteDestination" /><property name="messageListener" ref="itemDeleteListener" /></bean></beans>

新建一個監(jiān)聽類itemSearchListener接收文本類型消息
注，這個監(jiān)聽類上加上@Component注解，并且能被spring的包掃描掃描到
下面監(jiān)聽類的包是：package com.pinyougou.search.service.impl;
在此項目spring的配置文件中有掃描包的配置，因此，可以被掃描到

package com.pinyougou.search.service.impl;import java.util.List;import javax.jms.JMSException; import javax.jms.Message; import javax.jms.MessageListener; import javax.jms.TextMessage;import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component;import com.alibaba.fastjson.JSON; import com.pinyougou.pojo.TbItem; import com.pinyougou.search.service.ItemSearchService; @Component public class ItemSearchListener implements MessageListener {@Autowiredprivate ItemSearchService itemSearchService;@Overridepublic void onMessage(Message message) {TextMessage textMessage=(TextMessage)message;try {String text = textMessage.getText();//json字符串System.out.println("監(jiān)聽到消息:"+text);List<TbItem> itemList = JSON.parseArray(text, TbItem.class);itemSearchService.importList(itemList);System.out.println("導(dǎo)入到solr索引庫");} catch (JMSException e) {// TODO Auto-generated catch blocke.printStackTrace();}} }

發(fā)送對象類型消息

@Autowiredprivate JmsTemplate jmsTemplate;@Autowiredprivate Destination queueTextDestination;/*** 發(fā)送文本消息* @param text*/public void sendTextMessage(final String text){jmsTemplate.send(queueTextDestination, new MessageCreator() {public Message createMessage(Session session) throws JMSException { // return session.createTextMessage(text);return session.createObjectMessage(對象);}});}

新建一個監(jiān)聽接收對象類型消息

在這里插入代碼片package com.pinyougou.search.service.impl;import java.util.Arrays;import javax.jms.JMSException; import javax.jms.Message; import javax.jms.MessageListener; import javax.jms.ObjectMessage;import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component;import com.pinyougou.search.service.ItemSearchService; @Component public class ItemDeleteListener implements MessageListener {@Autowiredprivate ItemSearchService itemSearchService;@Overridepublic void onMessage(Message message) {ObjectMessage objectMessage =(ObjectMessage)message;try {Long[] goodsIds= (Long[]) objectMessage.getObject();System.out.println("監(jiān)聽獲取到消息："+goodsIds);itemSearchService.deleteByGoodsIds(Arrays.asList(goodsIds));System.out.println("執(zhí)行索引庫刪除");} catch (JMSException e) {// TODO Auto-generated catch blocke.printStackTrace();}}}

總結(jié)

以上是生活随笔為你收集整理的企业级实战03_真实项目实战SpringMVC整合ActiveMQ的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。