spring boot-17.RabbitMQ

1.JMS&AMQP

JMS（Java MessageService）其實是指JMS API。JMS是由Sun公司早期提出的消息標準，旨在爲java應用提供統一的消息操做，包括create、send、receive等。 JMS提供了兩種消息模型，peer-2-peer(點對點)以及publish-subscribe（發佈訂閱）模型。在JMS中，消息路由很是簡單，由producer和consumer連接到同一個queue（p2p）或者topic（pub/sub）來實現消息的路由。

AMQP (高級消息隊列協議)AMQP是一種協議，更準確的說是一種binary wire-level protocol（連接協議）。這是其和JMS的本質差異，AMQP不從API層進行限定，而是直接定義網絡交換的數據格式。這使得實現了AMQP的provider自然性就是跨平臺的。在AMQP中增長了Exchange和binding的角色。producer將消息發送給Exchange，binding決定Exchange的消息應該發送到那個queue，而consumer直接從queue中消費消息。queue和exchange的bind有consumer來決定。

2.RabbitMQ基本概念（來自https://www.jianshu.com/p/79ca08116d57）

• Message
  消息，消息是不具名的，它由消息頭和消息體組成。消息體是不透明的，而消息頭則由一系列的可選屬性組成，這些屬性包括routing-key（路由鍵）、priority（相對於其餘消息的優先權）、delivery-mode（指出該消息可能須要持久性存儲）等。
• Publisher
  消息的生產者，也是一個向交換器發佈消息的客戶端應用程序。
• Exchange
  交換器，用來接收生產者發送的消息並將這些消息路由給服務器中的隊列。
• Binding
  綁定，用於消息隊列和交換器之間的關聯。一個綁定就是基於路由鍵將交換器和消息隊列鏈接起來的路由規則，因此能夠將交換器理解成一個由綁定構成的路由表。
• Queue
  消息隊列，用來保存消息直到發送給消費者。它是消息的容器，也是消息的終點。一個消息可投入一個或多個隊列。消息一直在隊列裏面，等待消費者鏈接到這個隊列將其取走。
• Connection
  網絡鏈接，好比一個TCP鏈接。
• Channel
  信道，多路複用鏈接中的一條獨立的雙向數據流通道。信道是創建在真實的TCP鏈接內地虛擬鏈接，AMQP 命令都是經過信道發出去的，無論是發佈消息、訂閱隊列仍是接收消息，這些動做都是經過信道完成。由於對於操做系統來講創建和銷燬 TCP 都是很是昂貴的開銷，因此引入了信道的概念，以複用一條 TCP 鏈接。
• Consumer
  消息的消費者，表示一個從消息隊列中取得消息的客戶端應用程序。
• Virtual Host
  虛擬主機，表示一批交換器、消息隊列和相關對象。虛擬主機是共享相同的身份認證和加密環境的獨立服務器域。每一個 vhost 本質上就是一個 mini 版的 RabbitMQ 服務器，擁有本身的隊列、交換器、綁定和權限機制。vhost 是 AMQP 概念的基礎，必須在鏈接時指定，RabbitMQ 默認的 vhost 是 / 。
• Broker
  表示消息隊列服務器實體。

AMQP 中的消息路由

AMQP 中消息的路由過程和 Java 開發者熟悉的 JMS 存在一些差異，AMQP 中增長了 Exchange 和 Binding 的角色。生產者把消息發佈到 Exchange 上，消息最終到達隊列並被消費者接收，而 Binding 決定交換器的消息應該發送到那個隊列。

Exchange 類型

Exchange分發消息時根據類型的不一樣分發策略有區別，目前共四種類型：direct、fanout、topic、headers 。headers 匹配 AMQP 消息的 header 而不是路由鍵，此外 headers 交換器和 direct 交換器徹底一致，但性能差不少，目前幾乎用不到了，因此直接看另外三種類型：

（1）.direct

消息中的路由鍵（routing key）若是和 Binding 中的 binding key 一致， 交換器就將消息發到對應的隊列中。路由鍵與隊列名徹底匹配，若是一個隊列綁定到交換機要求路由鍵爲「dog」，則只轉發 routing key 標記爲「dog」的消息，不會轉發「dog.puppy」，也不會轉發「dog.guard」等等。它是徹底匹配、單播的模式。

（2）fanout

每一個發到 fanout 類型交換器的消息都會分到全部綁定的隊列上去。fanout 交換器不處理路由鍵，只是簡單的將隊列綁定到交換器上，每一個發送到交換器的消息都會被轉發到與該交換器綁定的全部隊列上。很像子網廣播，每臺子網內的主機都得到了一份複製的消息。fanout 類型轉發消息是最快的。

（3）topic

topic 交換器經過模式匹配分配消息的路由鍵屬性，將路由鍵和某個模式進行匹配，此時隊列須要綁定到一個模式上。它將路由鍵和綁定鍵的字符串切分紅單詞，這些單詞之間用點隔開。它一樣也會識別兩個通配符：符號「#」和符號「 」。#匹配0個或多個單詞，匹配很少很多一個單詞。

3.安裝

能夠去https://www.rabbitmq.com/download.html 官網下載安裝，運行rabbitmq-server。

我是經過docker 安裝的，版本是官方版本，tag是3-management，帶有管理後臺的。

4.spring boot 集成 RabbitMQ

(1)引入rabbitmq 依賴

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-amqp</artifactId>
</dependency>

（2）配置rabbitmq，創建Exchange和Queen，Buding

spring.rabbitmq.host=192.168.1.215 spring.rabbitmq.username=guest spring.rabbitmq.password=guest #也可不寫，默認5672 spring.rabbitmq.port=5672 #也可不配，默認爲/ spring.rabbitmq.virtual-host=/

Exchange和Queen，Buding 能夠經過管理後臺來實現，管理後臺的端口號默認爲15672，能夠創建Exchange 和 queen 以及經過routing key 在交換器和隊列之間創建路由規則。

（3）自動配置

RabbitMQ的自動配置在org.springframework.boot.autoconfigure.amqp.RabbitAutoConfiguration下面，自動配置了rabbitConnectionFactory建立鏈接，rabbitTemplate 提供模板操做，amqpAdmin 提供管理功能。rabbitmq的其餘相關配置可在全局配置文件中以spring.rabbitmq 來配置。

（4）發送消息

能夠直接注入RabbitTemplate，而後調用send 方法或者convertAndSend 方法發送消息，同時制定要發送的Exchange名稱， routing key 值，消息內容。

public void sendObject() { Employee emp = new Employee(1, "王小二", "dedwew@163.com", 1, 1); rabbitTemplate.convertAndSend("exchanges.direct","xxx",emp); } 

（5）接收消息

public void receiveMsg() { Object msg = rabbitTemplate.receiveAndConvert("xxx"); System.out.println(msg); }

（6）帶有監聽事件的接收消息

@RabbitListener(queues= {"xxx"}) public void receive(Employee employee) { System.out.println(employee.toString()); }

（7）自定義json格式的消息轉換器

@Configuration public class AmqpMessageConvert { @Bean public MessageConverter messageConverter() { return new Jackson2JsonMessageConverter(); } }