MQTT消息发送失败 MAX_INFLIGHT

### MQTT 消息发送失败与 MAX_INFLIGHT 参数

当处理 MQTT 协议下的消息传递时，`MAX_INFLIGHT` 参数对于确保消息可靠性和性能至关重要。此参数定义了未确认的消息数量上限，在达到该限制之前不会发送新的消息。

#### `MAX_INFLIGHT` 的作用机制

在 QoS 1 或者 QoS 2 下，如果设置过高的 `MAX_INFLIGHT` 值可能导致内存溢出或过多的重传请求，从而影响系统的稳定性。相反，较低的值虽然可以减少资源消耗并提高稳定性，但也可能成为吞吐量瓶颈[^1]。

为了有效管理 `MAX_INFLIGHT` 并防止消息发送失败：

- **调整 `MAX_INFLIGHT` 数值**：根据实际应用场景的需求来合理配置这个数值。例如，在网络状况良好且服务器端具备较强处理能力的情况下适当增加；反之则应减小。

- **优化网络连接质量**：由于 MQTT 高度依赖于底层 TCP/IP 连接的质量，因此保持稳定可靠的网络环境非常重要。可以通过改善物理链路条件或是采用更优的数据包调度算法等方式提升整体表现。

- **实现超时检测逻辑**：针对长时间未能得到响应的消息实施合理的超时策略，并及时清理这些悬而未决的任务，以免占用过多系统资源。

下面是一个简单的 Python 实现片段用于展示如何通过 Paho-MQTT 库设定 `max_inflight_messages_set()` 方法来自定义最大并发未完成消息数目的例子:

import paho.mqtt.client as mqtt

def on_connect(client, userdata, flags, rc):
    print(f"Connected with result code {rc}")
    
client = mqtt.Client()
client.on_connect = on_connect

# 设置最大的 inflight messages 数目为 50
client.max_inflight_messages_set(50)

client.connect("mqtt.example.com", 1883, 60)
client.loop_forever()