这篇文章将为大家详细讲解有关怎么解析ActiveMQ消息队列技术融合Spring过程，文章内容质量较高，因此小编分享给大家做个参考，希望大家阅读完这篇文章后对相关知识有一定的了解。

成都创新互联公司专注为客户提供全方位的互联网综合服务，包含不限于成都做网站、网站制作、张家口网络推广、微信平台小程序开发、张家口网络营销、张家口企业策划、张家口品牌公关、搜索引擎seo、人物专访、企业宣传片、企业代运营等，从售前售中售后，我们都将竭诚为您服务，您的肯定，是我们大的嘉奖；成都创新互联公司为所有大学生创业者提供张家口建站搭建服务，24小时服务热线：028-86922220，官方网址：www.cdcxhl.com

一、业务逻辑

我想在修改一个物品的状态时，同时发送广播，给对应的监听器去实现，此商品存储到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());      Map goodsData = cmsService.findGoodsData(goodsId);      cmsService.createStaticPage(goodsId,goodsData);    } catch (Exception e) {      e.printStackTrace();    }  }}

点对点

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

//发布广播,  @Autowired  private ActiveMQTopic topicPageAndSolrDestination;//在修改的代码方法中来广播发布当前商品的idif (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过程就分享到这里了，希望以上内容可以对大家有一定的帮助，可以学到更多知识。如果觉得文章不错，可以把它分享出去让更多的人看到。

分享名称：怎么解析ActiveMQ消息队列技术融合Spring过程-创新互联
网站链接：http://azwzsj.com/article/depoph.html