Mosquitto MQTT桥接断开后一段时间停止持久化存储消息求助

我运行两套MQTT系统：

• 系统1：包含每10秒发送数据的Publisher，以及配置为桥接的Mosquitto Broker（将部署在现场，通过移动网络连接，需在网络中断时存储消息）
• 系统2：包含主Mosquitto Broker和将消息写入数据库的Subscriber客户端

设备连通时一切正常，但断开系统2（模拟停机）后，系统1的Broker会暂时将消息存入持久化数据库，随后停止存储，该时长可复现。日志中出现错误Error creating bridge: Broken pipe.，此后不再存储消息；重新连接系统2后，已存储的消息会正常发送。

使用Mosquitto 1.5.7版本，桥接配置如下：

pid_file /var/run/mosquitto.pid

persistence true
persistence_location /var/lib/mosquitto/

log_dest file /var/log/mosquitto/mosquitto.log

connection OT-to-IT
address 192.168.10.244
cleansession false
bridge_insecure true
remote_password <password>
remote_username <user>
remote_clientid <client_id>

try_private true
topic # both 1

autosave_interval 10
persistent_client_expiration 30d
max_queued_messages 0
max_queued_bytes 0
#keepalive_interval 65535
keepalive_interval 0

调整keepalive_interval参数会改变错误出现的延迟：

• 设为最大值65535时，约能存储半小时消息，但我需要至少3-4天的存储时长
• 设为0（禁用保活）时，不到1分钟就出现错误，仅存储4条消息

1. 升级Mosquitto版本 #

Mosquitto 1.5.7是2019年的旧版本，桥接模块在后续2.x及以上稳定版本中修复了大量持久化、重连队列相关的bug，对网络中断后的队列管理、桥接重连逻辑有显著优化，能支持更长时间的离线消息存储，这是最彻底的解决方式。

2. 调整桥接重连与队列参数（针对旧版本） #

如果暂时无法升级，可修改以下配置参数：

• 添加reconnect_interval和reconnect_interval_max：指定断开后的初始重连间隔（单位：秒），以及最大重连间隔，避免频繁重连耗尽资源，示例：reconnect_interval 30、reconnect_interval_max 300
• 显式开启桥接持久化：添加bridge_persistence true，旧版本中部分场景下默认未启用桥接的持久化逻辑
• 合理设置keepalive：不要设为0（旧版本禁用保活会导致连接被快速判定失效），建议设为300秒（5分钟），配合max_inflight_messages 10平衡保活检测与队列存储

修改后的桥接配置示例：

connection OT-to-IT
address 192.168.10.244
cleansession false
bridge_persistence true
bridge_insecure true
remote_password <password>
remote_username <user>
remote_clientid <client_id>
reconnect_interval 30
reconnect_interval_max 300
keepalive_interval 300
max_inflight_messages 10

try_private true
topic # both 1

3. 检查持久化存储环境 #

确保persistence_location指定的/var/lib/mosquitto/目录有Mosquitto进程的读写权限，且磁盘空间充足。旧版本中如果磁盘满或权限不足，会静默停止持久化存储。

4. 本地Subscriber替代方案 #

如果桥接的持久化始终无法满足需求，可在系统1的Broker本地部署一个Subscriber客户端，将消息写入本地数据库（如SQLite、Redis），待网络恢复后，再由该客户端将本地存储的消息转发到系统2的Broker。这种方式不受Mosquitto桥接队列限制，能灵活控制离线存储时长。

内容的提问来源于stack exchange，提问作者Marcel