簡(jiǎn)單隊(duì)列模式

紅色：隊(duì)列
P：消息的生產(chǎn)者
C：消息的消費(fèi)者

生產(chǎn)者，將消息發(fā)送到隊(duì)列
消費(fèi)者，從隊(duì)列中獲取消息

配置依賴

導(dǎo)入RabbitMQ客戶端依賴

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

ConnectionUtil

獲取連接

package cn.itcast.rabbitmq.util;import com.rabbitmq.client.ConnectionFactory; import com.rabbitmq.client.Connection;public class ConnectionUtil {public static Connection getConnection() throws Exception {// 定義連接工廠ConnectionFactory factory = new ConnectionFactory();// 設(shè)置服務(wù)地址factory.setHost("localhost");// 端口factory.setPort(5672);// 設(shè)置賬號(hào)信息，用戶名、密碼、vhostfactory.setVirtualHost("/taotao");factory.setUsername("taotao");factory.setPassword("taotao");// 通過(guò)工程獲取連接Connection connection = factory.newConnection();return connection;}}

Send

發(fā)送者

package cn.itcast.rabbitmq.simple;import cn.itcast.rabbitmq.util.ConnectionUtil;import com.rabbitmq.client.Channel; import com.rabbitmq.client.Connection;public class Send {private final static String QUEUE_NAME = "test_queue";public static void main(String[] argv) throws Exception {// 獲取到連接以及mq通道Connection connection = ConnectionUtil.getConnection();// 從連接中創(chuàng)建通道Channel channel = connection.createChannel();// 聲明（創(chuàng)建）隊(duì)列channel.queueDeclare(QUEUE_NAME, false, false, false, null);// 消息內(nèi)容String message = "Hello World!";channel.basicPublish("", QUEUE_NAME, null, message.getBytes());System.out.println(" [x] Sent '" + message + "'");//關(guān)閉通道和連接channel.close();connection.close();} }

Recv

接收者

package cn.itcast.rabbitmq.simple;import cn.itcast.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";public static void main(String[] argv) throws Exception {// 獲取到連接以及mq通道Connection connection = ConnectionUtil.getConnection();Channel channel = connection.createChannel();// 聲明隊(duì)列channel.queueDeclare(QUEUE_NAME, false, false, false, null);// 定義隊(duì)列的消費(fèi)者QueueingConsumer consumer = new QueueingConsumer(channel);// 監(jiān)聽(tīng)隊(duì)列channel.basicConsume(QUEUE_NAME, true, consumer);// 獲取消息while (true) {QueueingConsumer.Delivery delivery = consumer.nextDelivery();String message = new String(delivery.getBody());System.out.println(" [x] Received '" + message + "'");}} }

發(fā)送消息

查看隊(duì)列消息
可以設(shè)置，更新頻率

查看隊(duì)列詳情

查看隊(duì)列消息

消費(fèi)者

聲明隊(duì)列
因?yàn)?#xff0c;消費(fèi)者不知道這個(gè)隊(duì)列是否存在

如果，隊(duì)列不存在，創(chuàng)建隊(duì)列
如果，隊(duì)列存在，會(huì)忽略聲明隊(duì)列語(yǔ)句

接收之后

查看隊(duì)列消息，消息為0

被接收之后，消息就沒(méi)有了
消費(fèi)者，處于監(jiān)聽(tīng)狀態(tài)

再次，發(fā)送一條消息
消費(fèi)者，會(huì)馬上接收到消息

總結(jié)

以上是生活随笔為你收集整理的RabbitMQ简单队列模式的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

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