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

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

消息生产者（运营商后台）

1）修改 pinyougou-manager-web 工程的 spring-activemq.xml，添加 bean 配置

<!--这个是队列目的地，点对点-->
<bean id="queueSolrDeleteDestination"class="org.apache.activemq.command.ActiveMQQueue">
	 <constructor-arg value="pinyougou_queue_solr_delete"/>
</bean>

2） 代码实现,修改 GoodsController.java:

@Autowired
private Destination queueSolrDeleteDestination;//用户在索引库中删除记录

/**
* 批量删除
* @param ids
* @return
*/
@RequestMapping("/delete")
public Result delete(final Long [] ids){
			try {
				goodsService.delete(ids);
				jmsTemplate.send(queueSolrDeleteDestination, new MessageCreator() {
					@Override
					public Message createMessage(Session session) throws JMSException {
						return session.createObjectMessage(ids);
					}
				});
				return new Result(true, "删除成功"); 
			} catch (Exception e) {
				e.printStackTrace();
				return new Result(false, "删除失败");
			} 
	}

消息消费者（搜索服务）

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

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

/**
* 监听：用于删除索引库中记录
* @author Administrator 
* /
 @Component
 public class ItemDeleteListener implements MessageListener{
	
	 @Autowired
	 private ItemSearchService itemSearchService;
	
	 @Override
	 public void onMessage(Message message) {
		 try {
			 ObjectMessage objectMessage= (ObjectMessage)message;
			 Long[] goodsIds = (Long[]) objectMessage.getObject();
			 System.out.println("ItemDeleteListener 监听接收到消息..."+goodsIds)
			 itemSearchService.deleteByGoodsIds(Arrays.asList(goodsIds));
			 System.out.println("成功删除索引库中的记录");
		 } catch (Exception e) {
			 e.printStackTrace();
		 } 
	 } 
 }

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