mqtt- 轻量级的消息传输协议

金融数据流：实时数据传输  实现方式基于mqtt

MQTT（Message Queuing Telemetry Transport）是一种轻量级的消息传输协议，主要用于低带宽和高延迟的网络环境。它特别适合于物联网（IoT）应用、移动设备和其他需要可靠消息传递的场景。

MQTT 的主要特点

1. 轻量级和高效：

• MQTT 协议的开销非常小，适合于资源受限的设备和网络环境。它使用了小型的报文头部，降低了带宽和处理能力的需求。

2. 发布/订阅模式：

• MQTT 使用发布/订阅模式来解耦生产者（发布者）和消费者（订阅者）。发布者将消息发布到一个主题（topic），而订阅者订阅一个或多个主题以接收相关消息。这种模式提高了系统的灵活性和扩展性。

3. 可靠的消息传递：

• MQTT 提供了三种消息服务质量（QoS）级别：

• QoS 0: 至多一次（At most once） - 消息发送一次，不保证送达。

• QoS 1: 至少一次（At least once） - 消息至少送达一次，但可能会重复。

• QoS 2: 仅一次（Exactly once） - 消息仅送达一次，确保不重复也不丢失。

4. 持久会话：

• 客户端可以选择持久会话模式，以便在断开和重连后继续接收之前未收到的消息。

5. 保留消息：

• MQTT 支持“保留”消息（Retained Messages），这些消息会被保存在代理服务器上，并在有新的订阅者订阅该主题时发送给他们。

6. 遗嘱消息：

• 客户端可以在连接时设置遗嘱消息（Last Will and Testament），当客户端异常断开连接时，代理会发布这条消息通知其他订阅者。

MQTT 的工作原理

1. 连接：

• 客户端连接到 MQTT 代理服务器（Broker），并进行身份验证（如果需要）。

2. 发布：

• 客户端将消息发布到特定的主题。代理服务器接收这些消息并将其转发给所有订阅了该主题的客户端。

3. 订阅：

• 客户端订阅一个或多个主题。代理服务器将所有发布到这些主题的消息发送给相应的客户端。

4. 断开：

• 客户端断开连接时，代理服务器会根据设置的遗嘱消息发布相应的信息（如果配置了遗嘱消息）。

MQTT 使用场景

• 物联网（IoT）：如传感器数据传输、设备状态监控等。

• 移动应用：如消息推送、实时聊天等。

• 智能家居：如控制家电、获取传感器数据等。

• 实时数据传输：如金融数据流、交通信息等。

典型的 MQTT 组件

1. MQTT 代理（Broker）：

• 负责接收、存储和转发消息到适当的客户端。常见的 MQTT 代理有 Mosquitto、EMQX、HiveMQ 等。

2. MQTT 客户端（Client）：

• 发布和订阅消息的终端设备或应用程序。