学习淘淘商城第六十二课（添加商品同步到索引库以及消息机制测试）

        我们在添加商品时需要与索引库进行同步，这样每添加一个商品索引库就多一个文档，这样做的好处是不用把数据库中的所有数据进行同步，大大提高了性能节约了时间。

        我们要做的是当添加商品的时候发送activemq消息，至于发送什么类型的activemq消息则要根据实际应用场景来定，由于添加商品涉及到同步缓存、同步索引库、添加静态页面等操作，也就是一个消息被多个消费者所消费，显然发送topic消息更为合适。

        要发送topic消息，就要在activemq的配置文件中做下配置，我们将原来配置的topic做下简单的修改，根据命名有意义原则，我们给<bean>起名为"itemAddTopic"，给消息起名为"item-add-topic"，如下图所示。

         修改后topic如下：

<!--这个是主题目的地，一对多的 -->
	<bean id="itemAddTopic" class="org.apache.activemq.command.ActiveMQTopic">
		<constructor-arg value="item-add-topic" />
	</bean>

          下一步是我们找到添加商品的实现类"ItemServiceImpl"，在该类中注入jmsTemplate和Destination，如下图所示。

        然后我们找到添加商品的方法，在添加完商品后，发送消息，这里需要考虑一个问题，那就是消息的内容应该是什么？既然是添加商品，消费者肯定是要知道添加的商品是哪个商品，同时本着简单的原则，我们只需要传新增商品的ID即可，如下图所示。

          当前ItemServiceImpl类的所有代码如下：

package com.taotao.service.impl;

import java.util.Date;
import java.util.List;

import javax.annotation.Resource;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.Session;
import javax.jms.TextMessage;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.jms.core.MessageCreator;
import org.springframework.stereotype.Service;

import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import com.taotao.common.pojo.EasyUIDataGridResult;
import com.taotao.common.pojo.TaotaoResult;
import com.taotao.common.utils.IDUtils;
import com.taotao.mapper.TbItemDescMapper;
import com.taotao.mapper.TbItemMapper;
import com.taotao.pojo.TbItem;
import com.taotao.pojo.TbItemDesc;
import com.taotao.pojo.TbItemExample;
import com.taotao.service.ItemService;

@Service
public class ItemServiceImpl implements ItemService {
	
	@Autowired
	private TbItemMapper itemMapper;
	@Autowired
	private TbItemDescMapper itemDescMapper;
	
	@Autowired
	private JmsTemplate jmsTemplate;
	@Resource(name="itemAddTopic")
	private Destination destination;

	@Override
	public TbItem getItemById(long itemId) {
		TbItem tbItem = itemMapper.selectByPrimaryKey(itemId);
		return tbItem;
	}

	@Override
	public EasyUIDataGridResult getItemList(int page, int rows) {
		//设置分页信息
		PageHelper.startPage(page, rows);
		//执行查询
		TbItemExample example = new TbItemExample();
		List<TbItem>  list = itemMapper.selectByExample(example);
		//获取查询结果
		PageInfo<TbItem> pageInfo = new PageInfo<>(list);
		EasyUIDataGridResult result = new EasyUIDataGridResult();
		result.setRows(list);
		result.setTotal(pageInfo.getTotal());
		//返回结果
		return result;
	}

	@Override
	public TaotaoResult createItem(TbItem tbItem, String desc) throws Exception{
		//生成商品ID
		long itemId = IDUtils.genItemId();
		//补全item的属性
		tbItem.setId(itemId);
		//商品状态，1-正常，2-下架，3-删除
		tbItem.setStatus(((byte) 1));
		tbItem.setCreated(new Date());
		tbItem.setUpdated(new Date());
		itemMapper.insert(tbItem);
		//添加商品描述
		insertItemDesc(itemId, desc);
		//发送activemq消息
		jmsTemplate.send(destination,new MessageCreator() {
			
			@Override
			public Message createMessage(Session session) throws JMSException {
				TextMessage textMessage = session.createTextMessage(itemId+"");
				return textMessage;
			}
		});
		return TaotaoResult.ok();
	}
	
	//添加商品描述
	private void insertItemDesc(long itemId,String desc){
		//创建一个商品描述表对应的pojo
		TbItemDesc itemDesc = new TbItemDesc();
		//补全pojo的属性
		itemDesc.setItemId(itemId);
		itemDesc.setItemDesc(desc);
		itemDesc.setCreated(new Date());
		itemDesc.setUpdated(new Date());
		//向商品描述表插入数据
		itemDescMapper.insert(itemDesc);
	}

}

       上面是发送activemq消息，下面我们再来写下接收消息，接收消息是在taotao-search-service工程，我们先要做的事情是修改Mybatis文件，添加一个根据商品ID来查询商品详情的方法，如下图所示。

      上图添加的代码如下：

<select id="getItemById" parameterType="long" resultType="com.taotao.common.pojo.SearchItem">
  	SELECT
		a.id,
		a.title,
		a.sell_point,
		a.price,
		a.image,
		b. NAME item_category_name,
		c.item_desc
	FROM
		tb_item a
	LEFT JOIN tb_item_cat b ON a.cid = b.id
	LEFT JOIN tb_item_desc c ON a.id = c.item_id
	WHERE
		a.`status` = 1
	AND a.id = #{itemId}
  </select>

      接着，在接口类中添加更加商品ID查询商品详情的接口，如下图所示。

       现在我启动的是单机版的solr服务器，因此要保证solr配置文件当前切换到单机版，如下图所示。

          下面我们需要创建一个监听器类ItemAddMessageListener，在该类中处理同步索引库的逻辑，如下图所示。

        ItemAddMessageListener.java类代码如下：

package com.taotao.search.listener;

import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.TextMessage;

import org.apache.solr.client.solrj.SolrServer;
import org.apache.solr.common.SolrInputDocument;
import org.springframework.beans.factory.annotation.Autowired;

import com.taotao.common.pojo.SearchItem;
import com.taotao.search.mapper.SearchItemMapper;

public class ItemAddMessageListener implements MessageListener {
	@Autowired
	private SearchItemMapper searchItemMapper;
	@Autowired
	private SolrServer solrServer;

	@Override
	public void onMessage(Message message) {
		try {
			//从消息中取出商品id
			TextMessage textMessage = (TextMessage)message;
			String text = textMessage.getText();
			long itemId = Long.valueOf(text);
			//根据商品id查询商品详情，这里需要注意的是消息发送方法
			//有可能还没有提交事务，因此这里是有可能取不到商品信息
			//的，为了避免这种情况出现，我们最好等待事务提交，这里
			//我采用3次尝试的方法，每尝试一次休眠一秒
			SearchItem searchItem = null;
			for(int i=0;i<3;i++){
				try {
					Thread.sleep(1000);//休眠一秒
					searchItem = searchItemMapper.getItemById(itemId);
					//如果获取到了商品信息，那就退出循环。
					if(searchItem != null){
						break;
					}
				} catch (Exception e) {
					e.printStackTrace();
				}
			}
			//创建文档对象
			SolrInputDocument document = new SolrInputDocument();
			//向文档对象中添加域
			document.setField("id", searchItem.getId());
			document.setField("item_title", searchItem.getTitle());
			document.setField("item_sell_point", searchItem.getSell_point());
			document.setField("item_price", searchItem.getPrice());
			document.setField("item_image", searchItem.getImage());
			document.setField("item_category_name", searchItem.getItem_category_name());
			document.setField("item_desc", searchItem.getItem_desc());
			//把文档写入索引库
			solrServer.add(document);
			//提交
			solrServer.commit();
		} catch (Exception e) {
			e.printStackTrace();
		}
	}

}

        正如在代码中提到的那样，在添加商品的时候（如下图所示）是涉及到事务的，事务提交之后才能在数据库中查询到商品信息，假如网络不济，造成事务还没提交，接收消息的一端想去查询商品信息，这时显然是查询不到的，为了等待事务提交，采用三次尝试的机制，如上面代码所示。

        写完监听器我们再配置下接收的topic（要与taotao-manager-service当中配置的topic一致），以及设置监听器，如下图所示。

         applicationContext-activemq.xml文件内容如下：

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
	xmlns:context="http://www.springframework.org/schema/context" xmlns:p="http://www.springframework.org/schema/p"
	xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.2.xsd
	http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.2.xsd
	http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-4.2.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-4.2.xsd
	http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-4.2.xsd">
	
	<!-- 真正可以产生Connection的ConnectionFactory，由对应的 JMS服务厂商提供 -->
	<bean id="targetConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
		<property name="brokerURL" value="tcp://192.168.156.30:61616" />
	</bean>
	<!-- Spring用于管理真正的ConnectionFactory的ConnectionFactory -->
	<bean id="connectionFactory"
		class="org.springframework.jms.connection.SingleConnectionFactory">
		<!-- 目标ConnectionFactory对应真实的可以产生JMS Connection的ConnectionFactory -->
		<property name="targetConnectionFactory" ref="targetConnectionFactory" />
	</bean>
	<!-- 配置生产者 -->
	<!-- Spring提供的JMS工具类，它可以进行消息发送、接收等 -->
	<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
		<!-- 这个connectionFactory对应的是我们定义的Spring提供的那个ConnectionFactory对象 -->
		<property name="connectionFactory" ref="connectionFactory" />
	</bean>
	<!--这个是队列目的地，点对点的 -->
	<bean id="queueDestination" class="org.apache.activemq.command.ActiveMQQueue">
		<constructor-arg value="spring-queue"/>
	</bean>
	<!--这个是主题目的地，一对多的 -->
	<bean id="itemAddTopic" class="org.apache.activemq.command.ActiveMQTopic">
		<constructor-arg value="item-add-topic" />
	</bean>
	
	<!-- 接收消息 -->
	<!-- 配置监听器 -->
	<bean id="messageListener" class="com.taotao.search.listener.MyMessageListener"/>
	<!-- 消息监听容器 -->
	<bean class="org.springframework.jms.listener.DefaultMessageListenerContainer">
	    <property name="connectionFactory" ref="connectionFactory"/>
	    <property name="destination" ref="queueDestination"/>
	    <property name="messageListener" ref="messageListener"/>
	</bean>
	
	<!-- 配置监听器 -->
	<bean id="itemAddMessageListener" class="com.taotao.search.listener.ItemAddMessageListener"/>
	<!-- 消息监听容器 -->
	<bean class="org.springframework.jms.listener.DefaultMessageListenerContainer">
	    <property name="connectionFactory" ref="connectionFactory"/>
	    <property name="destination" ref="itemAddTopic"/>
	    <property name="messageListener" ref="itemAddMessageListener"/>
	</bean>

</beans>

      在启动工程前，我们需要把学习JMail发送邮件时人为添加的异常给删掉，如下图所示

      好了，写完了代码，现在我们来测试一下，我们依次启动taotao-manager、taotao-content、taotao-search、taotao-manager-web、taotao-port-web、taotao-search-web工程。启动完之后，我们访问http://localhost:8081来访问淘淘商城管理后台，添加一款商品，这里我添加的是华为P10手机，如下图所示。

         添加完商品后，我们到淘淘商城首页进行搜索，看能不能搜索到我们刚才添加的手机，如下图所示，发现可以正常搜索到刚才添加的华为手机！！说明我们的消息机制没问题。