消息队列（2）：常见的消息队列协议

协议很常见，只要是通信，就会用到协议，就像我们说话的语言一样，不同的语言连通着不同的人群。
所以说，消息队列也是一样，想要互相通信，就要使用同一种协议。
每个协议下的消息队列，都有着不同的角色定义。
简单说下常见的消息队列协议：

1.AMQP（Advance Message Queuing Protocol）

Message（消息）：消息服务器处理消息的原子单元，包括一个内容头，一组属性和一个内容体。
消息有优先级，高优先级的消息在等待同一消息队列时会比低优先级的消息先发送，而且当消息必须被丢弃时，低优先级的消息优先被丢弃。
使用AMQP协议，消息服务器不能修改内容体和内容头，但可以在内容头上添加额外信息。
PubLisher（消息生产者）：发送消息
Consumer（消息消费者）：消费消息
Broker（消息代理）：消息队列服务器，负责接收客户端连接，路由消息。
Queue（消息队列）：Broker中的一个角色，一个Broker中可以有多个Queue，负责保存消息直到发送给不同的消费者。算是消息的容器。一个消息可以被投入一个或多个队列中，每个队列的消息都会等待消费者连接到这个队列并被取走。
Exchange（交换路由）：Broker中的一个角色，负责接收生产者发送的消息，并路由给服务器中的队列。可以被理解成一个规则表，指明消息该被投到哪个队列中。
Channel（信道）：信道是一条独立的双向数据流通道。为了解决操作系统无法承受每秒建立特别多的TCP连接。

生产者发送消息时，必须指定消息要被路由到哪些个消息队列中。
当消息到消息队列中，消息队列会尝试将消息传给消费者，如果失败，消息队列会存储消息并等待消费者。
如果没有消费者，消息队列将选择性的将消息返回给生产者。
如果消息别消费掉，消息队列会删除消息，删除的过程或者是及时的，或者是等到消费者消费结果后才删除的。

AMQP是二进制协议。

2.MQTT（Message Queuing Telemetry Transport，消息队列遥测传输）

由IBM开发，现在被广泛用于物联网公司。因为他的特点就是轻量，简单，开放和易于实现。所以他常用于很多计算能力有限、带宽低、网络不可靠的远程通信应用场景。
Publisher（发布者）：消息发布客户端
Subscriber（订阅者）：消息订阅客户端
Broker（消息代理）：消息服务器端
Application Message（应用消息）：指通过网络传输的应用数据，一般包括主题和负载。
Topic（主题）：应用消息的类型，一般消息发布者会确定消息的主题，订阅者根据自己实际情况选择不同的主题进行消息订阅消费。
Payload（负载）：消息订阅者具体接收的内容。

MQTT协议是通过交换预定义的MQTT控制报文来通信的。
控制报文内容由三部分组成：固定报头，可变报头和消息体。
固定报头通过标识不同位的值来确定报文类型，包括发布订阅的一些完成状态等。
可变报头的内容根据控制报文类型不同而不同，常作为包的标识符。
消息体也是根据不同的消息类型有着不同的内容。

MQTT协议中，客户端和服务端是通过请求应答模式通信的。客户端发送一条控制报文数据给服务器，服务器再发送一条控制报文数据给客户端。

MQTT在发布消息时，有三种Qos等级：至多一次（0级），至少一次（1级），只有一次（2级）。
至多一次等级最低，客户端只需要将消息发出去即可，这种等级很low，用于消息不重要但特别多，为了减轻通信压力，就不顾质量，只看数量了。
至少一次等级中等，客户端要保证发出去的消息至少一次被服务端接收到，所以要收到服务端的回应，否则一直发，这种等级一般用于服务端有幂等处理，所以不怕重复消费，还要保证消息不会丢失。
只有一次等级最高，客户端先发消息过去，然后本地记录一个我已发送，但不确定你是否收到的状态，然后服务端接收到消息后，回给客户端一个我已接收的报文，同时服务端记录一个我不确定你知不知道我已接收的状态，然后客户端收到这个已接收的消息后，就确定服务端收到这个消息了，于是把自己本地记录的已发送未确定的状态删除，同时再给客户端发送一个我已经知道你收到的报文，服务端收到这个报文，也会把自己之前记录的状态删掉，整个一条报文只有一次的通信才算完成，这种等级就比较严格了，但质量上去了，相对低等级的，数量就会相对小些，但可靠就是王道，不多不少才是最好的。
只有一次的发送和确定，其实思想和三次握手差不多，都是两端互相确认的过程，所以会一来一回的。如果传输过程中出现丢包，都会由发送者重发上一条消息。