文章目錄

• 一、work模式
• • 1.1. 圖示
  • 1.2. 消費者1
  • 1.3. 消費者2
  • 1.4. 生產者
  • 1.5. 測試
• 二、Work模式的“能者多勞”
• • 2.1. 關鍵配置
  • 2.2. 測試：

一、work模式

1.1. 圖示

一個生產者、2個消費者。

一個消息只能被一個消費者獲取。

1.2. 消費者1

package com.gblfy.rabbitmq.work;import com.gblfy.rabbitmq.util.ConnectionUtil; import com.rabbitmq.client.Channel; import com.rabbitmq.client.Connection; import com.rabbitmq.client.QueueingConsumer;public class Recv {private final static String QUEUE_NAME = "test_queue_work";public static void main(String[] argv) throws Exception {// 獲取到連接以及mq通道Connection connection = ConnectionUtil.getConnection();Channel channel = connection.createChannel();// 聲明隊列channel.queueDeclare(QUEUE_NAME, false, false, false, null);// 同一時刻服務器只會發一條消息給消費者// channel.basicQos(1);// 定義隊列的消費者QueueingConsumer consumer = new QueueingConsumer(channel);// 監聽隊列，手動返回完成channel.basicConsume(QUEUE_NAME, false, consumer);// 獲取消息while (true) {QueueingConsumer.Delivery delivery = consumer.nextDelivery();String message = new String(delivery.getBody());System.out.println(" [x] Received '" + message + "'");//休眠Thread.sleep(10);// 返回確認狀態channel.basicAck(delivery.getEnvelope().getDeliveryTag(), false);}} }

1.3. 消費者2

package com.gblfy.rabbitmq.work;import com.gblfy.rabbitmq.util.ConnectionUtil; import com.rabbitmq.client.Channel; import com.rabbitmq.client.Connection; import com.rabbitmq.client.QueueingConsumer;public class Recv2 {private final static String QUEUE_NAME = "test_queue_work";public static void main(String[] argv) throws Exception {// 獲取到連接以及mq通道Connection connection = ConnectionUtil.getConnection();Channel channel = connection.createChannel();// 聲明隊列channel.queueDeclare(QUEUE_NAME, false, false, false, null);// 同一時刻服務器只會發一條消息給消費者//channel.basicQos(1);// 定義隊列的消費者QueueingConsumer consumer = new QueueingConsumer(channel);// 監聽隊列，手動返回完成狀態channel.basicConsume(QUEUE_NAME, false, consumer);// 獲取消息while (true) {QueueingConsumer.Delivery delivery = consumer.nextDelivery();String message = new String(delivery.getBody());System.out.println(" [x] Received '" + message + "'");// 休眠1秒Thread.sleep(1000);channel.basicAck(delivery.getEnvelope().getDeliveryTag(), false);}} }

1.4. 生產者

向隊列中發送10條消息。

1.5. 測試

測試結果：
1、消費者1和消費者2獲取到的消息內容是不同的，同一個消息只能被一個消費者獲取。
2、消費者1和消費者2獲取到的消息的數量是相同的，一個是奇數一個是偶數。

其實，這樣是不合理的，應該是消費者1要比消費者2獲取到的消息多才對。

二、Work模式的“能者多勞”

2.1. 關鍵配置

2.2. 測試：

啟動消費者1

啟動消費者2

查看管控臺消費者是否啟動完畢


啟動生產者

消息一共發送10條


消費者1比消費者2獲取的消息更多。

總結

以上是生活随笔為你收集整理的RabbitMQ的5种队列_Work模式_入门试炼_第5篇的全部內容，希望文章能夠幫你解決所遇到的問題。

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