消息协议

AMQP(高级消息队列协议)的重要组件

• Message:消息服务器处理的基本单元
• Publisher(生产者):向交换机发布消息的程序
• Exchange(交换器):接受生产者消息并传递给消息路由的队列
• Binding:将消息队列与交换器绑定关联
• VirtualHost:它是消息队列以及相关对象的集合
• Broker(消息代理):表示消息队列服务器实体,接受客户端连接,实现 AMQP 消息 队列和路由功能的过程
• Routing Key:确定VirtualHost与message的路由关系
• Queue:用来保存消息
• Connection:客户端与队列服务器之间建立的TCP连接
• Channel:AMQP的命令都是通过信道发布的;多路复用TCP连接中的双向数据流通道,Channel是建立在真实的TCP连接中的虚拟连接
• Consumer:从消息队列获取消息的程序
• AMQP基础模型:
  

AMQP协议分层

• 0-9分为功能层,传输层;

• • 功能层定义了许多命令
  • 传输层将功能层传递的消息进行处理,包括括信道用、同步、内容编码、 跳检测、数据表和错误处理

• 0-10分为模型层,会话层,传输层;

• • 模型层提供了命令
  • 会话层将命令从客户端传递给服务器,这个过程提供了可靠、同步机制、错误处理
  • 传输层负责提供帧处 信道复用 、错误检测和数据表示

MQTT(消息队列遥测传输)

• MQTT的特点是轻量、简单、开放和易于实现。正因为这些特点，使它常应用于很多机器计算 能力有限、低带宽、网络不可靠的远程通信应用场景中
• MQTT基础模型:
  

MQTT协议的基础组件

• 网络连接:提供有序,可靠,基于字节流的双向传输
• 应用消息:指传输的应用数据,包含两个部分,指主题、负载
• 主题:应用消息的类型
• 负载:指订阅者具体接受的消息
• 客户端:指使用MQTT协议的设备或者程序
• 服务端:它作为发送消息的客户端束与请求订阅的客户端之间的中介
• 会话:客户端与服务端建立连接之后就是会话
• 订阅:订阅与会话关联,包含一个主题过滤器与服务质量等级
• 主题名:指消息上面的标签,会匹配服务器的多个订阅者客户端
• 主题过滤器:订阅中包含的表达式,表示相关联的一个或者多个主题
• MQTT控制报文:通过网络连接发送的信息数据包

其余的消息协议

• STOMP(流文本定向消息协议),XMPP(可拓展通信与表示协议),等

JMS

• JMS不属于任何一种消息协议,它是基础消息协议的抽象;类似于JDBC
• JMS中的消息队列模型

• • 点对点模型:
    
  • 发布/订阅者模型:
    

• JMS中主要的基本概念

• • 生产者:点对点模型指生产者;订阅者发布者指发布者
  • 消费者:点对点模型指消费者;订阅者发布者指订阅者
  • 客户端:指生产、消费消息的Java程序或者对象
  • 队列:容纳消息等待消费的区域,点对点模型的队列
  • 主题:支持一种消息发布给多个订阅者的机制,是订阅者\发布者模式的主题
  • 消息:JMS中传输的数据对象