ActiveMQ 项目实战

港控/mmm° 2022-06-05 00:47 197阅读 0赞

1.添加商品同步到索引库

![Center][]  
2.发送消息

manager-server工程中发送消息: 当商品添加完成后发送一个TextMessage，包含一个商品id。

**\[java\]**  [view plain][]   [copy][view plain]

1.  @Override  
2.        **public** e3Result addItem(TbItem item, String desc) \{  
3.             // 1、生成商品id  
4.             **final** **long** itemId = IDUtils.genItemId();  
5.             // 2、补全TbItem对象的属性  
6.             item.setId(itemId);  
7.             //商品状态，1-正常，2-下架，3-删除  
8.             item.setStatus((**byte**) 1);  
9.             Date date = **new** Date();  
10.            item.setCreated(date);  
11.            item.setUpdated(date);  
12.            // 3、向商品表插入数据  
13.            itemMapper.insert(item);  
14.            // 4、创建一个TbItemDesc对象  
15.            TbItemDesc itemDesc = **new** TbItemDesc();  
16.            // 5、补全TbItemDesc的属性  
17.            itemDesc.setItemId(itemId);  
18.            itemDesc.setItemDesc(desc);  
19.            itemDesc.setCreated(date);  
20.            itemDesc.setUpdated(date);  
21.            // 6、向商品描述表插入数据  
22.            itemDescMapper.insert(itemDesc);  
23.            //发送一个商品添加消息  
24.            jmsTemplate.send(topicDestination, **new** MessageCreator() \{  
25.                  @Override  
26.                  **public** Message createMessage(Session session) **throws** JMSException \{  
27.                       TextMessage textMessage = session.createTextMessage(itemId + "");  
28.                       **return** textMessage;  
29.                  \}  
30.            \});  
31.            // 7、e3Result.ok()  
32.            **return** e3Result.ok();  
33.       \}

3.接收消息

(1) 功能分析：

① 接收消息。需要创建MessageListener接口的实现类。

② 取消息，取商品id。

③ 根据商品id查询数据库。

④ 创建一SolrInputDocument对象。

⑤ 使用SolrServer对象写入索引库。

⑥ 返回成功，返回e3Result。

(2) Dao层

① 根据商品id查询商品信息。

![Center 1][]  
     ② 映射文件：

**\[html\]**  [view plain][]   [copy][view plain]

1.  **<****select** id="getItemById" parameterType="long" resultType="cn.e3mall.common.pojo.SearchItem"**>**      
2.           SELECT  
3.                  a.id,  
4.                  a.title,  
5.                  a.sell\_point,  
6.                  a.price,  
7.                  a.image,  
8.                  b. NAME category\_name,  
9.                  c.item\_desc  
10.           FROM  
11.                 tb\_item a  
12.           JOIN tb\_item\_cat b ON a.cid = b.id  
13.           JOIN tb\_item\_desc c ON a.id = c.item\_id  
14.           WHERE a.status = 1  
15.             AND a.id=\#\{itemId\}  
16. lt;/select**>**

(3) Service层

参数：商品ID

业务逻辑：

① 根据商品id查询商品信息。

② 创建一SolrInputDocument对象。

③ 使用SolrServer对象写入索引库。

④ 返回成功，返回e3Result。

返回值：e3Result

**\[java\]**  [view plain][]   [copy][view plain]

1.  **public** e3Result addDocument(**long** itemId) **throws** Exception \{  
2.             // 1、根据商品id查询商品信息。  
3.             SearchItem searchItem = searchItemMapper.getItemById(itemId);  
4.             // 2、创建一SolrInputDocument对象。  
5.             SolrInputDocument document = **new** SolrInputDocument();  
6.             // 3、使用SolrServer对象写入索引库。  
7.             document.addField("id", searchItem.getId());  
8.             document.addField("item\_title", searchItem.getTitle());  
9.             document.addField("item\_sell\_point", searchItem.getSell\_point());  
10.            document.addField("item\_price", searchItem.getPrice());  
11.            document.addField("item\_image", searchItem.getImage());  
12.            document.addField("item\_category\_name", searchItem.getCategory\_name());  
13.            document.addField("item\_desc", searchItem.getItem\_desc());  
14.            // 5、向索引库中添加文档。  
15.            solrServer.add(document);  
16.            solrServer.commit();  
17.            // 4、返回成功，返回e3Result。  
18.            **return** e3Result.ok();  
19.       \}

(4) Listener

**\[java\]**  [view plain][]   [copy][view plain]

1.  **public** **class** ItemChangeListener **implements** MessageListener \{  
2.    
3.        @Autowired  
4.        **private** SearchItemServiceImpl searchItemServiceImpl;  
5.    
6.        @Override  
7.        **public** **void** onMessage(Message message) \{  
8.             **try** \{  
9.                   TextMessage textMessage = **null**;  
10.                  Long itemId = **null**;  
11.                  //取商品id  
12.                  **if** (message **instanceof** TextMessage) \{  
13.                       textMessage = (TextMessage) message;  
14.                       itemId = Long.parseLong(textMessage.getText());  
15.                  \}  
16.                  //向索引库添加文档  
17.                  searchItemServiceImpl.addDocument(itemId);  
18.   
19.            \} **catch** (Exception e) \{  
20.                  e.printStackTrace();  
21.            \}  
22.       \}  
23.   
24. \}

(5) Spring配置监听

![Center 2][]

[Center]: /images/20220605/6705d663fa064b01b0361c74e533b74a.png
[view plain]: http://blog.csdn.net/Luomingkui1109/article/details/78436510#
[Center 1]: /images/20220605/d3dcd448d1fb495b9d0f4b201cedc0d0.png
[Center 2]: /images/20220605/0ff04ce6ac624b9280470ed4cd14cbea.png