57分布式电商项目ActiveMQ实现运营商后台与搜索服务的零耦合（二）

现在需要通过ActiveMQ消息中间件实现在商品删除时也同时移除索引库记录的功能。

消息生产者&＃xff08;运营商后台&＃xff09;

1&＃xff09;修改 pinyougou-manager-web 工程的 spring-activemq.xml&＃xff0c;添加 bean 配置

2&＃xff09; 代码实现,修改 GoodsController.java:

&＃64;Autowired
private Destination queueSolrDeleteDestination;//用户在索引库中删除记录/**
* 批量删除
* &＃64;param ids
* &＃64;return
*/
&＃64;RequestMapping("/delete")
public Result delete(final Long [] ids){try {goodsService.delete(ids);jmsTemplate.send(queueSolrDeleteDestination, new MessageCreator() {&＃64;Overridepublic Message createMessage(Session session) throws JMSException {return session.createObjectMessage(ids);}});return new Result(true, "删除成功"); } catch (Exception e) {e.printStackTrace();return new Result(false, "删除失败");} }


消息消费者&＃xff08;搜索服务&＃xff09;

1 )配置文件
修改 pinyougou-search-service 的 applicationContext-activemq-consumer.xml

2)代码实现
com.pinyougou.search.service.impl 包下创建监听类 ItemDeleteListener

/**
* 监听&＃xff1a;用于删除索引库中记录
* &＃64;author Administrator
* /&＃64;Componentpublic class ItemDeleteListener implements MessageListener{&＃64;Autowiredprivate ItemSearchService itemSearchService;&＃64;Overridepublic void onMessage(Message message) {try {ObjectMessage objectMessage&＃61; (ObjectMessage)message;Long[] goodsIds &＃61; (Long[]) objectMessage.getObject();System.out.println("ItemDeleteListener 监听接收到消息..."&＃43;goodsIds)itemSearchService.deleteByGoodsIds(Arrays.asList(goodsIds));System.out.println("成功删除索引库中的记录");} catch (Exception e) {e.printStackTrace();} } }


其它增删改查模式都大同小异&＃xff0c;再次不在重复赘述。