RabbitMQ简单模式
创始人
2024-05-01 10:15:30
0

🍁博客主页:👉不会压弯的小飞侠
✨欢迎关注:👉点赞👍收藏⭐留言✒
✨系列专栏:👉Linux专栏
🔥欢迎大佬指正,一起学习!一起加油!

在这里插入图片描述

目录

  • 🍁介绍
  • 🍁简单模式完成消息传递
  • 🍁总结


🍁介绍

  • “P”是我们的生产者,“C”是我们的消费者。 中间的框是一个队列 - RabbitMQ 保留的消息缓冲区 代表消费者。
  • 生产者将消息发送到“hello”队列。消费者收到 来自该队列的消息。
    在这里插入图片描述
  • 一个生产者、一个消费者,不需要设置交换机(使用默认的交换机)

🍁简单模式完成消息传递

  • 创建工程(生成者、消费者)

在这里插入图片描述

  • 往两个rabbitmq的pom.xml文件中添加依赖:
com.rabbitmqamqp-client5.6.0org.apache.maven.pluginsmaven-compiler-plugin3.8.01.81.8
  • 编写生产者发送消息
    • 编写消息生产者 Producter
package com.study.rabbitmq.simple;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import java.io.IOException;
import java.util.concurrent.TimeoutException;//简单模式的生产者
public class Producer {public static void main(String[] args) throws IOException, TimeoutException {//创建连接工厂ConnectionFactory connectionFactory = new ConnectionFactory();//设置主机connectionFactory.setHost("*************");  //主机IP//设置端口号connectionFactory.setPort(5672);//虚拟主机名称;默认为 /connectionFactory.setVirtualHost("/");//连接用户名;默认为guestconnectionFactory.setUsername("admin");//连接密码;默认为guestconnectionFactory.setPassword("root");//创建连接Connection connection = connectionFactory.newConnection();//创建信道Channel channel = connection.createChannel();// 声明(创建)队列/*** queue      参数1:队列名称* durable    参数2:是否定义持久化队列,当mq重启之后,还在* exclusive  参数3:是否独占本次连接*            ① 是否独占,只能有一个消费者监听这个队列*            ② 当connection关闭时,是否删除队列* autoDelete 参数4:是否在不使用的时候自动删除队列,当没有consumer时,自动删除* arguments  参数5:队列其它参数*/channel.queueDeclare("simple_queue", true, false, false, null);// 要发送的信息String message = "Hello RabbitMQ!";/*** 参数1:交换机名称,如果没有指定则使用默认Default Exchage* 参数2:路由key,简单模式可以传递队列名称* 参数3:配置信息* 参数4:消息内容*/channel.basicPublish("", "simple_queue", null, message.getBytes());System.out.println("已发送消息:" + message);// 关闭资源channel.close();connection.close();}
}
  • 测试生产者

在这里插入图片描述

在这里插入图片描述

  • 编写消费者接收消息
    • 编写消息消费者Consumer
package rabbitmq.simple;import com.rabbitmq.client.*;import java.io.IOException;
import java.util.concurrent.TimeoutException;public class Consumer {public static void main(String[] args) throws IOException, TimeoutException {//1.创建连接工厂ConnectionFactory factory = new ConnectionFactory();//2. 设置参数factory.setHost("********************");//主机ipfactory.setPort(5672); //端口  默认值 5672factory.setVirtualHost("/");//虚拟机 默认值/factory.setUsername("admin");//用户名factory.setPassword("root");//密码//3. 创建连接 ConnectionConnection connection = factory.newConnection();//4. 创建信道Channel channel = connection.createChannel();/*消费者不需要声明队列,queueDeclare(String queue, boolean durable, boolean exclusive, boolean autoDelete, Map arguments)参数:1. queue:队列名称2. durable:是否持久化,当mq重启之后,还在3. exclusive:* 是否独占。只能有一个消费者监听这队列* 当Connection关闭时,是否删除队列4. autoDelete:是否自动删除。当没有Consumer时,自动删除掉5. arguments:参数。*///如果没有一个名字叫simple_queue的队列,则会创建该队列,如果有则不会创建channel.queueDeclare("simple_queue",true,false,false,null);// 接收消息DefaultConsumer consumer = new DefaultConsumer(channel){/*回调方法,当收到消息后,会自动执行该方法1. consumerTag:标识2. envelope:获取一些信息,交换机,路由key...3. properties:配置信息4. body:数据*/@Overridepublic void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {System.out.println("consumerTag:"+consumerTag);System.out.println("Exchange:"+envelope.getExchange());System.out.println("RoutingKey:"+envelope.getRoutingKey());System.out.println("properties:"+properties);System.out.println("body:"+new String(body));}};/*basicConsume(String queue, boolean autoAck, Consumer callback)参数:1. queue:队列名称2. autoAck:是否自动确认 ,类似咱们发短信,发送成功会收到一个确认消息3. callback:回调对象*/// 消费者类似一个监听程序,主要是用来监听消息channel.basicConsume("simple_queue",true,consumer);}
}
  • 测试消费者

在这里插入图片描述
在这里插入图片描述

🍁总结

• P:生产者,也就是要发送消息的程序
• C:消费者:消息的接受者,会一直等待消息到来。
• queue:消息队列类似一个邮箱,可以缓存消息;生产者向其中投递消息,消费者从其中取出消息。

相关内容

热门资讯

安卓双系统添加应用,轻松实现多... 你有没有想过,你的安卓手机里可以同时运行两个系统呢?听起来是不是很酷?想象一边是熟悉的安卓系统,一边...
pipo安卓进系统慢,探究pi... 最近是不是发现你的Pipo安卓系统更新或者运行起来特别慢?别急,今天就来给你好好分析分析这个问题,让...
怎样使用安卓手机系统,安卓手机... 你有没有发现,安卓手机已经成为我们生活中不可或缺的一部分呢?从早晨闹钟响起,到晚上睡前刷剧,安卓手机...
双系统安卓安装caj,轻松实现... 你有没有想过,你的安卓手机里装上双系统,是不是就能同时享受安卓和Windows系统的乐趣呢?没错,这...
安卓使用ios系统教程,安卓用... 你是不是也和我一样,对安卓手机上的iOS系统充满了好奇?想要体验一下苹果的优雅和流畅?别急,今天我就...
安卓系统gps快速定位,畅享便... 你有没有遇到过这样的情况:手机里装了各种地图导航软件,但每次出门前都要等上好几分钟才能定位成功,急得...
安卓手机系统更新原理,原理与流... 你有没有发现,你的安卓手机最近是不是总在提醒你更新系统呢?别急,别急,让我来给你揭秘一下安卓手机系统...
安卓系统通知管理,全面解析与优... 你有没有发现,手机里的通知就像是一群调皮的小精灵,时不时地跳出来和你互动?没错,说的就是安卓系统的通...
安卓系统手机哪买,揭秘哪里购买... 你有没有想过,拥有一部安卓系统手机是多么酷的事情呢?想象你可以自由安装各种应用,不受限制地探索各种功...
安卓系统 ipv4,基于安卓系... 你知道吗?在智能手机的世界里,有一个系统可是无人不知、无人不晓,那就是安卓系统。而在这个庞大的安卓家...
目前安卓是什么系统,探索安卓系... 亲爱的读者,你是否曾好奇过,如今安卓系统究竟是什么模样?在这个科技飞速发展的时代,操作系统如同人体的...
安卓6.0系统比5.0,从5.... 你有没有发现,自从手机更新了安卓6.0系统,感觉整个人都清爽了不少呢?没错,今天咱们就来聊聊这个话题...
安卓2.36系统升级,功能革新... 你知道吗?最近安卓系统又来了一次大变身,那就是安卓2.36系统升级!这可不是一个小打小闹的更新,而是...
安卓系统源码怎么打开,并可能需... 你有没有想过,安卓系统的源码就像是一扇神秘的门,隐藏着无数的技术秘密?想要打开这扇门,你得掌握一些小...
安卓8.0系统体验视频,智能革... 你有没有听说安卓8.0系统最近可是火得一塌糊涂啊!作为一个紧跟科技潮流的数码达人,我当然要来给你好好...
宣传系统漫画app安卓,探索安... 亲爱的读者们,你是否曾在某个午后,百无聊赖地打开手机,想要寻找一些轻松愉悦的读物?今天,我要给你介绍...
鸿蒙替换安卓系统吗,开启智能生... 你知道吗?最近科技圈里可是炸开了锅,因为华为的新操作系统鸿蒙系统,据说要大举进军手机市场,替换掉安卓...
手机安卓系统深度清理,解锁手机... 手机里的东西是不是越来越多,感觉就像一个装满了杂物的储物柜?别急,今天就来教你一招——手机安卓系统深...
安卓上的windows系统,融... 你有没有想过,在安卓手机上也能体验到Windows系统的魅力呢?没错,这就是今天我要跟你分享的神奇故...
安卓系统焦点变化事件,Andr... 你知道吗?在安卓系统的世界里,最近发生了一件超级有趣的事情——焦点变化事件。这可不是什么小打小闹,它...