ActiveMQ在分布式项目中的实际应用

清疚 2022-09-02 05:24 169阅读 0赞

**点击关注公众号，利用****碎片时间学习****![809c45a10b7156f19d8456df3af365fc.png][]**

### 具体需求： ###

后台添加商品后，需要执行两个操作：

1.  同步索引库（商品搜索使用了Solr实现）
2.  生成静态页面（使用freemarker）

### 实现构思： ###

使用消息队列。MQ作为消息中间件，传递的消息内容为新增商品的ID。

![786abd2d5349df37381c15c4859b97a4.png][]

### 准备工作： ###

**在需要的地方添加相应的依赖（基础依赖就不再说了）**

商品服务需要发送商品添加消息，所以需要添加三个依赖，分别是整合Spring需要的两个Jar和ActiveMQ的Jar：

<dependency>
     <groupId>org.springframework</groupId>
     <artifactId>spring-jms</artifactId>
    </dependency>
    <dependency>
     <groupId>org.springframework</groupId>
     <artifactId>spring-context-support</artifactId>
    </dependency>
    <dependency>
     <groupId>org.apache.activemq</groupId>
     <artifactId>activemq-all</artifactId>
    </dependency>

索引服务需要接收消息，然后同步索引库，所以需要添加四个依赖，分别是整合Spring需要的两个Jar和ActiveMQ的Jar和Solr客户端的Jar：

商品详情工程需要就收消息，然后生成静态页面，所以需要添加四个依赖，分别是整合Spring需要的两个Jar和ActiveMQ的Jar和Solr客户端的Jar：

### 具体实现： ###

**1.商品服务添加商品信息后，发布商品添加消息**

spring-activemq.xml

<bean id="targetConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
     <property name="brokerURL" value="tcp://192.168.25.131:61616" />
    </bean>
     
    
    <bean id="connectionFactory" class="org.springframework.jms.connection.SingleConnectionFactory">
     
     <property name="targetConnectionFactory" ref="targetConnectionFactory" />
    </bean>
     
    
    
    <bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
     
     <property name="connectionFactory" ref="connectionFactory" />
    </bean>
     
    
    <bean id="topicDestination" class="org.apache.activemq.command.ActiveMQTopic">
     <constructor-arg value="itemAddTopic" />
    </bean>

ItemServiceImpl.java

@Autowired
    private JmsTemplate jmsTemplate;
    @Resource // 默认通过id注入，找不到再通过类型注入
    private Destination topicDestination; 
     
    @Override
    public E3Result addItem(TbItem item, String desc, String itemParams) {
     // 生成商品ID
     final long itemId = IDUtils.genItemId();
     
     /**
      * 将商品信息插入数据库中
      */
     
     // 发送一个商品添加消息
     jmsTemplate.send(topicDestination, new MessageCreator() {
      
      @Override
      public Message createMessage(Session session) throws JMSException {
       TextMessage textMessage = session.createTextMessage(itemId + "");
       return textMessage;
      }
     });
     // 返回成功
     return E3Result.ok();
    }

**2.索引服务配置监听器，接收到商品添加消息后，同步索引库**

ItemAddMessageListener.java

public class ItemAddMessageListener implements MessageListener {
     
     @Autowired
     private ItemMapper itemMapper;
     @Autowired
     private SolrServer solrServer;
     
     @Override
     public void onMessage(Message message) {
      try {
       // 从消息中取商品ID
       TextMessage textMessage = (TextMessage) message;
       String text = textMessage.getText();
       Long itemId = new Long(text);
       // 等待事务提交,不等待的话有可能下面会查不到商品信息
       Thread.sleep(1000);
       // 根据商品ID查询商品信息
       SearchItem searchItem = itemMapper.getItemById(itemId);
       // 创建一个文档对象
       SolrInputDocument document = new SolrInputDocument();
       // 向文档对象中添加域
       document.addField("id", searchItem.getId());
       document.addField("item_title", searchItem.getTitle());
       document.addField("item_sell_point", searchItem.getSell_point());
       document.addField("item_price", searchItem.getPrice());
       document.addField("item_image", searchItem.getImage());
       document.addField("item_category_name", searchItem.getCategory_name());
       // 把文档对象写入索引库
       solrServer.add(document);
       // 提交
       solrServer.commit();
      } catch (Exception e) {
       e.printStackTrace();
      }
     }
    }

spring-activemq.xml

<bean id="targetConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
     <property name="brokerURL" value="tcp://192.168.25.131:61616" />
    </bean>
     
    
    <bean id="connectionFactory" class="org.springframework.jms.connection.SingleConnectionFactory">
     
     <property name="targetConnectionFactory" ref="targetConnectionFactory" />
    </bean>
     
    
    <bean id="topicDestination" class="org.apache.activemq.command.ActiveMQTopic">
     <constructor-arg value="itemAddTopic" />
    </bean>
     
    
    
    <bean id="itemAddMessageListener" class="cn.e3mall.search.message.ItemAddMessageListener"/>
    
    <bean class="org.springframework.jms.listener.DefaultMessageListenerContainer">
     <property name="connectionFactory" ref="connectionFactory" />
     <property name="destination" ref="topicDestination" />
     <property name="messageListener" ref="itemAddMessageListener" />
    </bean>

**3.商品详情工程配置监听器，接收到商品添加消息后，生成商品详情静态页面**

首先需要配置用于生成静态页面的模板，具体的配置方法请参看FreeMarker教程，在这里就不详细叙述了，我这里配置好的模板如下：

![574b3f1f62db8ae49dd45b556b9bafb8.png][]

item.ftl是商品详情页面，其他的几个ftl是include进去的，都需要配置。另外，关注Java知音公众号，回复“后端面试”，送你一份面试题宝典！

FreeMarker的配置：

<bean id="freemarkerConfig" class="org.springframework.web.servlet.view.freemarker.FreeMarkerConfigurer">
     <property name="templateLoaderPath" value="/WEB-INF/ftl/" />
     <property name="defaultEncoding" value="UTF-8" />
    </bean>

监听器：

public class HtmlGenListener implements MessageListener {
     
     @Autowired
     private ItemService itemService;
     @Autowired
     private FreeMarkerConfigurer freeMarkerConfigurer;
     @Value("${HTML_GEN_PATH}")
     private String HTML_GEN_PATH; // 生成的静态页面保存的位置
     
     @Override
     public void onMessage(Message message) {
      try {
       // 从商品中取商品ID
       TextMessage textMessage = (TextMessage) message;
       String text = textMessage.getText();
       Long itemId = new Long(text);
       // 等待事务提交（防止还未插入数据库就查询）
       Thread.sleep(1000);
       // 根据商品id查询商品信息，商品基本信息和商品描述信息
       TbItem tbItem= itemService.getItemById(itemId);
       Item item = new Item(tbItem);
       item.setPrice(item.getPrice() / 100); // 转换价格
       // 取商品描述
       TbItemDesc itemDesc = itemService.getItemDesc(itemId);
       // 创建一个数据集，将模板所需的数据全部放进去
       Map<String, Object> data = new HashMap<>();
       data.put("item", item);
       data.put("itemDesc", itemDesc);
       // 加载模板对象
       Configuration configuration = freeMarkerConfigurer.getConfiguration();
       Template template = configuration.getTemplate("item.ftl");
       // 创建一个输出流，指定输出的目录以及文件名
       Writer out = new FileWriter(HTML_GEN_PATH + itemId + ".html");
       // 生成静态页面
       template.process(data, out);
       // 关闭流
       out.close();
      } catch (Exception e) {
       e.printStackTrace();
      }
     }
    }

引用外部文件：

![a3a3eaa3f64c216a72659dcbdb06434e.png][]

监听器配置：

<bean id="targetConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
     <property name="brokerURL" value="tcp://192.168.25.131:61616" />
    </bean>
     
    
    <bean id="connectionFactory" class="org.springframework.jms.connection.SingleConnectionFactory">
     
     <property name="targetConnectionFactory" ref="targetConnectionFactory" />
    </bean>
     
    
    <bean id="topicDestination" class="org.apache.activemq.command.ActiveMQTopic">
     <constructor-arg value="itemAddTopic" />
    </bean>
     
    
    
    <bean id="htmlGenListener" class="cn.e3mall.item.message.HtmlGenListener"/>
    <bean class="org.springframework.jms.listener.DefaultMessageListenerContainer">
     <property name="connectionFactory" ref="connectionFactory" />
     <property name="destination" ref="topicDestination" />
     <property name="messageListener" ref="htmlGenListener" />
    </bean>

至此，功能就实现了。

### 功能测试 ###

首先查看一下索引库，可以看到目前有943条商品数据

![4333ccb3f22b6b0cd1fd0c1f220daa8c.png][] ![1004687580436bda86963c79befefdc4.png][]

再次查看索引库，可以看到新增加了一条数据，现在有944条数据：

![7c11bb1fc0401413acc8838b3e9ee4b9.png][]

搜索新添加的商品：，可以看到，已经能够查到了：

![b2e48e9086e84326625f2cef4ab6a41b.png][]

查看商品详情，与本地生成的静态页面进行对比：

![3082bd092548605a88032271a789c22f.png][]

本地生成静态文件：

![27712f69101a91dc2359c8b2d80189d6.png][]

访问本地静态文件（这里使用了Nginx服务器访问静态文件）

![e3587293fed740674912ae06b018e7eb.png][]

可以对比一下，两个绝对是一模一样的，这样以后用户访问商品详情的时候就可以返回给其一个静态页面，大大减小了服务器压力，访问速度加快，也提升了用户体验。

*（感谢阅读，希望对你所有帮助)*

*来源：blog.csdn.net/qq\_39056805/article/details/80778485*

推荐好文

[强大，10k+点赞的 SpringBoot 后台管理系统竟然出了详细教程！][10k_ SpringBoot]

[分享一套基于SpringBoot和Vue的企业级中后台开源项目，代码很规范！][SpringBoot_Vue]

[能挣钱的，开源 SpringBoot 商城系统，功能超全，超漂亮][SpringBoot]![7c4357e034ad60b42797e5100a0539b8.png][]

[809c45a10b7156f19d8456df3af365fc.png]: /images/20220829/db22ce35c7c042c88380cbd1bbfbaad2.png
[786abd2d5349df37381c15c4859b97a4.png]: /images/20220829/7de92249b62c44ef955974a47a8a0ec8.png
[574b3f1f62db8ae49dd45b556b9bafb8.png]: /images/20220829/81977ccea75845cfbb88eddc9371e2d2.png
[a3a3eaa3f64c216a72659dcbdb06434e.png]: /images/20220829/67530bba7d73404687ade7365ad500b1.png
[4333ccb3f22b6b0cd1fd0c1f220daa8c.png]: https://img-blog.csdnimg.cn/img_convert/4333ccb3f22b6b0cd1fd0c1f220daa8c.png
[1004687580436bda86963c79befefdc4.png]: /images/20220829/5c6d6cdff4634188b5008e72d84f368c.png
[7c11bb1fc0401413acc8838b3e9ee4b9.png]: /images/20220829/81239c3735434337bf0923c54789de00.png
[b2e48e9086e84326625f2cef4ab6a41b.png]: /images/20220829/eeffec9e4ebd45449fbb217525ad2e76.png
[3082bd092548605a88032271a789c22f.png]: /images/20220829/72affcfcdf12417b84e145d7bd475caa.png
[27712f69101a91dc2359c8b2d80189d6.png]: /images/20220829/7e10fe4cac964cab91c80dcb58431152.png
[e3587293fed740674912ae06b018e7eb.png]: /images/20220829/1543bd2408804b30bcf376d8d89b7f34.png
[10k_ SpringBoot]: http://mp.weixin.qq.com/s?__biz=MzI4Njc5NjM1NQ%3D%3D&chksm=ebd5c411dca24d07446a4f22772cd12d2cc1143b62eb922a14500ae981cd57fb850ef74ca257&idx=2&mid=2247498557&scene=21&sn=84902d7030e174e152615d8fae3755cc#wechat_redirect
[SpringBoot_Vue]: http://mp.weixin.qq.com/s?__biz=MzU2MTI4MjI0MQ%3D%3D&chksm=fc799be6cb0e12f0b58479f8b031bc5ae79efdca1880ff9b19f0a107c3a88c37b9596dc73203&idx=2&mid=2247497288&scene=21&sn=65d7111a19e920df1e9416959594b2f4#wechat_redirect
[SpringBoot]: http://mp.weixin.qq.com/s?__biz=MzU2MTI4MjI0MQ%3D%3D&chksm=fc799a9ccb0e138a64a2671f31b8d4be1b3c061a288f7b0d1d4af02a60c45a72231446b91e00&idx=2&mid=2247497522&scene=21&sn=c5b4e596be4ac7d7f293e7e2f0ea0769#wechat_redirect
[7c4357e034ad60b42797e5100a0539b8.png]: /images/20220829/d22ff24bec734e55a997ac38f346ef55.png