前言

RabbitMQ六種隊列模式-簡單隊列?[本文]
RabbitMQ六種隊列模式-工作隊列
RabbitMQ六種隊列模式-發布訂閱
RabbitMQ六種隊列模式-路由模式
RabbitMQ六種隊列模式-主題模式

在官網的教程中，描述了如上六類工作隊列模式：

簡單隊列模式：最簡單的工作隊列，其中一個消息生產者，一個消息消費者，一個隊列。也稱為點對點模式

工作模式：一個消息生產者，一個交換器，一個消息隊列，多個消費者。同樣也稱為點對點模式

發布/訂閱模式：無選擇接收消息，一個消息生產者，一個交換器，多個消息隊列，多個消費者。稱為發布/訂閱模式

路由模式：在發布/訂閱模式的基礎上，有選擇的接收消息，也就是通過 routing 路由進行匹配條件是否滿足接收消息。

主題模式：同樣是在發布/訂閱模式的基礎上，根據主題匹配進行篩選是否接收消息，比第四類更靈活。

RPC模式：與上面其他5種所不同之處，類模式是擁有請求/回復的。也就是有響應的，上面5種都沒有。

接下來幾篇文章一起來看看這幾種隊列模式吧，本篇為簡單隊列模式。

文章目錄

1 實現功能2 構建項目2.1 導入依賴2.2 封裝Connection3 生產者4 消費者5 測試環節5.1 啟動RabbitMQ5.2 創建vhost5.3 依次運行Producer\Customer6 簡單隊列總結

1 實現功能

功能描述：一個生產者 P 發送消息到隊列 Q，一個消費者 C 接收

P 表示為生產者 、C 表示為消費者，紅色表示隊列。

2 構建項目

創建一個簡單的maven項目

• rabbitmq 父工程
  -- common 存放公用工具類
  -- customer 消費者
  -- producer生產者

2.1 導入依賴

在 rabbitmq 父工程 pom.xml 導入 maven 依賴

<dependencies><dependency><groupId>com.rabbitmq</groupId><artifactId>amqp-client</artifactId><version>3.6.5</version></dependency> </dependencies>

2.2 封裝Connection

common模塊中封裝 rabbitmq 連接類

public?class?MQConnectionUtils?{public?static?Connection?newConnection()?throws?IOException,?TimeoutException?{/**?1.定義連接工廠?*/ConnectionFactory?factory?=?new?ConnectionFactory();/**?2.設置服務器地址?*/factory.setHost("127.0.0.1");/**?3.設置協議端口號?*/factory.setPort(5672);/**?4.設置vhost?*/factory.setVirtualHost("test001_host");/**?5.設置用戶名稱?*/factory.setUsername("guest");/**?6.設置用戶密碼?*/factory.setPassword("guest");/**?7.創建新的連接?*/Connection?newConnection?=?factory.newConnection();return?newConnection;}}

3 生產者

生產者負責創建消息隊列并發送消息入列，簡單分為5步：

獲取連接

創建通道

創建隊列聲明

發送消息

關閉隊列

public?class?Producer?{/**?隊列名稱?*/private?static?final?String?QUEUE_NAME?=?"test_queue";public?static?void?main(String[]?args)?throws?IOException,?TimeoutException?{/**?1.獲取連接?*/Connection?newConnection?=?MQConnectionUtils.newConnection();/**?2.創建通道?*/Channel?channel?=?newConnection.createChannel();/**?3.創建隊列聲明?*/channel.queueDeclare(QUEUE_NAME,?false,?false,?false,?null);String?msg?=?"我是生產者生成的消息";System.out.println("生產者發送消息:"?+?msg);/**?4.發送消息?*/channel.basicPublish("",?QUEUE_NAME,?null,?msg.getBytes());channel.close();newConnection.close();} }

4 消費者

消費者實現和生產者實現過程差不多，但是沒有關閉連接和通道，是因為要消費者一直等待隨時可能發來的消息，大致分為如下3步：

獲取連接

獲取通道

監聽隊列

public?class?Customer?{/**?隊列名稱?*/private?static?final?String?QUEUE_NAME?=?"test_queue";public?static?void?main(String[]?args)?throws?IOException,?TimeoutException?{System.out.println("002");/**?1.獲取連接?*/Connection?newConnection?=?MQConnectionUtils.newConnection();/**?2.獲取通道?*/Channel?channel?=?newConnection.createChannel();channel.queueDeclare(QUEUE_NAME,?false,?false,?false,?null);DefaultConsumer?defaultConsumer?=?new?DefaultConsumer(channel)?{@Overridepublic?void?handleDelivery(String?consumerTag,?Envelope?envelope,?AMQP.BasicProperties?properties,?byte[]?body)throws?IOException?{String?msgString?=?new?String(body,?"UTF-8");System.out.println("消費者獲取消息:"?+?msgString);}};/**?3.監聽隊列?*/channel.basicConsume(QUEUE_NAME,?true,?defaultConsumer);}}

5 測試環節

至此，整個項目代碼寫完了，接下來就是測試環節

5.1 啟動RabbitMQ

5.2 創建vhost

5.3 依次運行Producer\Customer

Producer生產者啟動

Rabbit管理平臺，三條消息

Customer消費者啟動

6 簡單隊列總結

簡單隊列也稱為點對點，即一個生產者對應一個消費者，生產者發送消息到隊列，消費者在隊列中取出消息消費。

生產者大致步驟：

獲取連接

創建通道

創建隊列聲明

發送消息

關閉隊列

消費者大致步驟：

獲取連接

獲取通道

監聽隊列

消費消息

簡單隊列雖然簡單，但是有一些不足，比如這種點對點無疑在復雜情況下會產生大量冗余代碼，繼續看下一篇工作隊列吧。

案例代碼：https://www.lanzous.com/i5ydu6d

總結

以上是生活随笔為你收集整理的【转】RabbitMQ六种队列模式-1.简单队列模式的全部內容，希望文章能夠幫你解決所遇到的問題。

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