現在微服務盛行， 我們通常會進行解耦， 這時候就需要異步的消息隊列來幫助各個服務之間解耦

rabbitmq的基本概念介紹

rabbitmq的基本概念有消息producer(消息生產者)、exchange(交換機)、queue(隊列)、consumer(消費者)、routingKey

(圖中的P是producer， 即消息生產者， 中簡的Server是Exchange(交換機) 和 Queue(隊列))

• Queue(隊列)

queue是存放消息的隊列， 實際上就是一個存放消息數據結構為隊列的一個容器

• exchange(交換機)

我們可能會簡單的以為發送者會把消息發送到隊列中， 然后消費者對隊列進行監聽。事實上， 消息發送者永遠不會將消息直接發送到隊列中， 而是將消息發送到exhang中， 再由exchange通過一定的路由規則路由到對應的消息隊列中。
交換機有四種類型:

Direct Topic Headers FanoutDirect Exchange:

• routingKey

在上面介紹exchange中說到消息通過一定的路由規則路由到對應的隊列中， routingKey就是起著這樣的一個作用，通常我們發送消息到exchane中的時候會攜帶一個routingKey, 而這個routingKey就是exchange和queue綁定的一個規則， 由此便可以將消息從exchange再發送到對應的queue上

參考文章https://segmentfault.com/a/11...

SpringBoot中使用rabbitmq

首先添加以下依賴：

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

配置項如下：

spring:rabbitmq:port: 5672password: guestusername: guesthost: localhostlistener:simple:acknowledge-mode: manualconcurrency: 1max-concurrency: 1retry:enabled: true

在瀏覽器輸入http://localhost:15672/, 在mq上我們新建了一個名為exchange1, routingKey為exhcange1-queue1的exchange， 并且映射到名為queue1的隊列,

發送消息代碼Prodcuer：

public class Sender{@Autowiredprivate RabbitTemplate rabbitTemplate;public void send(Object object) {CorrelationData correlationData = new CorrelationData();correlationData.setId("exchange1-queue1-id");String message = "hello world";rabbitTemplate.convertAndSend("exchange1", "exchange1-queue1", "helloworld", new CorrelationData());} }

在上面的代碼中我們發送了一個消息到名為"exchange1", routingKey為"exchange1-queue1"的消息。我們啟動rabbitmq。
發送后可以在mq上看到如下圖已經成功發送了。

接下來貼上接受消息的receiver代碼：

@Component public class Receiver {@RabbitListener(queues = "queue1")public void receive(Message message, Channel channel) {try {System.out.println(message.getBody());} catch (Exception e) {e.printStackTrace();}} }

接受消息后再看mq上如下圖：

可以看出queue1上Ready一欄是0，但是Unacked一欄和Total一欄依然有消息， 這是因為我們再配置文件中設置的是手動的ack，這時候代碼中沒有進行ack, mq會認為消費者沒有成功消費掉這條消息， 這時候就需要在配置文件中設置成自動ack, 或者在代碼中手動進行ack,在消費者后添加如下代碼：

channel.basicAck(message.getMessageProperties().getDeliveryTag(), true);

總結

以上是生活随笔為你收集整理的rabbitmq的基本使用的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。