0 RabbitMQ概念
目录
- 1、RabbitMQ基本概念
- 2、为什么使用消息队列
- 3、RabbitMQ特点
- 4、基本概念解释
- 4.1 宏观
- 4.2 概念
- 4.3 消息路由
- Exchange类型
- 5、工作过程
- 6、持久化
版本 | 内容 | 时间 |
---|---|---|
1.0 | 初步版本 | 20180923 |
2.0 | 复习添加 | 20181007 |
1、RabbitMQ基本概念
- 消息是指在应用程序间传送的数据;
- 消息可以非常的简单,比如文本字符串,也可以更加的复杂,包含嵌入对象;
- 消息队列(Message Queue)是一种应用间的通信方式,消息发送后可以立即返回,由消息系统来确保消息的可靠传递。消息发布者只管把消息发布到 MQ 中而不用管谁来取,消息使用者只管从 MQ 中取消息而不管是谁发布的。这样发布者和使用者都不用知道对方的存在
2、为什么使用消息队列
- 从上面的描述中可以看出消息队列是一种应用间的异步协作机制
订单系统
用户点击【下单】按钮之后的业务逻辑可能包括:==扣减库存==、==生成相应单据==、==发红包==、==发短信通知==
在业务发展初期这些逻辑可能放在一起同步执行,随着业务的发展订单量增长,需要提升系统服务的性能,这时可以将一些不需要立即生效的操作拆分出来异步执行,比如发放红包、发短信通知等。
这种场景下就可以用 MQ ,在下单的主流程(比如扣减库存、生成相应单据)完成之后发送一条消息到 MQ 让主流程快速完结,而由另外的单独线程拉取MQ的消息(或者由 MQ 推送消息),当发现 MQ 中有发红包或发短信之类的消息时,执行相应的业务逻辑
3、RabbitMQ特点
RabbitMQ
是一个由 Erlang
语言开发的 AMQP
的开源实现。
AMQP: Advanced Message Queue
,高级消息队列协议。它是应用层协议的一个开放标准,为面向消息的中间件设计,基于此协议的客户端与消息中间件可传递消息,并不受产品、开发语言等条件的限制。
- 可靠性(
Reliability
)
RabbitMQ 使用一些机制来保证可靠性,如持久化、传输确认、发布确认
- 灵活的路由(
Flexible Routing
)
在消息进入队列之前,通过 Exchange
来路由消息的。对于典型的路由功能,RabbitMQ
已经提供了一些内置的 Exchange
来实现。针对更复杂的路由功能,可以将多个 Exchange
绑定在一起,也通过插件机制实现自己的 Exchange
- 消息集群(
Clustering
)
多个 RabbitMQ
服务器可以组成一个集群,形成一个逻辑 Broker
- 高可用(
Highly Available Queues
)
队列可以在集群中的机器上进行镜像,使得在部分节点出问题的情况下队列仍然可用
- 多种协议(
Multi-protocol
)
RabbitMQ
支持多种消息队列协议,比如 STOMP
、MQTT
- 多语言客户端(
Many Clients
)
RabbitMQ
几乎支持所有常用语言,比如 Java
、.NET
、Ruby
等等
- 管理界面(
Management UI
)
RabbitMQ
提供了一个易用的用户界面,使得用户可以监控和管理消息 Broker
的许多方面
- 跟踪机制(
Tracing
)
如果消息异常,RabbitMQ
提供了消息跟踪机制,使用者可以找出发生了什么
- 插件机制(
Plugin System
)
RabbitMQ
提供了许多插件,来从多方面进行扩展,也可以编写自己的插件
4、基本概念解释
4.1 宏观
MQ的原理
消费者(consumer
)订阅某个队列。生产者(producer
)创建消息,然后发布到队列(queue
)中,最后将消息发送到监听的消费者
4.2 概念
上面介绍过 RabbitMQ
是 AMQP
协议的一个开源实现,所以其内部实际上也是 AMQP 中的基本概念
- Message
消息是不具名的,它有==消息头==和==消息体==组成。
消息体是不透明的,但是消息头是有一系列的可选属性组成
这些属性包括routing-key(路由键),priority(相对于其它消息的优先权),delivery-mode(指出来该消息可能需要持久性存储)等
- Publisher
消息的生产者,也是一个向交换器发布消息的客户端应用程序
- Exchange
交换器,用来接收生产者发送的消息并且将这些消息路由给服务器中的队列
- Binding
绑定,用于消息队列和交换器之间的关联,一个绑定就是基于路由键将交换器和消息队列连接起来的路由规则,所以可以将交换器理解成一个由绑定构成的路由表
- Queue
消息队列,用来保存消息直到发送给消费者,他是消息的容器,也是消息的终点。一个消息可投入一个或者多个队列。消息一直在队列里面,等待消费者连接到这个队列将其取走
- Connection
网络连接比如tcp连接
- Channel
信道,多路复用连接中的一条独立的双向数据流通道。信道是建立在真实的TCP连接内地虚拟连接,AMQP命令都是通过信道发出去的,不管是发布消息,订阅队列,还是接受消息,这些动作都是在信道完成的。
因为对于操作系统来说建立和销毁TCP都是非常安昂贵的开销,所以引入信道的概念,以此来复用一条TCP连接
- Consumer
消息的消费者,表示一个从消息队列中取得消息的客户端应用程序
- Virtual Host
虚拟主机,表示一批交换机,消息队列和相关的对象。虚拟主机是共享相同的身份认证和加密环境的独立服务器域。
每个vhost本质上就是一个mini版的RabbitMQ服务器,拥有自己的队列、交换器、绑定和权限机制。
vhost是AMQP概念的基础,必须在连接的时候指定,RabbitMQ默认的vhost是/
- Broker
表示消息队列服务器实体
4.3 消息路由
AMQP
中消息的路由过程和 Java 开发者熟悉的 JMS 存在一些差别,AMQP
中增加了 Exchange
和 Binding
的角色。生产者把消息发布到 Exchange 上,消息最终到达队列并被消费者接收,而 Binding
决定交换器的消息应该发送到那个队列
Exchange类型
Exchange分发消息时根据类型的不同分发策略有区别,目前共四种类型:
direct
、fanout
、topic
、headers
。headers
匹配 AMQP
消息的 header
而不是路由键,此外 headers
交换器和 direct
交换器完全一致,但性能差很多,目前几乎用不到了,所以直接看另外三种类型
direct
消息中的路由键(routing key
)如果和 Binding
中的 binding key
一致, 交换器就将消息发到对应的队列中。路由键与队列名完全匹配,如果一个队列绑定到交换机要求路由键为“dog”,则只转发 routing key
标记为“dog”的消息,不会转发“dog.puppy”,也不会转发“dog.guard”等等。它是完全匹配、单播的模式。
fanout
每个发到 fanout
类型交换器的消息都会分到所有绑定的队列上去。fanout
交换器不处理路由键,只是简单的将队列绑定到交换器上,每个发送到交换器的消息都会被转发到与该交换器绑定的所有队列上。很像子网广播,每台子网内的主机都获得了一份复制的消息。fanout
类型转发消息是最快的
topic
topic
交换器通过模式匹配分配消息的路由键属性,将路由键和某个模式进行匹配,此时队列需要绑定到一个模式上。
它将路由键和绑定键的字符串切分成单词,这些单词之间用点隔开。它同样也会识别两个通配符:符号“#”和符号“”。#匹配0个或多个单词,匹配不多不少一个单词
5、工作过程
- 生产者客户端
客户端连接到RabbitMQ服务器上,打开一个消息通道(channel);
客户端声明一个消息交换机(exchange),并设置相关属性。
客户端声明一个消息队列(queue),并设置相关属性。
客户端使用routing key在消息交换机(exchange)和消息队列(queue)中建立好绑定关系。
客户端投递消息都消息交换机(exchange)上
客户端关闭消息通道(channel)以及和服务器的连接。
- 服务器端
exchange接收到消息后,根据消息的key(这个key的产生规则暂时没研究,有知道的小伙伴可以留言告诉我)和以及设置的binding,进行消息路由,将消息投递到一个或多个消息队列中。
关于exchange也有几个类型:
(1). Direct交换机:完全根据key进行投递。例如,绑定时设置了routing key为abc,客户端提交信息提交信息时只有设置了key为abc的才会投递到队列;
(2).Topic交换机:在key进行模式匹配后进行投递。例如:符号”#”匹配一个或多个字符,符号””匹配一串连续的字母字符,例如”abc.#”可以匹配”abc.def.ghi”,而”abc.”只可以匹配”abc.def”。
(3).Fanout交换机:它采取广播模式,消息进来时,将会被投递到与改交换机绑定的所有队列中。
6、持久化
RabbitMQ支持数据持久化,也就是把数据写在磁盘上,可以增加数据的安全性。消息队列持久化包括三个部分:
消息交换机(exchange)持久化,在声明时指定durable为1
消息队列(queue)持久化,在声明时指定durable为1
消息持久化,在投递时指定delivery_mode为2(1是非持久化)
如果消息交换机(exchange)和消息队列(queue)都是持久化的话,那么他们之间的绑定(Binding)也是持久化的。如果消息交换机和消息队列之间一个持久化、一个非持久化,那么就不允许绑定。
转载于:https://www.cnblogs.com/zhaod/p/11379089.html
0 RabbitMQ概念相关推荐
- 当WEB2.0从概念变成电子商务网站的工具
当一些WEB2.0模式的网站还将WEB2.0作为概念吸引疯投注意的时候,电子商务巨头亚马逊已经成功地将博客(BLOG)和标签(tag)等具有典型WEB2.0特征的技术和思想应用网站的经营,使得WEB2 ...
- STM32驱动开发(二)--USB Device RNDIS虚拟网卡(USB2.0 基础概念讲解)
STM32驱动开发(二)–USB Device RNDIS虚拟网卡(USB2.0基础概念讲解) 一.简介 本文基于stm32 Rndis实例,github开源, 使用STM32F407单板.结合协 ...
- 工业4.0的概念及关键要素价值分析
工业4.0的概念及内涵 工业4.0是什么?工业4.0的概念是德国于2013年提出,随后被上升至德国国家创新战略之一,是德国20个面向2020年的科技战略之一.在2013年汉诺威展会上,德国教研部.科技 ...
- PCIE 2.0协议概念基本科普
PCIE的概念:是电脑总线PCI的一种,它沿用现有的PCI编程概念及通信标准,但建基于更快的串行通信系统. 英特尔是该接口的主要支持者.PCIe仅应用于内部互连.由于PCIe是基于现有的PCI系统,只 ...
- 继承和多态 1.0 -- 继承概念(is-a、has-a,赋值兼容规则,隐藏重定义)
普通继承和访问权限 当一个继承没有虚拟继承或者是多重继承时,就是一个简单的继承的时候,这个时候就是一个普通的继承. 普通继承的内存空间是:子类的对象中,包含了父类的成员变量,同时也可以调用父类的成员函 ...
- [RabbitMQ]RabbitMQ概念_四大核心概念
RabbitMQ RabbitMQ 的概念 RabbitMQ 是一个消息中间件:它接受并转发消息.你可以把它当做一个快递站点,当你要发送一个包裹时,你把你的包裹放到快递站,快递员最终会把你的快递送到收 ...
- Dubbo3.0系列(2)- Dubbo3.0核心概念与架构
前言 本文整理内容来自官网:https://dubbo.apache.org/zh/docs/concepts/ 服务发现 服务发现,即消费端自动发现服务地址列表的能力,是微服务框架需要具备的关键能力 ...
- 嵌入式开发板硬件操作入门学习0——电路图概念 硬件接口的四大类
电路图概念 术语: sch:schematic,原理图 PCB:Printed Circuit Board,印刷电路板 footprint:脚印.足迹,表示元件在电路板上的外形 component:元 ...
- 笔记与心得:《人人都是产品经理 V2.0》--概念:提出与筛选
<人人都是产品经理V2.0>第三章主要讲述的是 产品概念所包含的内涵及筛选的准则.不管自己的岗位是不是产品经理,或只是日常做一些小的创新和改进这样的产品思维都是非常重要的. 以下是我以思维 ...
最新文章
- 开了一论坛,专门讨论控件技术
- java.lang.ClassNotFoundException: org.codehaus.jackson.JsonProcessingException 异常解决方案
- HDU 1258 Sum It Up
- python中json文件处理涉及的四个函数json.dumps()和json.loads()、json.dump()和json.load()的区分
- iOS CoreAnimation
- 常用的 Java 工具类之 Apache 全家桶使用
- Torch 学习总结
- java urlrewrite_Java|urlrewrite|URL重写|多个参数
- Kotlin学习资料
- Excel数据导入___你hold住么(一)
- sql server中binary怎么得到char类型
- DDoS攻击防范技术
- 如何成为一名优秀的技术Leader?
- MySQL----多表查询
- php odbc informix,odbc php informix 问题求助
- VC2008 NewControl 示例
- rk3288 7.1 lvds屏幕亮度偏暗
- 用好Eclipse Task功能
- hive乱码彻底解决方案全记录
- 上海市2019年公务员录用考试笔试合格人员笔试成绩(B类)