ActiveMQ消息队列技术融合Spring的示例分析-创新互联
小编给大家分享一下ActiveMQ消息队列技术融合Spring的示例分析,相信大部分人都还不怎么了解,因此分享这篇文章给大家参考一下,希望大家阅读完这篇文章后大有收获,下面让我们一起去了解一下吧!
创新互联公司专业为企业提供华宁网站建设、华宁做网站、华宁网站设计、华宁网站制作等企业网站建设、网页设计与制作、华宁企业网站模板建站服务,十年华宁做网站经验,不只是建网站,更提供有价值的思路和整体网络服务。一、业务逻辑
我想在修改一个物品的状态时,同时发送广播,给对应的监听器去实现,此商品存储到solr中,同时通过网页静态模板生成一个当前物品的详情页面,此时用到了广播机制
当我删除一个商品时,发送一个广播,给对应的监听器,同时删除solr中对应的物品。
广播机制:必须要同时在线,才能接收我的消息
使用消息中间件需要导入配置文件
发布广播:
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; } }); }
监听器1,将当前商品存入solr中:操作solr的服务器配置文件
#对应的用来监听执行往solr中保存库存的消息
监听器类
public class ItemSearchListener implements MessageListener { @Autowired private SearchService searchService; @Autowired private ItemDao itemDao; @Override public void onMessage(Message message) { //获取生产者发布的广播,往solr中添加库存列表 ActiveMQTextMessage atm = (ActiveMQTextMessage) message; try { //获取广播中的数据。 Long goodsId = Long.valueOf(atm.getText()); //通过传过来的商品id去查询库存表 ItemQuery query = new ItemQuery(); ItemQuery.Criteria criteria = query.createCriteria(); criteria.andGoodsIdEqualTo(goodsId); //查询对应商品id的库存表 List- items = itemDao.selectByExample(query); //调用对应的方法,往solr中添加当前商品对应库存信息 searchService.importList(items); } catch (JMSException e) { e.printStackTrace(); } } }
监听器类2:配置文件
监听器类2:生成静态网页模板
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()); MapgoodsData = cmsService.findGoodsData(goodsId); cmsService.createStaticPage(goodsId,goodsData); } catch (Exception e) { e.printStackTrace(); } } }
点对点
当我删除商品时,我需要对应的服务进行删除solr中库存信息,添加和删除使用的是同一个服务中,使用的是上面的配置文件
//发布广播, @Autowired private ActiveMQTopic topicPageAndSolrDestination; //在修改的代码方法中来广播发布当前商品的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; } }); }
#执行删除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(); } } }
以上是“ActiveMQ消息队列技术融合Spring的示例分析”这篇文章的所有内容,感谢各位的阅读!相信大家都有了一定的了解,希望分享的内容对大家有所帮助,如果还想学习更多知识,欢迎关注创新互联网站建设公司行业资讯频道!
另外有需要云服务器可以了解下创新互联建站www.cdcxhl.com,海内外云服务器15元起步,三天无理由+7*72小时售后在线,公司持有idc许可证,提供“云服务器、裸金属服务器、高防服务器、香港服务器、美国服务器、虚拟主机、免备案服务器”等云主机租用服务以及企业上云的综合解决方案,具有“安全稳定、简单易用、服务可用性高、性价比高”等特点与优势,专为企业上云打造定制,能够满足用户丰富、多元化的应用场景需求。
新闻标题:ActiveMQ消息队列技术融合Spring的示例分析-创新互联
分享路径:http://scyanting.com/article/dshsdp.html