消息中间件 - RabbitMQ (3)

消息中间件 - RabbitMQ

在上图的模型中,有以下概念:

P:生产者,也就是要发送消息的程序

C:消费者:消息的接受者,会一直等待消息到来。

queue:消息队列,图中红色部分。类似一个邮箱,可以缓存消息;生产者向其中投递消息,消费者从其中取出消息。

4. AMQP 4.1. 相关概念介绍

AMQP 一个提供统一消息服务的应用层标准高级消息队列协议,是应用层协议的一个开放标准,为面向消息的中间件设计。

AMQP是一个二进制协议,拥有一些现代化特点:多信道、协商式,异步,安全,扩平台,中立,高效。

RabbitMQ是AMQP协议的Erlang的实现。

概念 说明
连接Connection   一个网络连接,比如TCP/IP套接字连接。  
会话Session   端点之间的命名对话。在一个会话上下文中,保证“恰好传递一次”。  
信道Channel   多路复用连接中的一条独立的双向数据流通道。为会话提供物理传输介质。  
客户端Client   AMQP连接或者会话的发起者。AMQP是非对称的,客户端生产和消费消息,服务器存储和路由这些消息。  
服务节点Broker   消息中间件的服务节点;一般情况下可以将一个RabbitMQ Broker看作一台RabbitMQ 服务器。  
端点   AMQP对话的任意一方。一个AMQP连接包括两个端点(一个是客户端,一个是服务器)。  
消费者Consumer   一个从消息队列里请求消息的客户端程序。  
生产者Producer   一个向交换机发布消息的客户端应用程序。  
4.2. RabbitMQ运转流程

在入门案例中:

生产者发送消息

生产者创建连接(Connection),开启一个信道(Channel),连接到RabbitMQ Broker;

声明队列并设置属性;如是否排它,是否持久化,是否自动删除;

将路由键(空字符串)与队列绑定起来;

发送消息至RabbitMQ Broker;

关闭信道;

关闭连接;

消费者接收消息

消费者创建连接(Connection),开启一个信道(Channel),连接到RabbitMQ Broker

向Broker 请求消费相应队列中的消息,设置相应的回调函数;

等待Broker回应闭关投递响应队列中的消息,消费者接收消息;

确认(ack,自动确认)接收到的消息;

RabbitMQ从队列中删除相应已经被确认的消息;

关闭信道;

关闭连接;

消息中间件 - RabbitMQ

4.3. 生产者流转过程说明

客户端与代理服务器Broker建立连接。会调用newConnection() 方法,这个方法会进一步封装Protocol Header 0-9-1 的报文头发送给Broker ,以此通知Broker 本次交互采用的是AMQPO-9-1 协议,紧接着Broker 返回Connection.Start 来建立连接,在连接的过程中涉及Connection.Start/.Start-OK 、Connection.Tune/.Tune-Ok ,Connection.Open/ .Open-Ok 这6 个命令的交互。

客户端调用connection.createChannel方法。此方法开启信道,其包装的channel.open命令发送给Broker,等待channel.basicPublish方法,对应的AMQP命令为Basic.Publish,这个命令包含了content Header 和content Body()。content Header 包含了消息体的属性,例如:投递模式,优先级等,content Body 包含了消息体本身。

客户端发送完消息需要关闭资源时,涉及到Channel.Close和Channl.Close-Ok 与Connetion.Close和Connection.Close-Ok的命令交互。

消息中间件 - RabbitMQ

4.4. 消费者流转过程说明

消费者客户端与代理服务器Broker建立连接。会调用newConnection() 方法,这个方法会进一步封装Protocol Header 0-9-1 的报文头发送给Broker ,以此通知Broker 本次交互采用的是AMQPO-9-1 协议,紧接着Broker 返回Connection.Start 来建立连接,在连接的过程中涉及Connection.Start/.Start-OK 、Connection.Tune/.Tune-Ok ,Connection.Open/ .Open-Ok 这6 个命令的交互。

消费者客户端调用connection.createChannel方法。和生产者客户端一样,协议涉及Channel . Open/Open-Ok命令。

内容版权声明:除非注明,否则皆为本站原创文章。

转载注明出处:https://www.heiqu.com/zzdpfy.html