RabbitMQ安裝與使用

RabbitMQ安裝與啟動

 

window安裝

 

（1）下載並安裝 Eralng

 

（2）下載並安裝rabbitmq

 

雙擊安裝，注意不要安裝在包含中文和

 

空格的目錄下！安裝后window服務中就存在rabbitMQ了，並且是啟動狀態。

 

進入官網下載：https://www.rabbitmq.com/install-windows.html

 

3）安裝管理界面（插件）

 

進入rabbitMQ安裝目錄的sbin目錄，輸入命令

 

rabbitmq‐plugins enable rabbitmq_management 

 

（4）重新啟動服務

（5）打開瀏覽器，地址欄輸入http://127.0.0.1:15672 ,即可看到管理界面的登陸頁

 

 

 

 

輸入用戶名和密碼，都為guest 進入主界面

 

 

 

最上側的導航以此是：概覽、連接、信道、交換器、隊列、用戶管理

 docker安裝

 

下載鏡像：

docker pull rabbitmq:management

創建容器，rabbitmq需要有映射以下端口: 5671 5672 4369 15671 15672 25672

15672 (if management plugin is enabled)

15671 management監聽端口

5672, 5671 (AMQP 0-9-1 without and with TLS)

4369 (epmd) epmd 代表 Erlang 端口映射守護進程

25672 (Erlang distribution)

docker run -di --name=tensquare_rabbitmq -p 5671:5617 -p 5672:5672 -p
4369:4369 -p 15671:15671 -p 15672:15672 -p 25672:25672 rabbitmq:management

 

瀏覽器訪問 http://xxxxxx:15672/#/

springboot引入rabbitmq依賴：

 

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

 

編寫配置文件application.yml

spring:
     rabbitmq:
       host: xxxxxx 

 

 

 

直接模式（Direct）

 

什么是Direct模式

 

我們需要將消息發給唯一一個節點時使用這種模式，這是最簡單的一種形式。

 

 

 

任何發送到Direct Exchange的消息都會被轉發到RouteKey中指定的Queue。

1.一般情況可以使用rabbitMQ自帶的Exchange：”"(該Exchange的名字為空字符串，下

文稱其為default Exchange)。

2.這種模式下不需要將Exchange進行任何綁定(binding)操作

3.消息傳遞時需要一個“RouteKey”，可以簡單的理解為要發送到的隊列名字。

4.如果vhost中不存在RouteKey中指定的隊列名，則該消息會被拋棄。

自我理解：消費者自己有指定的隊列，生產者也有指定的隊列通過routerkey經過rabbitmq默認的空exchange到相對應的隊列中

生產者：

import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.amqp.rabbit.core.RabbitMessagingTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;

@RunWith(SpringRunner.class)
@SpringBootTest(classes= Application.class)
public class MqTest {

    @Autowired
    private RabbitMessagingTemplate rabbitTemplate;

    @Test
    public void testSend(){
        rabbitTemplate.convertAndSend("queue1","我要紅包");
    }

}

消費者：

import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

/**
 * 直接模式-消費者
 */
@Component
@RabbitListener(queues = "queue1")
public class Consumer1 {

    @RabbitHandler
    public void sendMessage(String msg){
        System.out.println("接收到的消息："+msg);
    }
}

測試

開啟多個消費者工程，測試運行消息生產者工程，會發現只有一個消費者工程可以接收到消息。

如何在IDEA中多次啟動同一個程序呢？

（1）選擇IDEA右上角的類名稱按鈕

 

（2）選擇Edit Configurations 

 

（3）在彈出窗口中取消單例模式 ，點擊OK 

 

（4）每次運行前修改application.yml，指定不同的端口 

server:
  port: 9202 

運行后在控制台可以看到多個窗口 

 

 

 

分列模式（Fanout）

 

什么是分列模式

當我們需要將消息一次發給多個隊列時，需要使用這種模式。如下圖：

 

 

 

任何發送到Fanout Exchange的消息都會被轉發到與該Exchange綁定(Binding)的所有
Queue上。
1.可以理解為路由表的模式
2.這種模式不需要RouteKey
3.這種模式需要提前將Exchange與Queue進行綁定，一個Exchange可以綁定多個
Queue，一個Queue可以同多個Exchange進行綁定。
4.如果接受到消息的Exchange沒有與任何Queue綁定，則消息會被拋棄 。

將相應隊列綁定到fanout交換機上

個人理解：相應隊列queue綁定到fanout交換機上，生產者往fanout交換機發送消息，綁定好的queue就都有消息了，消費者只要到指定的隊列上去取就好了。

生產者：

@Test
public void testSendFanout(){
    rabbitTemplate.convertAndSend("exchange1","", "分列模式走起");
}

消費者：

創建消息監聽類，用於監聽queue2的消息

import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

/**
 * 分列模式-消費者
 */
@Component
@RabbitListener(queues = "queue2")
public class Consumer2 {

    @RabbitHandler
    public void sendMessage(String msg){
        System.out.println("queue2接收到的消息："+msg);
    }
}

 

創建消息監聽類，用於監聽queue3的消息

import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

/**
 * 分列模式-消費者
 */
@Component
@RabbitListener(queues = "queue3")
public class Consumer3 {

    @RabbitHandler
    public void sendMessage(String msg){
        System.out.println("queue3接收到的消息："+msg);
    }
}

測試

啟動消費者工程，發送消息測試,兩個都接受到了分裂模式走起消息。

 

主題模式（Topic）

 

什么是主題模式

任何發送到Topic Exchange的消息都會被轉發到所有關心RouteKey中指定話題的Queue上

 

 

 

如上圖所示

此類交換器使得來自不同的源頭的消息可以到達一個對列，其實說的更明白一點就是模

糊匹配的意思，例如：上圖中紅色對列的routekey為usa.#，#代表匹配任意字符，但是

要想消息能到達此對列，usa.必須匹配后面的#好可以隨意。圖中usa.news

usa.weather,都能找到紅色隊列，符號 # 匹配一個或多個詞，符號 * 匹配不多不少一個

詞。因此 usa.# 能夠匹配到 usa.news.XXX ，但是 usa.* 只會匹配到 usa.XXX 。

注：

交換器說到底是一個名稱與隊列綁定的列表。當消息發布到交換器時，實際上是由你所

連接的信道，將消息路由鍵同交換器上綁定的列表進行比較，最后路由消息。

任何發送到Topic Exchange的消息都會被轉發到所有關心RouteKey中指定話題的

Queue上

1.這種模式較為復雜，簡單來說，就是每個隊列都有其關心的主題，所有的消息都帶有一

個“標題”(RouteKey)，Exchange會將消息轉發到所有關注主題能與RouteKey模糊匹配的

隊列。

2.這種模式需要RouteKey，也需要提前綁定Exchange與Queue。

3.在進行綁定時，要提供一個該隊列關心的主題，如“#.log.#”表示該隊列關心所有涉及

log的消息(一個RouteKey為”MQ.log.error”的消息會被轉發到該隊列)。

“#”表示0個或若干個關鍵字，“”表示一個關鍵字。如“log.”能與“log.warn”匹配，無法與“log.warn.timeout”匹配；但是“log.#”能與上述兩者匹配。

5.同樣，如果Exchange沒有發現能夠與RouteKey匹配的Queue，則會拋棄此消息

創建topic類型的交換機，綁定相應隊列，並添加相應routerkey的值。

queue1 routerkey值為： goods.#

queue2 routerkey值為：#.log

queue3 routerkey值為: goods.log

生產者：

@Test
public void testSendTopic1(){
    rabbitTemplate.convertAndSend("topictest","goods.aaa","主題模式");
}

@Test
public void testSendTopic2(){
    rabbitTemplate.convertAndSend("topictest","article.content.log","主題模式");


@Test
public void testSendTopic3(){
    rabbitTemplate.convertAndSend("topictest","goods.log","主題模式");
}

測試結果：