目錄

3.注意

1.為什麼要使用訊息對列acitveMQ

在我們的後臺，增加、修改、刪除商品時，這裡以修改為例。

修改商品時，修改的是資料庫中的資料。但是使用者在商品搜尋時，搜尋的是solr索引庫中的資料，所以使用者並不會搜到新修改商品的資訊。後臺雖然有一個匯入所有商品資訊到索引庫的，但是每次匯入的資訊過大，而我們只需要修改索引庫中的一個商品資訊，所以我們需要編寫一個，修改單個商品索引的功能。

我們有三種方案：

1.1方案1

在taotao-manager-service中，新增商品的業務邏輯中，新增一個同步索引庫的業務邏輯。

缺點：業務邏輯耦合度非常高，業務拆分不明確

1.2方案2

業務邏輯在taotao-search中實現，呼叫服務在taotao-manager實現。業務邏輯分開。

缺點：

服務之間的耦合度變高，啟動有先後順序。

隨著呼叫的服務會越來越多，服務之間的呼叫越來越複雜，難以管理。

1.3方案3

使用訊息佇列

實現效果：

後臺需要增刪改商品資訊很大的時候，只需要taotao-manager-service在資料庫修改商品資訊後，向MQ傳送一個被修改商品的id，然後直接返回提示，修改成功。然後在taotao-search-service寫一個監聽器，專門接收MQ傳送的訊息，修改索引庫即可。

存在的問題：

1、如果MQ掛了，所有相關的服務都掛了

2、MQ有效能的瓶頸，儘量減少訊息的內容的大小

2.使用訊息佇列activeMQ修改索引庫

需要在商品的新增/修改的時候，同步索引庫。將資料從資料庫中查詢出來匯入到索引庫更新。

訊息的傳送方為：所在工程taotao-manager-service

訊息的接收方為：所在工程taotao-search-service

兩個工程都需要依賴activmq:

<dependency>
	<groupId>org.apache.activemq</groupId>
	<artifactId>activemq-all</artifactId>
</dependency>
 

2.1producer

在taotao-manager-service工程中傳送訊息。

功能分析：

        當商品新增完成後傳送一個TextMessage，包含一個商品id即可。

        接收端接收到商品id通過資料庫查詢到商品的資訊（搜尋的結果商品的資訊）再同步索引庫。

2.1.1applicationContext-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">
	
	<bean id="targetConnection" class="org.apache.activemq.ActiveMQConnectionFactory">
		<property name="brokerURL" value="tcp://192.168.25.130:61616"></property>
	</bean>
	<!-- 通用的connectionfacotry 指定真正使用的連線工廠 -->
	<bean id="connectionFactory" class="org.springframework.jms.connection.SingleConnectionFactory">
		<property name="targetConnectionFactory" ref="targetConnection"></property>
	</bean>
	<!-- 接收和傳送訊息時使用的類 -->
	<bean class="org.springframework.jms.core.JmsTemplate">
		<property name="connectionFactory" ref="connectionFactory"></property>
	</bean>
	<bean id="topicDestination" class="org.apache.activemq.command.ActiveMQTopic">
		<constructor-arg name="name" value="item-change-topic"></constructor-arg>
	</bean> 
</beans>

2.1.2添加發送訊息邏輯

首先注入訊息模板物件與傳送訊息的目標

@Autowired
private JmsTemplate jmsTemplate;
@Resource(name="topicDestination")
private Destination topicDestination;

添加發送訊息的程式碼

// 傳送一個商品新增訊息
		jmsTemplate.send(topicDestination, new MessageCreator() {
			@Override
			public Message createMessage(Session session) throws JMSException {
				TextMessage textMessage = session.createTextMessage(itemId + "");
				return textMessage;
			}

		});

2.2consumer

在taotao-search-service中消費訊息。

需要加入activmq的依賴。

2.2.1功能分析

1. 接收訊息。需要建立MessageListener介面的實現類。
2. 取訊息，取商品id。
3. 根據商品id查詢資料庫。
4. 建立一SolrInputDocument物件。
5. 使用SolrServer物件寫入索引庫。
6. 返回成功，返回TaotaoResult。

2.2.2dao層

1. 根據商品id查詢商品資訊。
2. 建立一SolrInputDocument物件。
3. 使用SolrServer物件寫入索引庫。
4. 返回成功，返回TaotaoResult。

在taotao-search-service的com.taotao.search.mapper編寫mapper介面與mapper對映檔案，用於根據id查詢資料庫，返回searchItem

mapper介面

/**
	 * 根據id查詢SearchItem
	 * @param itemId
	 * @return
	 */
	public SearchItem getItemById(Long itemId);

mapper對映檔案

<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 category_name,
			c.item_desc
		FROM
			tb_item a
		JOIN tb_item_cat b ON a.cid = b.id
		JOIN tb_item_desc c ON a.id = c.item_id
		WHERE a.status = 1
		  AND a.id=#{itemId}
	</select>

索引庫dao

用於更新索引庫

在taotao-search-service的com.taotao.search.dao的SearchDao中

/**
	 * 商品增改時，更新索引庫
	 * @param itemId
	 * @return
	 * @throws Exception
	 */
	public TaotaoResult updateSearchItemById(Long itemId) throws Exception {
		//修改、新增
		//1.呼叫mapper中的方法
		SearchItem searchItem = searchItemMapper.getItemById(itemId);
		//2.建立solrinputdocument
		SolrInputDocument document = new SolrInputDocument();
		//3.向文件中新增域
		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());
		document.addField("item_desc", searchItem.getItem_desc());
		//4.新增文件到索引庫中
		solrServer.add(document);
		//5.提交
		solrServer.commit();
		return TaotaoResult.ok();
	}

2.2.3service層

引數：商品ID

業務邏輯：

1. 呼叫searchDao的方法。
2. 返回成功，返回TaotaoResult。

在taotao-search-interface的com.taotao.search.service包下SearchService

/**
	 * 根據id更新商品索引庫
	 * @param itemId
	 * @return
	 * @throws Exception
	 */
	TaotaoResult updateSearchItemById(Long itemId) throws Exception;

在taotao-search-service的com.taotao.search.service.impl包下SearchServiceImpl實現介面

/**
	 * 根據id更新商品索引庫
	 */
	@Override
	public TaotaoResult updateSearchItemById(Long itemId) throws Exception {
		return searchDao.updateSearchItemById(itemId);
	}
	

2.2.4listener

在taotao-search-service下建立com.taotao.search.listener包，在com.taotao.search.listener包下建立listener用於接收訊息佇列中的id訊息。

package com.taotao.search.listener;

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

import org.springframework.beans.factory.annotation.Autowired;

import com.taotao.search.service.SearchService;

/**
 * 接收訊息的監聽器
 * 
 * @author Administrator
 *
 */
public class ItemChangeMessageListener implements MessageListener {
	// 注入service 直接呼叫 方法更新即可
	@Autowired
	private SearchService searchService;

	@Override
	public void onMessage(Message message) {
		// 判斷訊息型別是否為textmessage
		if (message instanceof TextMessage) {
			// 如果是 獲取商品的id
			TextMessage message2 = (TextMessage) message;
			try {
				String id = message2.getText();
				// 通過商品的id查詢資料 需要開發mapper 通過id查詢商品(搜尋時)的資料
				// 更新索引庫
				Long itemId = Long.parseLong(id);
				searchService.updateSearchItemById(itemId);
			} catch (Exception e) {
				e.printStackTrace();
			}
		}
	}

}

2.2.5配置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">
	
	<bean id="targetConnection" class="org.apache.activemq.ActiveMQConnectionFactory">
		<property name="brokerURL" value="tcp://47.100.54.177:61616"></property>
	</bean>
	<!-- 通用的connectionfacotry 指定真正使用的連線工廠 -->
	<bean id="connectionFactory" class="org.springframework.jms.connection.SingleConnectionFactory">
		<property name="targetConnectionFactory" ref="targetConnection"></property>
	</bean>
	<bean id="topicDestination" class="org.apache.activemq.command.ActiveMQTopic">
		<constructor-arg name="name" value="item-change-topic"></constructor-arg>
	</bean>
	<!-- messagelistener的初始化 -->
	<bean id="itemChangeMessageListener" class="com.taotao.search.listener.ItemChangeMessageListener"></bean>
	<!-- 設定預設的監聽容器 -->
	<bean class="org.springframework.jms.listener.DefaultMessageListenerContainer">
		<property name="connectionFactory" ref="connectionFactory"></property>
		<property name="destination" ref="topicDestination"></property>
		<property name="messageListener" ref="itemChangeMessageListener"></property>
	</bean>
</beans>

3.注意

使用訊息佇列activeMQ更新solr索引庫，用於管理員更新商品時，使用者可以搜到最新的商品資訊，就分析和編寫完畢。

但是有一點遺憾的地方，這裡並不能用作商品的刪除、下架、上架

因為我當初在編寫這個三個功能的時候偷懶了，將三個功能放在一起，根據方法名判斷刪除、下架、上架，而且引數為List型別。

有一種可行的方法我將List<Long> ids，用逗號分割轉為String，最後加上delete、reshelf、instock這樣的標識

比如："15214,41358,123231,delete"、"152745,86358,123231,reshelf"，在searchDao做字串split，判斷最末尾是delete還是reshelf等，執行solrServer.delete()、solrServer.add()。但是感覺這樣太亂了，耦合死了，看著就難受。

這個坑一個以後解決吧！！！哎