[RabbitMQ] RabbitMQ简单概述,用法和交换机模型

MQ概述:

Message Queue(消息队列),实在消息的传输过程中保存消息的容器,都用于分布式系统之间进行通信
分布式系统通信的两种方式:直接远程调用 和 借助第三昂 完成间接通信
发送方称谓生产者,接收方称为消费者

MQ优势和劣势

优势:

  1. 应用解耦:如 把一个系统的不同功能拆分出来,中间连接mq,那么其中一个功能的系统挂掉也不会影响其它系统,达到解耦
  2. 异步提速:如 一个订单接受下单请求,正常需要去库存,支付,物流三个系统走一遍,但是可以通过直接交手mq然后直接返回,那三个系统用mq去排队进行操作,大大缩短等待时间,增加系统吞吐量
  3. 削峰填谷

劣势:

  1. 系统可用性降低
  2. 系统复杂性提高
  3. 一致性问题

RabbitMQ时基于AMQP(高级信息队里额协议)用于软件通信的中间件

RabbitMQ四大核心

  1. 生产者
  2. 消费者
  3. 队列
  4. 交换机

AMQP协议是一种二进制协议,它定义了一组规则和标准,以确保消息可以在不同的应用程序和平台之间传递和解释,AMQP包含四个核心组件:

  1. 消息
  2. 交换机
  3. 队列
  4. 绑定

工作原理

Broker:接受和分发消息的应用。RabbitMQ Server 就是 Message Broker
Virtual host:是一个虚拟主机的概念,一个Broker可以有多个Virtual host,每个Virtual都有一套自己的Exchange(交换机)和Queue(队列)

RabbitMQ工作原理

快速上手

  1. 导入依赖
    <dependency><groupId>com.rabbitmq</groupId><artifactId>amqp-client</artifactId><version>5.16.0</version></dependency>
  1. 写一个生产者
public class Producer {public static void main(String[] args) throws Exception {String queueName = "test_queue_name";String exchangeName = "test_exchange_name";//创建链接工厂ConnectionFactory factory = new ConnectionFactory();//服务地址factory.setHost("xx.xx.xx.xx");//账号密码factory.setUsername("root");factory.setPassword("xxx");//端口号factory.setPort(5672);//创建链接Connection connection = factory.newConnection();//创建信道Channel channel = connection.createChannel();/*** 创建交换机* params:* 1. 交换机名称* 2. 交换机类型:direct,topic,fanout,headers* 3. 指定交换机是否持久化 - true:那么交换机的元数据要持久化* 4. 指定交换机没有队列绑定时是否需要删除* 5. Map<String,Object>用来指定我们交换机其他的结构化参数,*/channel.exchangeDeclare(exchangeName, BuiltinExchangeType.DIRECT,true,false,null);/*** 生成一个队列* params* 1. 队列名称* 2. 队列是否需要持久化 - 是队列名称等这些元数据的持久化,不是队列中消息的持久化* 3. 标识队列是不是私有的,如果是私有的,只有创建它的应用程序才能消费消息* 4. 队列在没有消费者订阅的情况下是否自动删除* 5. 队列的一些结构化信息,比如声明私信队列,磁盘队列会用到*/channel.queueDeclare(queueName,true,false,false,null);/*** 将交换机和队列绑定* params:* 1.队列名称* 2. 交换机名称* 3. 路由键 - 在直连模式下,可以为我们队列名称*/channel.queueBind(queueName,exchangeName,queueName);/**发送消息* params:* 1. 发送到哪个交换机* 2. 队列名称* 3. 其他参数信息* 4. 发送消息的消息体*/String msg = "hello RabbitMQ!";channel.basicPublish(exchangeName,queueName,null,msg.getBytes());channel.close();connection.close();}
}
  1. 再写一个消费者来消费消息
public class Consumer {public static void main(String[] args) throws Exception{String queueName = "test_queue_name";String exchangeName = "test_exchange_name";//创建链接工厂ConnectionFactory factory = new ConnectionFactory();//服务地址factory.setHost("xx.xx.xx.xx");//账号密码factory.setUsername("root");factory.setPassword("xxx");//端口号factory.setPort(5672);//创建链接Connection connection = factory.newConnection();//创建信道Channel channel = connection.createChannel();//接收消息的回调函数DeliverCallback deliverCallback = (consumerTage, message) -> {System.out.println("接收到消息" + new String(message.getBody()));};//取消消息的回调函数CancelCallback cancelCallback = consumerTage -> {System.out.println("消费消息被中断");};/*** 消费消息* Params:* 1. 消费那个队列* 2. 消费成功后是否自动应答* 3. 接收消息的回调函数* 4. 取消消息的回调函数*/channel.basicConsume(queueName,true,deliverCallback,cancelCallback);}
}

RabbitMQ的交换机类型

  1. direct
    路由键与队列名完全匹配的交换机,通过RoutingKey路由键将交换机和队列进行绑定
public class Producer {public static void main(String[] args) throws Exception {String exchangeName = "test_exchange_name";String queueName1 = "test_queue_name1";String queueName2 = "test_queue_name2";String queueName3 = "test_queue_name3";String queueName4 = "test_queue_name4";String key1 = "key_1";String key3 = "key_3";String key4 = "key_4";ConnectionFactory factory = new ConnectionFactory();factory.setHost("xx.xxx.xxx.xx");factory.setUsername("root");factory.setPassword("xxx");factory.setPort(5672);Connection connection = factory.newConnection();       Channel channel = connection.createChannel();channel.exchangeDeclare(exchangeName, BuiltinExchangeType.DIRECT,true,false,null);channel.queueDeclare(queueName1,true,false,false,null);channel.queueDeclare(queueName2,true,false,false,null);channel.queueDeclare(queueName3,true,false,false,null);channel.queueDeclare(queueName4,true,false,false,null);channel.queueBind(queueName1,exchangeName,key1);channel.queueBind(queueName2,exchangeName,key1);channel.queueBind(queueName3,exchangeName,key3);channel.queueBind(queueName4,exchangeName,key4);channel.basicPublish(exchangeName,key1,null,"hello Key1".getBytes());channel.basicPublish(exchangeName,key3,null,"hello Key3".getBytes());channel.basicPublish(exchangeName,key4,null,"hello Key4".getBytes());channel.close();connection.close();System.out.println("发送消息成功");}
}

如上述代码,执行过后,四个队列每个都会收到消息,其中test_queue_name1,test_queue_name2各收到了一条hello Key1
direct的拼配要求是精准的,设置路由为key1就只能向key1发送才会接收到,发送key或者key.1之类都是不会接收到的
2. fanout

扇出类型交换机,会将消息分发给所有绑定了此交换机的队列,此时RoutingKey参数无效
也就是说,fanout类型交换机下发一条消息,无论RoutingKey是什么,所有队列都会收到消息

  1. topic
    主题类型交换机,此种交换机与Direct类似,也需要routingkey进行匹配分发,区别在于可以模糊查询
    Topic中,将routingkey通过"."来分为多个部分
    “*”:代表一个部分
    “#”:代表0-多个部分,路由键为#,则代表接受所有信息

  2. headers 性能太差 不做学习

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/8723.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

JMeter基础入门教程之CSV数据文件设置CSV Data Set Config

最近在做压力测试&#xff0c;登录功能用到了配置元件&#xff1a;CSV 数据文件设置&#xff0c;可以将登录用户名和密码放在一个csv文件中&#xff0c;然后通过CSV数据文件设置元件读取出来&#xff0c;用来做压测。 一、CSV文件 CSV文件小知识分享&#xff1a;是指"逗号…

POC CPU 单核性能基准测试 Linux bash 下的简单测试用例 bc计算兀

指令 time echo "scale5000;4*a(1)" | bc -l -q 通过耗时简单评估CPU单核性能 测试环境一 yeqiangyeqiang-MS-7B23:/opt/cpu2006$ cat /etc/os-release PRETTY_NAME"Ubuntu 22.04.2 LTS" NAME"Ubuntu" VERSION_ID"22.04" VERSION&…

leetcode 620. 有趣的电影

# Write your MySQL query statement below select * from Cinema where id%21 and description !boring order by rating descid%21是筛选奇数的条件description !‘boring’ 是筛选不无聊的条件order by rating desc 按评分由大到小排序

Ubuntu 下安装软件,卸载,查看已经安装的软件

参考网址&#xff1a;http://wiki.ubuntu.org.cn/UbuntuSkills 一般的安装程序用三种&#xff1a; .deb 和.rpm 这两种安装文件 .bundle 这是二进制的安装文件  而 tar.gz 这类的只是压缩包&#xff08;相当于 .rar,.zip 压缩包一样&#xff09;,如果此类文件是程序的话&a…

BP神经网络数据分类——语音特征信号分类(Matlab代码实现)

目录 &#x1f4a5;1 概述 &#x1f4da;2 运行结果 &#x1f389;3 参考文献 &#x1f468;‍&#x1f4bb;4 Matlab代码 &#x1f4a5;1 概述 BP神经网络是一种常见的人工神经网络&#xff0c;用于数据分类和回归等任务。在语音特征信号分类中&#xff0c;BP神经网络可…

qt画图大卫三角形电力

直接上code void paintEvent(QPaintEvent *event) {Q_UNUSED(event); QPainter painter(this); QRect rect0 = QRect(0,0,500,500);painter.drawRect(rect0);QRect rectB = QRect(-1,-1,501,501);painter.drawRect(rectB);//画三角形QLine line1 = QLine(QPoint(250.0f,80.0f),…

Android11 相机拍照权限,以及解决resolveActivity返回null

一、配置拍照和读写权限 <uses-permission android:name"android.permission.CAMERA"/> <uses-feature android:name"android.hardware.camera" /><uses-permission android:name"android.permission.WRITE_EXTERNAL_STORAGE"/&…

通过RPM方式安装,升级,卸载,以及配置使用MySQL

通过RPM方式安装&#xff0c;升级&#xff0c;卸载&#xff0c;以及配置使用MySQL 一、下载 MySQL是一种开源的关系数据库管理系统&#xff0c;被广泛应用于各种业务应用中。本文将讲解如何下载和安装MySQL的rpm安装包。下载rmp安装包有多种方式&#xff1a; 1、可以到MySQL的…

嵌入式C常用关键字解析

1、static关键字的作用 修饰局部变量 作用域&#xff1a;无变化 生命周期&#xff1a;函数--->程序&#xff08;数据段&#xff09; 特点&#xff1a;只初始化一次 修饰全局变量 作用域&#xff1a;整个工程----->本模块 生命周期&#xff1a;无变化 修饰函数 作…

【C++初阶】 priority_queue(优先级队列)

⭐博客主页&#xff1a;️CS semi主页 ⭐欢迎关注&#xff1a;点赞收藏留言 ⭐系列专栏&#xff1a;C初阶 ⭐代码仓库&#xff1a;C初阶 家人们更新不易&#xff0c;你们的点赞和关注对我而言十分重要&#xff0c;友友们麻烦多多点赞&#xff0b;关注&#xff0c;你们的支持是我…

python简单入门

python简单入门 文章目录 python简单入门0. 地址链接1. 官网2.2. 下载地址3. 官方文档 1. 第一章1.1 python解释器1.2 基础语法1.2.1 常见数据类型1.2.2 强制类型转换1.2.3 注释1.2.4 运算符1.2.5 字符串1.2.5.1 字符串的定义1.2.5.2 字符串拼接1.2.5.3 格式化字符串1.2.5.3 精…

vue指令-插值表达式

vue指令-插值表达式 1、什么是插值表达式2、Vue变量声明在哪里 1、什么是插值表达式 双大括号&#xff0c;可以把vue数据变量直接显示在标签内 2、Vue变量声明在哪里 data函数返回对象上&#xff0c;用key属性声明 示例&#xff1a; <template><div id"app&…

【防火墙】iptables防火墙(二)

1.写在命令行的备份和还原 2.把我们的规则配置在服务的文件当中&#xff0c;形成永久生效 iptables-save > /opt/ky30.bak iptables-restore < /opt/ky30.bak cat /etc/sysconfig/iptables 永久生效的配置文件 自定义链&#xff1a; 1.创建自定义链&#xff1a; i…

正则表达式 —— Sed

Sed Sed 类似于vim就是一个文本编辑器&#xff0c;按行来进行编辑和排序 Sed的原理&#xff1a;读取&#xff0c;执行&#xff0c;显示 读取&#xff1a;读取文本内容之后&#xff0c;读取到的内容存放到临时的缓冲区—模式空间 执行&#xff1a;在模式空间&#xff0c;根据…

第二天 kali代理配置

文章目录 环境一、虚拟机网络模式&#xff08;1&#xff09;NAT&#xff08;2&#xff09;NAT模式&#xff08;3&#xff09;桥接模式&#xff08;4&#xff09;仅主机模式&#xff08;5&#xff09;总结 二、配置代理&#xff08;桥接模式&#xff09;1、基础设置2、虚拟机浏览…

记录安装stable diffusion webui时,出现的gfpgan安装卡住的问题

参考链接&#xff1a;(145条消息) 使用stable diffusion webui时&#xff0c;安装gfpgan失败的解决方案&#xff08;windows下的操作&#xff09;_新时代原始人的博客-CSDN博客

【el-tree查询并高亮】vue使用el-tree组件,搜索展开并选中对应节点,高亮搜索的关键字,过滤后高亮关键字,两种方法

第一种&#xff08;直接展开并高亮关键字&#xff09; 效果图这样的&#xff0c;会把所有的有这些关键字的节点都展开 代码&#xff1a; 这里的逻辑就是通过递归循环把所有和关键字匹配的节点筛选出来 然后通过setCheckedKeys方法把他展开选中 然后通过filterReal把关键字高亮…

用Java写网络聊天系统你会吗???

1.使用Socket进行编写代码&#xff1a;这里还涉及多线程的简单应用。 2.首先创建一个MyWriter类&#xff0c;用于发送客户端和服务器端的聊天信息。 /** Copyright (c) 2020, 2023, All rights reserved.**/import java.io.PrintWriter; import java.net.Socket; import java.…

MATLAB | 产生阿尔法稳定分布噪声并作出概率密度函数

一、问题描述 想产生不同特征参数的α稳定随机变量&#xff0c;并且作出其概率密度函数进行对比。 二、解决思路 运行了MATLAB的官方实例代码&#xff1a; openExample(‘stats/ComparePDFsOfStableDistributionsExample’) &#xff08;1&#xff09;使用makedist()函数生成…

数据可视化(2)

1.柱状图 #柱状图 #bar(x,height,width,*,aligncenter,**kwargs) #height柱子的高度&#xff0c;即y轴上的数据 #width数组的宽度&#xff0c;默认值0.8 #*表示后面的参数为匿名关键字&#xff0c;必须传入参数 #kwargs关键字参数x[1,2,3,4,5] height[random.randint(10,100)f…