ActiveMQ消息隊列技術融合Spring過程解析
更新時間：2019年11月28日 16:59:24 作者：憤青程序猿
這篇文章主要介紹了ActiveMQ消息隊列技術融合Spring過程解析,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下
這篇文章主要介紹了ActiveMQ消息隊列技術融合Spring過程解析,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下
一、業(yè)務邏輯
我想在修改一個物品的狀態(tài)時，同時發(fā)送廣播，給對應的監(jiān)聽器去實現(xiàn)，此商品存儲到solr中，同時通過網(wǎng)頁靜態(tài)模板生成一個當前物品的詳情頁面，此時用到了廣播機制
當我刪除一個商品時，發(fā)送一個廣播，給對應的監(jiān)聽器，同時刪除solr中對應的物品。
廣播機制：必須要同時在線，才能接收我的消息
使用消息中間件需要導入配置文件
<?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.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context.xsd">
<!-- 真正可以產生Connection的ConnectionFactory，由對應的 JMS服務廠商提供-->
<bean id="targetConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
<property name="brokerURL" value="tcp://192.168.200.128:61616"/>
</bean>
<!-- Spring用于管理真正的ConnectionFactory的ConnectionFactory -->
<bean id="connectionFactory" class="org.springframework.jms.connection.SingleConnectionFactory">
<!-- 目標ConnectionFactory對應真實的可以產生JMS Connection的ConnectionFactory -->
<property name="targetConnectionFactory" ref="targetConnectionFactory"/>
</bean>
<!-- Spring提供的JMS工具類，它可以進行消息發(fā)送、接收等 -->
<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
<!-- 這個connectionFactory對應的是我們定義的Spring提供的那個ConnectionFactory對象 -->
<property name="connectionFactory" ref="connectionFactory"/>
</bean>
<!-- 發(fā)布訂閱模式, 商品導入索引庫和生成靜態(tài)頁面 -->
<bean id="topicPageAndSolrDestination" class="org.apache.activemq.command.ActiveMQTopic">
<!--將商品上架所有的商品的id發(fā)送到這個隊列中-->
<constructor-arg value="youlexuan_topic_page_solr"/>
</bean>
<!-- 點對點模式-->
<bean id="queueSolrDeleteDestination" class="org.apache.activemq.command.ActiveMQQueue">
<!--將商品上架所有的商品的id發(fā)送到這個隊列中-->
<constructor-arg value="youlexuan_queue_solr_delete"/>
</bean>
</beans>
發(fā)布廣播：
if ("1".equals(status)){
jmsTemplate.send(topicPageAndSolrDestination, new MessageCreator() {
@Override
public Message createMessage(Session session) throws JMSException {
TextMessage textMessage = session.createTextMessage(String.valueOf(id));
return textMessage;
}
});
}
監(jiān)聽器1，將當前商品存入solr中:操作solr的服務器配置文件
<?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.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context.xsd">
<!--產生Connection-->
<bean id="targetConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
<property name="brokerURL" value="tcp://192.168.200.128:61616"/>
</bean>
<!--spring 管理connectionFactory-->
<bean id="connectionFactory" class="org.springframework.jms.connection.SingleConnectionFactory">
<property name="targetConnectionFactory" ref="targetConnectionFactory"/>
</bean>
<!--發(fā)布訂閱模式 將數(shù)據(jù)導入solr 索引庫-->
<bean id="topicPageAndSolrDestination" class="org.apache.activemq.command.ActiveMQTopic">
<constructor-arg value="youlexuan_topic_page_solr"/>
</bean>
<!--發(fā)布訂閱模式 消息監(jiān)聽容器 將數(shù)據(jù)導入solr 索引庫-->
<bean class="org.springframework.jms.listener.DefaultMessageListenerContainer">
<property name="connectionFactory" ref="connectionFactory" />
<property name="destination" ref="topicPageAndSolrDestination" />
<property name="messageListener" ref="pageAndSolrListener" />
</bean>
#對應的用來監(jiān)聽執(zhí)行往solr中保存庫存的消息
<bean id="pageAndSolrListener" class="com.ghh.sellergoods.service.listener.ItemSearchListener"></bean>
<!--點對點的模式 刪除索引庫-->
<bean id="queueSolrDeleteDestination" class="org.apache.activemq.command.ActiveMQQueue">
<!--指定從這個隊列中 接收下架商品的-->
<constructor-arg value="youlexuan_queue_solr_delete"/>
</bean>
<!--點對點的模式 消息監(jiān)聽器 刪除索引庫-->
<bean class="org.springframework.jms.listener.DefaultMessageListenerContainer">
<property name="connectionFactory" ref="connectionFactory" />
<property name="destination" ref="queueSolrDeleteDestination" />
<property name="messageListener" ref="itemDeleteListener" />
</bean>
<bean id="itemDeleteListener" class="com.ghh.sellergoods.service.listener.ItemDeleteListener"></bean>
</beans>
監(jiān)聽器類
public class ItemSearchListener implements MessageListener {
@Autowired
private SearchService searchService;
@Autowired
private ItemDao itemDao;
@Override
public void onMessage(Message message) {
//獲取生產者發(fā)布的廣播，往solr中添加庫存列表
ActiveMQTextMessage atm = (ActiveMQTextMessage) message;
try {
//獲取廣播中的數(shù)據(jù)。
Long goodsId = Long.valueOf(atm.getText());
//通過傳過來的商品id去查詢庫存表
ItemQuery query = new ItemQuery();
ItemQuery.Criteria criteria = query.createCriteria();
criteria.andGoodsIdEqualTo(goodsId);
//查詢對應商品id的庫存表
List<Item> items = itemDao.selectByExample(query);
//調用對應的方法，往solr中添加當前商品對應庫存信息
searchService.importList(items);
} catch (JMSException e) {
e.printStackTrace();
}
}
}
監(jiān)聽器類2：配置文件
<?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.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context.xsd">
<!--產生Connection工廠類-->
<bean id="targetConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
<property name="brokerURL" value="tcp://192.168.200.128:61616"/>
</bean>
<!--spring管理工廠類-->
<bean id="connectionFactory" class="org.springframework.jms.connection.SingleConnectionFactory">
<property name="targetConnectionFactory" ref="targetConnectionFactory"/>
</bean>
<!--發(fā)布訂閱模式 生成頁面-->
<bean id="topicPageAndSolrDestination" class="org.apache.activemq.command.ActiveMQTopic">
<!--指定從這個隊列上獲取上架的商品id-->
<constructor-arg value="youlexuan_topic_page_solr"/>
</bean>
<!--發(fā)布訂閱模式 消息監(jiān)聽器 生成頁面-->
<bean class="org.springframework.jms.listener.DefaultMessageListenerContainer">
<property name="connectionFactory" ref="connectionFactory" />
<property name="destination" ref="topicPageAndSolrDestination" />
<property name="messageListener" ref="pageListener" />
</bean>
<bean id="pageListener" class="com.ghh.core.service.listener.PageListener"></bean>
</beans>
監(jiān)聽器類2：生成靜態(tài)網(wǎng)頁模板
public class PageListener implements MessageListener {
@Autowired
private CmsService cmsService;
@Override
public void onMessage(Message message) {
ActiveMQTextMessage atm = (ActiveMQTextMessage) message;
try {
Long goodsId = Long.valueOf(atm.getText());
Map<String, Object> goodsData = cmsService.findGoodsData(goodsId);
cmsService.createStaticPage(goodsId,goodsData);
} catch (Exception e) {
e.printStackTrace();
}
}
}
點對點
當我刪除商品時，我需要對應的服務進行刪除solr中庫存信息，添加和刪除使用的是同一個服務中，使用的是上面的配置文件
//發(fā)布廣播,
@Autowired
private ActiveMQTopic topicPageAndSolrDestination;
//在修改的代碼方法中來廣播發(fā)布當前商品的id
if (ids.length>0) {
jmsTemplate.send(queueSolrDeleteDestination, new MessageCreator() {
@Override
public Message createMessage(Session session) throws JMSException {
TextMessage textMessage = session.createTextMessage(String.valueOf(ids));
return textMessage;
}
});
}
#執(zhí)行刪除solr中庫存信息
public class ItemDeleteListener implements MessageListener {
@Autowired
private SearchService searchService;
@Override
public void onMessage(Message message) {
ActiveMQTextMessage atm = (ActiveMQTextMessage) message;
try {
Long goodsId = Long.valueOf(atm.getText());
searchService.deleteById(goodsId);
} catch (JMSException e) {
e.printStackTrace();
}
}
}
以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持腳本之家。
相關文章
Java子線程調用RequestContextHolder.getRequestAttributes()方法問題詳解
這篇文章主要介紹了Java子線程調用RequestContextHolder.getRequestAttributes()方法問題處理，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2022-09-09
本文將探討三種下一代 JVM 語言：Groovy、Scala 和 Clojure，比較并對比新的功能和范例，讓 Java 開發(fā)人員對自己近期的未來發(fā)展有大體的認識。,需要的朋友可以參考下2019-06-06
Mybatis如何傳入多個參數(shù)(實體類型和基本類型)
這篇文章主要介紹了Mybatis如何傳入多個參數(shù)(實體類型和基本類型)，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2022-06-06
這篇文章主要介紹了JPA?使用criteria簡單查詢工具類方式，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2021-12-12
idea install 時提示jdk的某個jar包的包不存在的問題
這篇文章主要介紹了idea install 時提示jdk的某個jar包的包不存在的問題,本文給大家分享解決方法，對大家的學習或工作具有一定的參考借鑒價值，需要的朋友可以參考下2020-09-09
這篇文章主要介紹了SpringBoot整合Lettuce redis過程解析,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下2019-10-10
這篇文章主要為大家介紹了java設計模式Ctrl?C和Ctrl?V的原型模式詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步，早日升職加薪2023-02-02
這篇文章主要介紹了關于replaceFirst使用時的注意事項，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2022-03-03
這篇文章主要介紹了java中使用url進行編碼和解碼，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2022-08-08
Spring?@bean和@component注解區(qū)別
本文主要介紹了Spring?@bean和@component注解區(qū)別，文中通過示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下2022-01-01