求關(guān)注

快速入門生產(chǎn)者與消費者，SpringBoot整合RabbitMQ！

前言

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

我們的消費端進行監(jiān)聽RabbitMQ，當發(fā)現(xiàn)隊列中有消息后，就進行消費。

1. 環(huán)境準備

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

2.大概步驟

我們來看下大概步驟：

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

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

Channel是我們RabbitMQ所有消息進行交互的關(guān)鍵。

3. 項目實戰(zhàn)

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(); //設(shè)置服務地址 factory.setHost("127.0.0.1"); //端口 factory.setPort(5672);//amqp協(xié)議 端口 類似與mysql的3306 //設(shè)置賬號信息，用戶名、密碼、vhost factory.setVirtualHost("/vhost_cp"); factory.setUsername("user_cp"); factory.setPassword("123456"); // 通過工程獲取連接 Connection connection = factory.newConnection(); return connection; }}

3.2 生產(chǎn)端

/** * * @ClassName: Producer * @Description: 生產(chǎn)者* @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 創(chuàng)建ConnectionFactory Connection connection = ConnectionUtils.getConnection(); //2 通過connection創(chuàng)建一個Channel Channel channel = connection.createChannel(); //3 通過Channel發(fā)送數(shù)據(jù) for(int i=0; i < 5; i++){ String msg = "Hello RabbitMQ!"; //1 exchange 2 routingKey channel.basicPublish( 與50位技術(shù)專家面對面20年技術(shù)見證，附贈技術(shù)全景圖

總結(jié)

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

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。