mq多个消费者消费一个消息_消息中间件——RabbitMQ(五)快速入门生产者与消费者...
生活随笔
收集整理的這篇文章主要介紹了
mq多个消费者消费一个消息_消息中间件——RabbitMQ(五)快速入门生产者与消费者...
小編覺得挺不錯的,現在分享給大家,幫大家做個參考.
求關注
快速入門生產者與消費者,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(五)快速入门生产者与消费者...的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: android线程间通信的几种方法_An
- 下一篇: xshell1分钟就会自动断_详解xsh