有道无术,术尚可求,有术无道,止于术。
文章目录
-
- 核心概念
-
- Producer(生产者)
- Connection(连接)
- Channel(信道)
- Broker(服务端)
- Virtual host(虚拟主机)
- Exchange(交换机)
- Queue(队列)
- Binding(绑定)
- Routing Key(路由键)
- Consumer(消费者)
核心概念
RabbitMQ的工作模型如下图所示:
涉及到RabbitMQ的
核心概念:Producer(生产者)、Connection(连接)、Channel(信道)、Exchange(交换机)、Queue(队列)、Virtual host(虚拟主机)、Consumer(消费者)、Routing Key(路由键)、Binding(绑定)等。
Producer(生产者)
产生数据发送消息的程序是生产者(Producer)
。
Connection(连接)
每个生产者或者消费者要通过RabbitMQ
发送与消费消息,首先就要与RabbitMQ
建立连接,这个连接就是Connection
,这是一个TCP
长连接。
Channel(信道)
如果每一次访问RabbitMQ
都建立一个Connection
,在消息量大的时候建立 TCP 连接
的开销将是巨大的,效率也较低,在系统访问流量高峰时,会严重影响系统性能。
Channel(信道)
是在Connection
内部建立的逻辑连接,如果应用程序支持多线程,通常每个线程创建单独的channel
进行通讯, channel 之间是完全隔离的。Channel
作为轻量级的Connection
极大减少了操作系统建立TCP connection
的开销 。
RabbitMQ
中大部分的操作都是使用Channel
完成的,比如:声明Queue
、声明Exchange
、发布消息、消费消息等。
Broker(服务端)
Broker(服务端)
接收和分发消息的应用,RabbitMQ Server
(服务端) 就是 Message Broker
。
Virtual host(虚拟主机)
Virtual host
是一个虚拟主机的概念,一个Broker
中可以有多个虚拟主机。
出于多租户和安全因素设计的,把 AMQP
的基本组件划分到一个虚拟的分组中,类似于网络中的命名空间概念。
当多个不同的用户使用同一个RabbitMQ server
提供的服务时,可以划分出多个vhost
,每个用户在自己的 vhost
创建 exchange/queue
等,很好地做到了不同用户之间相互隔离的效果。
Exchange(交换机)
交换机
是 RabbitMQ
非常重要的一个部件,一方面它接收来自生产者的消息,另一方面它将消息推送到队列中。交换机必须确切知道如何处理它接收到的消息,是将这些消息推送到特定队列还是推送到多个队列,亦或者是把消息丢弃,这个由交换机类型决定。
交换机有4种类型:direct、fanout、topic、headers
。
Queue(队列)
队列是RabbitMQ
内部使用的一种数据结构,尽管消息流经RabbitMQ
和应用程序,但它们只能存储在队列中。队列仅受主机的内存和磁盘限制的约束,本质上是一个大的消息缓冲区。许多生产者可以将消息发送到一个队列,许多消费者可以尝试从一个队列接收数据。
Binding(绑定)
Binding(绑定)
是指交换机和队列之间的虚拟连接,绑定信息被保存到交换机中的查询表中,用于消息的分发依据。
Routing Key(路由键)
创建好Exchange
和Queue
之后,需要使用Routing key(或者叫做Binding key)
将它们绑定起来,生产者在向交换机发送一条消息的时候,必须指定一个Routing key
,然后交换机接收到这条消息之后,会解析Routing key
,然后根据Exchange
和Queue
的绑定规则,将消息分发到符合规则的Queue
中。
Consumer(消费者)
接受消息并进行消费的程序是Consumer(消费者)
。
版权声明:本文不是「本站」原创文章,版权归原作者所有 | 原文地址: