ActiveMQ消息队列技术融合Spring过程解析

2023-08-05 06:27:04 255

这篇文章主要介绍了ActiveMQ消息队列技术融合Spring过程解析,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下

一、业务逻辑

我想在修改一个物品的状态时，同时发送广播，给对应的监听器去实现，此商品存储到solr中，同时通过网页静态模板生成一个当前物品的详情页面，此时用到了广播机制

当我删除一个商品时，发送一个广播，给对应的监听器，同时删除solr中对应的物品。

广播机制：必须要同时在线，才能接收我的消息

使用消息中间件需要导入配置文件

发布广播：

if("1".equals(status)){
jmsTemplate.send(topicPageAndSolrDestination,newMessageCreator(){
@Override
publicMessagecreateMessage(Sessionsession)throwsJMSException{
TextMessagetextMessage=session.createTextMessage(String.valueOf(id));
returntextMessage;
}
});
}

监听器1，将当前商品存入solr中:操作solr的服务器配置文件





















#对应的用来监听执行往solr中保存库存的消息

监听器类

publicclassItemSearchListenerimplementsMessageListener{
@Autowired
privateSearchServicesearchService;
@Autowired
privateItemDaoitemDao;
@Override
publicvoidonMessage(Messagemessage){
//获取生产者发布的广播，往solr中添加库存列表
ActiveMQTextMessageatm=(ActiveMQTextMessage)message;
try{
//获取广播中的数据。
LonggoodsId=Long.valueOf(atm.getText());
//通过传过来的商品id去查询库存表
ItemQueryquery=newItemQuery();
ItemQuery.Criteriacriteria=query.createCriteria();
criteria.andGoodsIdEqualTo(goodsId);
//查询对应商品id的库存表
Listitems=itemDao.selectByExample(query);
//调用对应的方法，往solr中添加当前商品对应库存信息
searchService.importList(items);
}catch(JMSExceptione){
e.printStackTrace();
}
}
}

监听器类2：配置文件

监听器类2：生成静态网页模板

publicclassPageListenerimplementsMessageListener{
@Autowired
privateCmsServicecmsService;
@Override
publicvoidonMessage(Messagemessage){
ActiveMQTextMessageatm=(ActiveMQTextMessage)message;
try{
LonggoodsId=Long.valueOf(atm.getText());
MapgoodsData=cmsService.findGoodsData(goodsId);
cmsService.createStaticPage(goodsId,goodsData);
}catch(Exceptione){
e.printStackTrace();
}
}
}

点对点

当我删除商品时，我需要对应的服务进行删除solr中库存信息，添加和删除使用的是同一个服务中，使用的是上面的配置文件

//发布广播,
@Autowired
privateActiveMQTopictopicPageAndSolrDestination;
//在修改的代码方法中来广播发布当前商品的id

if(ids.length>0){
jmsTemplate.send(queueSolrDeleteDestination,newMessageCreator(){
@Override
publicMessagecreateMessage(Sessionsession)throwsJMSException{
TextMessagetextMessage=session.createTextMessage(String.valueOf(ids));
returntextMessage;
}
});
}

#执行删除solr中库存信息

publicclassItemDeleteListenerimplementsMessageListener{
@Autowired
privateSearchServicesearchService;

@Override
publicvoidonMessage(Messagemessage){
ActiveMQTextMessageatm=(ActiveMQTextMessage)message;
try{
LonggoodsId=Long.valueOf(atm.getText());
searchService.deleteById(goodsId);
}catch(JMSExceptione){
e.printStackTrace();
}
}
}

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票。

声明：本文内容来源于网络，版权归原作者所有，内容由互联网用户自发贡献自行上传，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任。如果您发现有涉嫌版权的内容，欢迎发送邮件至：czq8825#qq.com（发邮件时，请将#更换为@）进行举报，并提供相关证据，一经查实，本站将立刻删除涉嫌侵权内容。

ActiveMQ消息队列技术融合Spring过程解析

热门推荐

随机推荐