java学习-消息队列rabbitmq的组成

rabbitmq有以下组成部分,分别为:
1. Server(broker)
接受客户端连接,实现AMQP消息队列和路由功能的进程

2.虚拟主机virtual host
虚拟主机类似于权限控制组,控制用户访问虚拟主机的权限。
权限控制最小的粒度是virtual host

3. 交换机exchange
交换机相当于一个具有独立进程的应用程序
接受生产者发送的消息,并根据Binding规则将消息路由给服务器中队列。
它具有一个路由表,即以key路由键-value路由,形式存储的表

4. 消息队列queue
队列,也就是存放消息的容器,遵循先进先出的规则

5. 消息Message
由Header和Body组成,Header是生产者添加的各种属性的集合,包括消息被那个Message Queue接受,优先级等属性,
body是需要传输的数据

6. 绑定binding,也叫路由规则
联系Exchange和Message Queue

7. connection连接
客户端与RabbitMQ server(broker)之间的TCP连接

8. Channel信道
客户端与broker在TCP连接后,需要为Connection创建Channel,AMQP协议规定只有Channel才能执行AMQP的命令。
一个Connection对多个Channel。建议客户端线程之间不要共用Channel,
至少要保证共用的Channel的线程发送消息必须是串行的,建议尽量共用Connection

9. AMQP命令
客户端通过Command命令完成与AMQP服务器的交互来实现自身的逻辑。
如通过publish命令发送消息,txSelect开启一个事务,txCommit提交一个事务。

note:
Exchange和多个Message Queue发生binding后形成一张路由表
当Exchange接收到Message时会解析其Header得到Routing Key,
Exchange根据Routing Key与Exchange Type将Message路由到Message Queue

Binding key由消费者在绑定Exchange和Message Queue时指定
Routing Key由Producer发送Message时指定,两者匹配方式由Exchange Type决定


AMQP协议栈:
1. Module Layer
定义了一些供客户端调用的命令,客户端可以利用这些命令实现自己的业务逻辑,
例如,客户端可以通过queue.declare声明一个队列,利用consume命令获取一个队列中的消息。

2. Session Layer
主要负责将客户端的命令发送给服务器,在将服务器端的应答返回给客户端
主要为客户端与服务器之间通信提供可靠性、同步机制和错误处理。

3.Transport Layer
主要传输二进制数据流,提供帧的处理、信道复用、错误检测和数据表示。

 

上一篇:java – Spring-AMQP重新队列消息计数基于JVM吗?


下一篇:PHP使用RabbitMQ实例