RabbitMQ概览

2019-08-18  本文已影响0人  快给我饭吃

RabbitMQ是由erlang开发的AMQP(Advanced Message Queue Protocol高级消息队列)的开源实现。本文我想讲讲我理解的RabbitMQ,以及Spring Boot整合RabbitMQ。有错的地方请各位大神指正。

一. RabbitMQ核心概念

RabbitMQ有几个核心的概念,下载安装RabbitMQ后,登录默认的RabbitMQ默认guest账户,可以看到如下几个标签。使用RabbitMQ前需要在这里进行配置,这是RabbitMQ的核心概念。

RabbitMQ
RabbitMQ架构图:
RabbitMQ架构图
结合上面两张图,RabbitMQ涉及到流程和大体概念如下:
1. RabbitMQ消息流程:消息发布者Publisher发布一条消息Message到消息队列服务器实体Broker,Broker上有多个虚拟主机Virtual Host,各主机之间相互独立。虚拟机主机中有交换机Exchange,消息队列Queue等一组相关对象。Exchange用来接收Publisher发送的消息并将这些消息路由给队列,RabbitMQ有4中Exchange路由器类型,可以实现点对点或发布订阅模型。Exchange通过绑定Binding关系,将消息Message发到指定的队列Queue,消息一直在队列中,等待消费者从队列中取走。消费者Consumer、发布者Publisher到Broker建立的每一个连接Connection,都是通过Channel来传输,避免Connection频繁创建销毁。
2. 核心概念
Publisher:消息的生产者,也是一个想交换机发布信息的客户端应用程序。
Message:消息,消息是不具名的,它由消息和消息体组成。消息体是不透明的,而消息头则由一系列的可选属性组成,这些属性包括routing-key(路由键)、priority(相对其他消息的优先权)、delivery-mode(指出该消息可能需要持久化存储)等。
Broker:表示消息队列服务器实体。
Virtual Host:虚拟主机,表示一批交换机、消息队列和相关对象。虚拟主机是共享相同的身份认证和加密环境的独立服务器域。每个vhost本质上是一个mini版的RabbitMQ服务器,拥有自己的队列、交换机、绑定和权限机制。vhost是AMQP概念的基础,必须在连接时指定,RabbitMQ默认的vhost是 / .
Exchange:交换机,用来接收生产者发布的消息并将这些消息路由给服务器中的队列。Exchange有四种类型,不同类型的Exchange转发消息的策略有所区别,四种类型如下:

Binding:绑定,用于交换机和消息队列之间的关联。一个绑定就是基于路由键将交换机和消息队列连接起来的路由规则,所以可以将交换机理解为一个由绑定构成的路由表。Exchange和Queue的绑定可以是多对多的关系。
Queue:消息队列,用来保存消息直到发送给消费者。它是消息的容器,也是消息的终点。一个消息可投入一个或多个队列。消息一直在队列里面,等待消费者连接到这个队列将消息取走。
Connection:网络连接,比如一个TCP连接。
Channel:信道,多路复用连接中的一条独立的双向数据通道。信道是建立在真实的TCP连接内的虚拟连接,AMQP命令都是通过信道发出去的,不管是发布消息、订阅队列还是接收消息,这些动作都是通过信道完成。因为对于操作系统来说建立和销毁TCP都是非常昂贵的开销,所以引入了信道的概念,以复用一条TCP连接。
Consumer:消息的消费者,表示一个从消息队列中取得消息的客户端应用程序。

二. RabbitMQ运行机制

Exchange常用的三种类型介绍如下图。发布者发布消息到broker,exchange根据binding规则将消息发送到指定的队列。exchange根据binding中的路由键的处理规则分为点对点、广播、发布订阅三种常用类型。


Direct
Fanout
Topic
上一篇下一篇

猜你喜欢

热点阅读