同步索引庫分析：

方案一：在shop-manager中，新增商品的業務邏輯中，新增一個同步索引庫的業務邏輯。

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

方案二：業務邏輯在shop-search中實現，呼叫服務在shop-manager實現。業務邏輯分開。

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

方案三：使用訊息佇列。MQ是一個訊息中介軟體。

MQ是一個訊息中介軟體，ActiveMQ、RabbitMQ、kafka。

什麼是ActiveMQ？

ActiveMQ 是Apache出品，最流行的，能力強勁的開源訊息匯流排。ActiveMQ 是一個完全支援JMS1.1和J2EE 1.4規範的 JMS Provider實現,儘管JMS規範出臺已經是很久的事情了,但是JMS在當今的J2EE應用中間仍然扮演著特殊的地位。
主要特點：

• 1. 多種語言和協議編寫客戶端。語言: Java, C, C++, C#, Ruby, Perl, Python, PHP。應用協議: OpenWire,Stomp REST,WS Notification,XMPP,AMQP
• 2. 完全支援JMS1.1和J2EE 1.4規範 (持久化,XA訊息,事務)
• 3. 對Spring的支援,ActiveMQ可以很容易內嵌到使用Spring的系統裡面去,而且也支援Spring2.0的特性
• 4. 通過了常見J2EE伺服器(如 Geronimo,JBoss 4, GlassFish,WebLogic)的測試,其中通過JCA 1.5 resource adaptors的配置,可以讓ActiveMQ可以自動的部署到任何相容J2EE 1.4 商業伺服器上
• 5. 支援多種傳送協議:in-VM,TCP,SSL,NIO,UDP,JGroups,JXTA
• 6. 支援通過JDBC和journal提供高速的訊息持久化
• 7. 從設計上保證了高效能的叢集,客戶端-伺服器,點對點
• 8. 支援Ajax
• 9. 支援與Axis的整合
• 10. 可以很容易得呼叫內嵌JMS provider,進行測試

ActiveMQ的訊息形式：

對於訊息的傳遞有兩種型別：
一種是點對點的，即一個生產者和一個消費者一一對應；
另一種是釋出/訂閱模式，即一個生產者產生訊息並進行傳送後，可以由多個消費者進行接收。
JMS定義了五種不同的訊息正文格式，以及呼叫的訊息型別，允許你傳送並接收以一些不同形式的資料，提供現有訊息格式的一些級別的相容性。

• 　　· StreamMessage -- Java原始值的資料流
• 　　· MapMessage--一套名稱-值對
• 　　· TextMessage--一個字串物件
• 　　· ObjectMessage--一個序列化的 Java物件
• 　　· BytesMessage--一個位元組的資料流

ActiveMQ的安裝：

安裝環境：
1、需要jdk
2、安裝Linux系統。生產環境都是Linux系統。
安裝步驟：
第一步： 把ActiveMQ 的壓縮包上傳到Linux系統。
第二步：解壓縮。
第三步：啟動。
使用bin目錄下的activemq命令啟動：

[[email protected] bin]# ./activemq start
關閉：
[[email protected] bin]# ./activemq stop
檢視狀態：
[[email protected] bin]# ./activemq status

注意：如果ActiveMQ整合spring使用不要使用activemq-all-5.12.0.jar包。建議使用5.11.2

解決405問題：

修改hosts檔案，配置機器名和127.0.0.1的對映關係。機器名：/etc/sysconfig/network檔案中定義了機器名：

Host檔案的配置（/stc/hosts）：

重新啟動Activemq的服務。

ActiveMQ的使用方法：

Queue：

Producer：

生產者：生產訊息，傳送端。
把jar包新增到shop-manager-service工程中。使用5.11.2版本的jar包。

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

第一步：建立ConnectionFactory物件，需要指定服務端ip及埠號。
第二步：使用ConnectionFactory物件建立一個Connection物件。
第三步：開啟連線，呼叫Connection物件的start方法。
第四步：使用Connection物件建立一個Session物件。
第五步：使用Session物件建立一個Destination物件（topic、queue），此處建立一個Queue物件。
第六步：使用Session物件建立一個Producer物件。
第七步：建立一個Message物件，建立一個TextMessage物件。
第八步：使用Producer物件傳送訊息。
第九步：關閉資源。

/**
	 * 點到點形式傳送訊息
	 */
	@Test
	public void testQueueProducer() throws Exception {
		//1、建立一個連線工廠物件，需要指定服務的ip及埠。
		ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://192.168.25.161:61616");
		//2、使用工廠物件建立一個Connection物件。
		Connection connection = connectionFactory.createConnection();
		//3、開啟連線，呼叫Connection物件的start方法。
		connection.start();
		//4、建立一個Session物件。
		//第一個引數：是否開啟事務。如果true開啟事務，第二個引數無意義。一般不開啟事務false。
		//第二個引數：應答模式。自動應答或者手動應答。一般自動應答。
		Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
		//5、使用Session物件建立一個Destination物件。兩種形式queue、topic，現在應該使用queue
		Queue queue = session.createQueue("test-queue");
		//6、使用Session物件建立一個Producer物件。
		MessageProducer producer = session.createProducer(queue);
		//7、建立一個Message物件，可以使用TextMessage。
		/*TextMessage textMessage = new ActiveMQTextMessage();
		textMessage.setText("hello Activemq");*/
		TextMessage textMessage = session.createTextMessage("hello activemq");
		//8、傳送訊息
		producer.send(textMessage);
		//9、關閉資源
		producer.close();
		session.close();
		connection.close();
	}

Consumer:

消費者：接收訊息。
第一步：建立一個ConnectionFactory物件。
第二步：從ConnectionFactory物件中獲得一個Connection物件。
第三步：開啟連線。呼叫Connection物件的start方法。
第四步：使用Connection物件建立一個Session物件。
第五步：使用Session物件建立一個Destination物件。和傳送端保持一致queue，並且佇列的名稱一致。
第六步：使用Session物件建立一個Consumer物件。
第七步：接收訊息。
第八步：列印訊息。
第九步：關閉資源

@Test
	public void testQueueConsumer() throws Exception {
		//建立一個ConnectionFactory物件連線MQ伺服器
		ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://192.168.25.161:61616");
		//建立一個連線物件
		Connection connection = connectionFactory.createConnection();
		//開啟連線
		connection.start();
		//使用Connection物件建立一個Session物件
		Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
		//建立一個Destination物件。queue物件
		Queue queue = session.createQueue("test-queue");
		//使用Session物件建立一個消費者物件。
		MessageConsumer consumer = session.createConsumer(queue);
		//接收訊息
		consumer.setMessageListener(new MessageListener() {
			
			@Override
			public void onMessage(Message message) {
				//列印結果
				TextMessage textMessage = (TextMessage) message;
				String text;
				try {
					text = textMessage.getText();
					System.out.println(text);
				} catch (JMSException e) {
					e.printStackTrace();
				}
				
			}
		});
		//等待接收訊息
		System.in.read();
		//關閉資源
		consumer.close();
		session.close();
		connection.close();
	}

Topic:

Producer:

使用步驟：
第一步：建立ConnectionFactory物件，需要指定服務端ip及埠號。
第二步：使用ConnectionFactory物件建立一個Connection物件。
第三步：開啟連線，呼叫Connection物件的start方法。
第四步：使用Connection物件建立一個Session物件。
第五步：使用Session物件建立一個Destination物件（topic、queue），此處建立一個Topic物件。
第六步：使用Session物件建立一個Producer物件。
第七步：建立一個Message物件，建立一個TextMessage物件。
第八步：使用Producer物件傳送訊息。
第九步：關閉資源。

@Test
	public void testTopicProducer() throws Exception {
		//1、建立一個連線工廠物件，需要指定服務的ip及埠。
		ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://192.168.25.161:61616");
		//2、使用工廠物件建立一個Connection物件。
		Connection connection = connectionFactory.createConnection();
		//3、開啟連線，呼叫Connection物件的start方法。
		connection.start();
		//4、建立一個Session物件。
		//第一個引數：是否開啟事務。如果true開啟事務，第二個引數無意義。一般不開啟事務false。
		//第二個引數：應答模式。自動應答或者手動應答。一般自動應答。
		Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
		//5、使用Session物件建立一個Destination物件。兩種形式queue、topic，現在應該使用topic
		Topic topic = session.createTopic("test-topic");
		//6、使用Session物件建立一個Producer物件。
		MessageProducer producer = session.createProducer(topic);
		//7、建立一個Message物件，可以使用TextMessage。
		/*TextMessage textMessage = new ActiveMQTextMessage();
		textMessage.setText("hello Activemq");*/
		TextMessage textMessage = session.createTextMessage("topic message");
		//8、傳送訊息
		producer.send(textMessage);
		//9、關閉資源
		producer.close();
		session.close();
		connection.close();
	}

Consumer:

消費者：接收訊息。
第一步：建立一個ConnectionFactory物件。
第二步：從ConnectionFactory物件中獲得一個Connection物件。
第三步：開啟連線。呼叫Connection物件的start方法。
第四步：使用Connection物件建立一個Session物件。
第五步：使用Session物件建立一個Destination物件。和傳送端保持一致topic，並且話題的名稱一致。
第六步：使用Session物件建立一個Consumer物件。
第七步：接收訊息。
第八步：列印訊息。
第九步：關閉資源

@Test
	public void testTopicConsumer() throws Exception {
		//建立一個ConnectionFactory物件連線MQ伺服器
		ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://192.168.25.161:61616");
		//建立一個連線物件
		Connection connection = connectionFactory.createConnection();
		//開啟連線
		connection.start();
		//使用Connection物件建立一個Session物件
		Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
		//建立一個Destination物件。topic物件
		Topic topic = session.createTopic("test-topic");
		//使用Session物件建立一個消費者物件。
		MessageConsumer consumer = session.createConsumer(topic);
		//接收訊息
		consumer.setMessageListener(new MessageListener() {
			
			@Override
			public void onMessage(Message message) {
				//列印結果
				TextMessage textMessage = (TextMessage) message;
				String text;
				try {
					text = textMessage.getText();
					System.out.println(text);
				} catch (JMSException e) {
					e.printStackTrace();
				}
				
			}
		});
		System.out.println("topic消費者3啟動。。。。");
		//等待接收訊息
		System.in.read();
		//關閉資源
		consumer.close();
		session.close();
		connection.close();
	}