求關注

快速入門生產者與消費者，SpringBoot整合RabbitMQ！

前言

本章我們來一次快速入門RabbitMQ——生產者與消費者。需要構建一個生產端與消費端的模型。什么意思呢？我們的生產者發送一條消息，投遞到RabbitMQ集群也就是Broker。

我們的消費端進行監聽RabbitMQ，當發現隊列中有消息后，就進行消費。

1. 環境準備

本次整合主要采用SpringBoot框架，需要對SpringBoot的使用有一定了解。

2.大概步驟

我們來看下大概步驟：

• ConnectionFacorty：獲取連接工廠
• Connection：一個連接
• Channel：數據通信信道，可發送和接收消息
• Queue：具體的消息存儲隊列
• Producer & Consumer 生產者和消費者

這個連接工廠需要配置一些相應的信息，例如: RabbitMQ節點的地址，端口號，VirtualHost等等。

Channel是我們RabbitMQ所有消息進行交互的關鍵。

3. 項目實戰

3.1 連接工廠

/** * * @ClassName: ConnectionUtils * @Description: 連接工具類* @author Coder編程* @date 2019年6月21日 上午22:28:22 * */public class ConnectionUtils { public static Connection getConnection() throws IOException, TimeoutException { //定義連接工廠 ConnectionFactory factory = new ConnectionFactory(); //設置服務地址 factory.setHost("127.0.0.1"); //端口 factory.setPort(5672);//amqp協議 端口 類似與mysql的3306 //設置賬號信息，用戶名、密碼、vhost factory.setVirtualHost("/vhost_cp"); factory.setUsername("user_cp"); factory.setPassword("123456"); // 通過工程獲取連接 Connection connection = factory.newConnection(); return connection; }}

3.2 生產端

/** * * @ClassName: Producer * @Description: 生產者* @author Coder編程* @date 2019年7月30日 上午21:04:43 * */public class Producer { public static void main(String[] args) throws Exception { System.out.println("Producer start..."); //1 創建ConnectionFactory Connection connection = ConnectionUtils.getConnection(); //2 通過connection創建一個Channel Channel channel = connection.createChannel(); //3 通過Channel發送數據 for(int i=0; i < 5; i++){ String msg = "Hello RabbitMQ!"; //1 exchange 2 routingKey channel.basicPublish( 與50位技術專家面對面20年技術見證，附贈技術全景圖

總結

以上是生活随笔為你收集整理的mq多个消费者消费一个消息_消息中间件——RabbitMQ（五）快速入门生产者与消费者...的全部內容，希望文章能夠幫你解決所遇到的問題。

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