消息中间件——RabbitMQ(三)理解RabbitMQ核心概念和AMQP协议!

前言

本章学习,我们可以了解到以下知识点:

  • 互联网大厂为什么选择RabbitMQ?
  • RabbiMQ的高性能之道是如何做到的?
  • 什么是AMQP高级协议?
  • AMQP核心概念是什么?
  • RabbitMQ整体架构模型是什么样子的?
  • RabbitMQ消息是如何流转的?

1. 初识RabbitMQ

RabbitMQ 是一个开源的消息代理和队列服务器,用来通过普通协议在完全不同的应用之间共享数据(RabbitMQ能够实现跨语言跨平台的机制,),RabbitMQ是使用Erlang语言来编写的,并且RabbitMQ是基于AMQP协议的。

仅仅通过上面一句话,相信大家一定有很多疑惑和问题。

  • RabbitM成熟度到底怎么样?
  • 业界使用度怎么样?哪些大厂在使用?为什么?
  • 包括RabbitMQ到底都有哪些特点?
  • RabbitMQ为什么要用Erlang语言去编写?
  • 什么是AMQP协议?AMQP协议里面的具体的规范又是什么?

我相信大家跟我一样都会有这样的疑惑。那么我们一起来学习一RabbitMQ吧。

我们来了解第一个问题。

2. 互联网大厂为什么选择RabbitMQ?

业界使用度怎么样?哪些大厂在使用?为什么?都有哪些优点?
据我了解:滴滴、美团、去哪儿、头条…

这些互联网大厂都会采用RabbitMQ作为它底层的消息通信的一个基础组件。根本原因:

  1. 开源、性能优秀、稳定性保障
  2. 提供可靠性消息投递模式(confirm)、返回模式(return)
  3. 与SpringAMQP完美的整合、扩展性变得更强、API丰富
  4. 集群模式丰富、表达式配置、HA(高可用)模式、镜像队列模型
  5. 保证数据不丢失的前提下做到高可靠性、可用性

3. RabbiMQ的高性能之道是如何做到的?

原因就在于它使用了Erlang语言,Erlang语言最初在于交换机领域的架构模式,这样使得RabbitQ在Broker之间进行数据交互的性能是非常优秀的。

还有一点也是取决于作者,RabbitMQ开发的作者在开发RabbitMQ之间,先用Erlang语言做了一个简单的交换机,然后他惊奇的发现:Erlang的优点:Erlang有着和原生Socket一样好的延迟效果。
相信大家接触过Socket的朋友,对它的有怎样的性能有一定的了解。像我们耳熟能详的RPC通信框架。比如说:dubbo,它底层就是采用了Netty,Netty无非就是网络编程中的高性能之王,它无非就是一个Socket
基于这个特点呢,我们就有了一个充分的选择RabbitMQ的理由。其实我们选择RabbitMQ的时候,有一个主要的考量目标就是:当消息入到RabbtMQ节点上的时候,RabbitMQ的延迟以及响应。

4. 什么是AMQP高级消息队列协议?

  • AMQP全称:Advanced Message Queuing Protocol(高级消息队列协议)

AMQP定义:是具有现代特征的二进制协议。是一个提供统一消息服务的应用层标准高级消息队列协议,是应用层协议的一个开放标准,为面向消息的中间件设计。

它就类似于Java中的JMS。是比较上层的规范,基于这个规范可以开发出各种各项的消息中间件。

模型分析

Pubilsher application:生产者应用 生产的消息,扔到Server端。

Server:指的就是RabbitMQ的节点

Virtual host:虚拟主机,比较上层的一个路由,类似于路由器这么一个概念。后续介绍

Exchange:交换机,生产者直接将消息投递到Exchange中。但是要经历3个过程 -》server->Virtual host->Exchange

先确定将消息发送到哪台服务器,那么就需要先去建立连接,设置一些地址等等。
第二层,投递到哪个Virtual host 需要定义。
第三层,投递到哪个Exchange也需要定义。

再看Consumer application 消费者的应用端,消费端只需要监听Message Queue,当队列中有消息的时候,就拿出来消费。因此在Exchange和Message Queue之间有绑定的关系存在,后续详细介绍。

5. AMQP核心概念是什么?

AMQP核心概念:

  • server: 又称Broker,接收客户端的链接,实现AMQP实体服务
  • Connection: 链接,应用程序与Broker的网络连接
  • Channel:网络信道,几乎所有的操作(数据的读、写)都在Channel中进行,Channel是进行消息读写的通道。客户端可建立多个Channel,每个Channel代表一个会话任务。
  • Message:消息,服务器和应用程序之间传送的数据,由Properties和Body组成。Properties可以对消息进行修饰,比如消息的优先级、延迟等高级特性;Body则就是消息体内容。
  • Virtual host:虚拟地址,用于进行逻辑隔离,最上层的消息路由。一个Virtual host 里面可以有若干个Exchange和Queue,同一个Virtual Host里面不能有相同名称的Exchange和Queue。一种逻辑概念,类似Redis的逻辑数据库。用来划分具体的服务。
  • Exchange:交换机,接收消息,根据路由键转发消息到绑定的队列
  • Binding:Exchange 和Queue之间的虚拟连接,Binding中可以包含routing key
  • Routing key:一个路由股则,虚拟机可用它来确定如何路由一个特定消息。
  • Queue:也称为message Queue,消息队列,保存消息并将它们转发给消费者。

以上核心概念先有一个大概的认知,以后会详细介绍。

6. RabbitMQ整体架构模型是什么样子的?


生产者把消息投递到Exchange,Exchange投递到Queue.
因此我们的生产者只需要关注把消息投递到指定的Exchange即可,我们的消费者只需要监听指定Queue即可。就是这么简单的机制。
通过图我们也能看到,生产者不需要关注投递到哪个队列,消费也不需要关注是从哪个Exchange上来的,这两块没有耦合的情况。主要是应为Exchange和Queue有一个绑定的关系。

7. RabbitMQ消息是如何流转的?

生产者publisher application 生产消息Message投递到Exchange上,Exchange绑定MessageQueue,可以绑定过多个MessageQueue,为什么三个队列只有其中一个队列收到了消息呢?主要是由于Exchange是有一个路由功能的。这个路由就是routing key,这个路由有两个非常关键的点,
第一个:你的消息是需要发送到哪个Exchange。
第二个:你发消息的时候需要带上routing key,然后通过Exchange 和 MessageQueue 建立一个绑定关系,通过路由key把消息路由到一个指定的队列上。然后我们的消费端直接监听队列就行了,就可以消费了。

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

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

相关文章

FSCTF2023-Reverse方向题解WP。学习贴

文章目录 [FSCTF 2023]signin[FSCTF 2023]MINE SWEEPER[FSCTF 2023]Xor[FSCTF 2023]EZRC4[FSCTF 2023]ez_pycxor[FSCTF 2023]Tea_apk[FSCTF 2023]ezcode[FSCTF 2023]ezbroke[FSCTF 2023]rrrrust!!![FSCTF2023]ezrev(未解决) [FSCTF 2023]signin UPX壳&am…

探索无限自然之美——Terragen Professional 4渲染软件

Terragen Professional 4是一款强大的自然环境渲染软件,为设计师、艺术家和电影制作人们带来了无限的创作可能性。无论是为游戏、电影、动画还是虚拟现实体验创建逼真的自然场景,Terragen Professional 4都能为您提供令人难以置信的结果。 Terragen Pro…

SAP_ABAP_面试篇_关于Function Module函数的三种处理类型

关于 Function Module 这个技术点,在面试过程中一般会考察以下几个问题: 1 函数处理类型的更新模式 一般会问到异步和事务(逻辑单元 LUW),异步函数的调试方式、SM13监控更新函数的执行过程(V1 与 V2 模式…

tokenizers Tokenizer 类

Tokenizer 类 依赖安装 pip install tensorflow pip install tensorflow -i https://pypi.tuna.tsinghua.edu.cn/simple基类原型 tokenizers.Tokenizer(model)基类说明 Tokenizer 函数构造一个分词器对象。分词方式主要有word-level、subword-level、char-level三种&#x…

备案信息一键查询:网站备案信息查询API的操作与优势

前言 在当今数字化的时代,企业的在线存在至关重要。而为了确保在网络空间的法规合规性,了解和管理网站备案信息变得尤为重要。为了使这一过程更为高效、便捷,网站备案信息查询API应运而生,为企业提供了一种简便的方式来获取和管理…

C++_String增删查改模拟实现

C_String增删查改模拟实现 前言一、string默认构造、析构函数、拷贝构造、赋值重载1.1 默认构造1.2 析构函数1.3 拷贝构造1.4 赋值重载 二、迭代器和范围for三、元素相关:operator[ ]四、容量相关:size、resize、capacity、reserve4.1 size、capacity4.2…

斯坦福NLP课程来了

生成式AI,尤其是以ChatGPT为首的大语言模型正在改变人们的生活方式,我想一定有小伙伴想加入NLP这个行列。 微软重磅发布4个适合初学者的机器学习资料 我在前一篇文章中分享了微软人工智能初学者课程,其中的【生成式AI】非常适合初学者&…

五大匹配算法

五大匹配算法 五大匹配算法 BF 匹配、RK 匹配、KMP 匹配、BM 匹配、Sunday 匹配。 1、BF 匹配 // BF 匹配(暴力匹配) public static int bfMatch(String text, String pattern) {char[] t text.toCharArray();char[] p pattern.toCharArray();int i …

CCF CSP认证 历年题目自练Day48

题目 试题编号: 201803-3 试题名称: URL映射 时间限制: 1.0s 内存限制: 256.0MB 问题描述: 问题描述   URL 映射是诸如 Django、Ruby on Rails 等网页框架 (web frameworks) 的一个重要组件。对于从浏览器发来的 H…

渗透测试高级技巧(二):对抗前端动态密钥与非对称加密防护

在前文的技术分享中,我们描述了验签和静态对称加密(静态密钥 AES)的常见场景,大家我相信遇到类似的加解密清醒,基本都可以通过热加载的基本使用获得破解前端加密解密的方法,达到一个比较好的测试状态。 在…

定时器的使用

目录 前言 正文 1.方法 schedule(TimerTask task, Date time) 的测试 (1)执行任务的时间晚于当前时间(在未来执行)的效果 (2)线程TimerThread不销毁的原因 (3)使用 public void cancel() 方法实现 T…

阿里云高效计划学生和老师免费代金券申请认证方法

阿里云高校计划学生和教师均可参与,完成学生认证和教师验证后学生可以免费领取300元无门槛代金券和3折优惠折扣,适用于云服务器等全量公共云产品,订单原价金额封顶5000元/年,阿里云百科aliyunbaike.com分享阿里云高校计划入口及学…