【RabbitMQ实战】04 RabbitMQ的基本概念:Exchange,Queue,Channel等

news2025/1/12 12:17:28

一、简介

Message Queue的需求由来已久,80年代最早在金融交易中,高盛等公司采用Teknekron公司的产品,当时的Message queuing软件叫做:the information bus(TIB)。 TIB被电信和通讯公司采用,路透社收购了Teknekron公司。之后,IBM开发了MQSeries,微软开发了Microsoft Message Queue(MSMQ)。这些商业MQ供应商的问题是厂商锁定,价格高昂。2001年,Java Message queuing试图解决锁定和交互性的问题,但对应用来说反而更加麻烦了。

于是2004年,摩根大通和iMatrix开始着手Advanced Message Queuing Protocol (AMQP)开放标准的开发。2006年,AMQP规范发布。2007年,Rabbit技术公司基于AMQP标准开发的RabbitMQ 1.0 发布。

二、AMQP 的基本概念

AMQP(RabbitMQ)必须由三部分:交换器、队列和绑定
AMQP基本概念

  • 消息(Message):由有效载荷(playload)和标签(label)组成。其中有效载荷既传输的数据。
  • 生产者(producer):创建消息,发布到代理服务器(Message Broker)。
  • 代理服务器(Message Broker):接收和分发消息的应用,RabbitMQ Server就是消息代理服务器,其中包含概念很多,以RabbitMQ 为例:信道(channel)、队列(queue)、交换器(exchange)、路由键(routing key)、绑定(binding key)、虚拟主机(vhost)等。
  • 信道(channel): 应用程序(生产与/或消费)和代理服务器之间TCP连接内的虚拟连接,解决TCP连接数量限制及降低TCP连接代价。每个信道有一个ID,其概念与“频分多路复用”类似。参考上图:AMQP基本概念
  • 队列(queue):消息最终到达队列中,等待消费者消费。使用“basic.consume”订阅可获得队列全部消息,“basic.get”订阅只能获得队列的一条消息(如果队列中存在消息)。如果无人订阅,消息将在队列中存储,等待订阅;如果多个消费者同时订阅该队列,消息将以自动轮询(round-robin)方式发送给消费者(Fanout Exchange,每个消费者只能获得队列中消息的子集)
  • 交换器(exchange):消息到达代理服务器的第一站,根据分发规则,匹配查询表中的(routing key)路由键(Fanout Exchange除外),分发消息到队列(queue)中去。常用的类型有:direct (point-to-point), topic (publish-subscribe) and fanout (multicast),请参考“2.1交换器”
  • 路由键(routing key):消息发送给交换器时,消息将拥有一个路由键(默认为空),交换器根据这个路由键将消息发送到匹配的队列中。
  • 绑定键(binding key):队列需要通过绑定键(默认为空)绑定到交换器上,交换器将消息的路由键与所绑定队列的绑定键进行匹配,正确匹配的消息将发送到队列中。路由键是偏向生产的概念,而绑定键是偏向消费的概念。
  • 虚拟主机(vhost):AMQP概念的基础,其本质上就是一个mini版的代理服务器(拥有自己的队列、交换器和绑定,更重要的是,拥有自己的权限机制),RabbitMQ默认的vhost:“/”(类似于网络中的namespace),每个用户只能访问自己的vhost(通常会被指派至少一个vhost),进而用户只能访问自己的队列、交换器和绑定,所以vhost之间是绝对隔离的(安全性与可移植性)。
  • 消费者(consumer):连接到代理服务器,并订阅到队列(queue)上,代理服务器将发送消息给一个订阅的/监听的消费者,消费者其只能接收消息的一部分:有效载荷(playload)。

三、交换器、队列、绑定是怎么一回事

生产者发送消息到broker server(RabbitMQ)。在Broker内部,用户创建Exchange/Queue,通过Binding规则将两者联系在一起。Exchange分发消息,根据类型/binding的不同分发策略有区别。消息最后来到Queue中,等待消费者取走。

3.1 交换器类型

  • direct交换器
    如果路由键(routing key)匹配成功,消息就被投递到对应的各个队列,绑定键(binding key)不支持“*”和“#”。消费者在接受消息的信道上可以给生产者反馈。
    在这里插入图片描述
    Message中的“routing key”如果和Binding中的“binding key”一致, Direct exchange则将message发到对应的queue中。

  • fanout
    不存在(routing key)路由键,消息以自动轮询(round-robin)的形式发送到对应的队列(幼儿园给孩子分苹果,如果苹果足够多,将平均分配给每个人),队列不存在绑定键(binding key),消费者在接受消息的当前信道上可以给生产者反馈。
    在这里插入图片描述
    每个发到Fanout类型Exchange的message都会分到所有绑定的queue上去。

  • topic
    存在(routing key)路由键,消息以广播的形式发送到绑定键(bing key)匹配的各个队列,绑定键(binding key)支持“”和“#”
    “#”通配任何零个或多个word
    ”通配任何单个word
    这里也推荐给想要了解RabbitMQ的同学一个网站,http://tryrabbitmq.com ,它提供在线RabbitMQ 模拟器,可以帮助理解Exchange/queue/binding概念。
    在这里插入图片描述
    根据routing key,及通配规则,Topic exchange将分发到目标queue中。

  • headers (已废弃)

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

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

相关文章

某度sign参数逆向

文章目录 前文分析完整代码结尾 前文 本文章中所有内容仅供学习交流,严禁用于商业用途和非法用途,否则由此产生的一切后果均与作者无关,若有侵权,请联系我立即删除! 分析 经过我们几次抓包,测试&#xf…

单片机IAP固件升级分几步?(Qt上位机)

更新 0924,一些潜在的bug解决方案 前言 这周一直想做一个IAP固件升级的上位机,然后把升级流程全都搞懂。 我用的单片机型号是STM32F103VET6,FLASH容量是512K,FLASH单页是2K。 有纰漏请指出,转载请说明。 学习交流…

Rabbit消息的可靠性

Confirm模式简介 消息的confirm确认机制,是指生产者投递消息后,到达了消息服务器Broker里面的exchange交换机,则会给生产者一个应答,生产者接收到应答,用来确定这条消息是否正常的发送到Broker的exchange中&#xff…

黑马JVM总结(二十二)

(1)类的结构-field 成员变量信息 类字节码里的一些简单表示: (2)类文件结构-method-init (3)类文件结构-method-main (4)类文件结构-附加属性

Java基础(六)

前言:本篇博客学习Junit单元测试框架的使用以及常见的注解。 目录 单元测试 Junit单元测试框架 常见注解 单元测试 什么是单元测试? 针对最小的功能单元(方法),编写测试代码对其进行正确性测试。 Junit单元测试框…

十六、MySql的MVCC机制CONNECT(收官!)

文章目录 一、数据库并发的场景有三种:二、读-写(一)3个记录隐藏列字段(二)undo 日志(三)模拟 MVCC(四)一些思考(五)Read View 一、数据库并发的场…

interview6-jvm篇

JVM(Java Virtual Machine)Java程序的运行环境(java二进制字节码的运行环境) 在JVM中共有四大部分,分别是ClassLoader(类加载器)、Runtime DataArea(运行时数据区,内存分区)、Execu…

整合车辆出险报告Api接口,轻松管理车险理赔!

随着车辆保有量的不断增加,车辆出险的情况也越来越普遍。对于车主来说,如何高效地管理车险理赔,处理保险事故是非常重要的。这时候我们就可以借助整合车辆出险报告API接口,实现快速定位理赔信息,轻松管理车险理赔。 一…

【C++面向对象侯捷】8.栈,堆和内存管理

文章目录 栈,堆stack object的生命周期static local object的生命周期global object的生命周期heap objects 的生命期new:先分配memory,再调用构造函数delete: 先调用析构函数,再释放 memory动态分配所得的内存块,in V…

VirtualBox解决VERR_SUPDRV_COMPONENT_NOT_FOUND错误

简述 最近使用VirtualBox时发现其增强功能不能用了,也就是不能双向拖拉文件,整了很久不知所以;看到有网友说跟新其VBoxGuestAdditions.ios文件,所以直接把我的VirtualBox从6.x升级到了7.x,然后就发生了眼前的一幕&…

040_小驰私房菜_MTK平台,添加camera客制化size

全网最具价值的Android Camera开发学习系列资料~ 作者:8年Android Camera开发,从Camera app一直做到Hal和驱动~ 欢迎订阅,相信能扩展你的知识面,提升个人能力~ 【问题背景:】mtk8195平台,录像需要添加一组自定义size 2560 * 1600。 添加一组自定义size,我们需要确认一…

数据湖在爱奇艺数据中台的应用

01 我们眼中的数据湖 作为爱奇艺的数据中台团队,我们的核心任务是管理和服务公司内的大量数据资产。在实施数据治理的过程中,我们不断吸收新的理念,引入尖端的工具,以精细化我们的数据体系管理。“数据湖”作为近年来数据领域广泛…

为您的SSH提提速

SSH是运维和开发人员接触比较多的工具,一般用SSH来连接远程服务器,这个是我的一些免费客户和企业客户经常使用的场景,当然SSH除了远程连接之外,还有很多额外的用途,比如SSH本身是具备代理功能的,我们也有一…

HarmonyOS开发:封装一个便捷的Log工具类

前言 日志打印,没什么好说的,系统已给我们提供,且调用也是非常的简单,我们封装的目的,一是扩展,打印一些不常见的类型,比如格式化json,使得日志看起来比较好看,二是&…

【Java 基础篇】Java Consumer 接口详解

在Java编程中,有时需要对某个对象进行操作或者处理,而这个操作可能是非常灵活的。Java 8引入了函数式编程的特性,其中的一个重要接口就是Consumer接口。本文将详细介绍Consumer接口,包括它的定义、用法以及示例。 什么是 Consume…

【Java 基础篇】Java Supplier 接口详解

在Java中,Supplier接口是一个重要的函数式接口,它属于java.util.function包,用于表示一个供应商,它不接受任何参数,但可以提供一个结果。Supplier通常用于延迟计算或生成值的场景。本文将详细介绍Supplier接口的用法以…

矩阵的c++实现

在大学数学课程《线性代数》中,就有矩阵和行列式的出现,这篇文章主要讲矩阵在c中的实现和一些用途(目前我知道的) 此篇文章只写c的内容,不具体写到数学中矩阵的一些公式、性质。 本篇文章中一部分图片来自百度百科。…

Android 12,调用系统库libft2.so 遇到的各种问题记录

问题前提,Android 12系统,vendor静态库中调用 libft2.so。(vendor静态库中调用libft2.so会简单点,没这么麻烦) 【问题1】 (native:vendor) can not link against libft2 (native:platform) 本地debug尝试修改: 为了本地环境debug调试方便,我找了个 mk文件,在里面添加了…

《富足》—没有完善的个人,但是可以有完善的团队

摘要:在吴军老师《富足》一书上,阅读到一句话:“没有完善的个人,但是可以有完善的团队”。很认同这句,目前听见最多的可能是“没有完美的个人,只有完美的团队”,这句长挂在嘴边的话在社会工作多…

Win7开启触摸键盘方法

在Win7系统中,自带有触摸屏幕键盘,能够在屏幕上显示虚拟键盘,让用户可以用指针设备或触屏等进行输入操作,那么Win7系统怎么开启触摸键盘呢?想知道的小伙伴可以跟着我一起来学习一下。 1、首先打开Win7系统的开始菜单&a…