Mosquitto桥接发送大量消息时无法接收远程消息的配置调整求助

问题说明 #

本地Mosquitto代理在发送大流量消息（如ROS激光扫描、代价地图数据）时，无法接收远程代理的消息；无高发送负载时接收正常。需求为优先保障远程消息接收，允许出站消息丢失或延迟。已尝试调整QoS、max_inflight_bytes、max_queued_bytes（约2MB），未解决问题。当前桥接配置如下：

connection remote-broker
address {address:port}
topic data/# out 0 "" remoter/namespace/
topic data/debug_control in 1 "" remoter/namespace/
cleansession false
notifications false
remote_clientid Testing
remote_password {username}
remote_username {password}
start_type automatic
try_private true
bridge_cafile {user_cafile}
bridge_insecure false
bridge_certfile {user_certfile}
bridge_keyfile {user_keyfile}
bridge_protocol_version mqttv50

可调整的关键配置项 #

1. 限制出站消息资源占用 #

• bridge_outgoing_qos 0：强制出站消息使用QoS 0，无需确认，减少协议开销，匹配“出站可丢失”的需求
• bridge_max_queued_messages 100：设置出站消息队列上限，避免队列无限膨胀占用内存和处理资源
• bridge_discard_outgoing true：队列满时自动丢弃旧的出站消息，优先释放资源给入站处理
• max_inflight_messages 10：减少同时处理的未确认出站消息数量，避免阻塞连接通道

2. 隔离入站/出站处理线程 #

• bridge_threaded true：为桥接连接启用独立线程，让入站、出站消息处理并行执行，避免发送负载阻塞接收逻辑

3. MQTTv5专属流量控制 #

• receive_maximum 64：告知远程代理本地可缓存的未确认入站消息数量，防止远程端发送过载
• maximum_packet_size 1048576：限制单条消息最大字节数（1MB），避免超大消息占用过多带宽和处理时间
• clean_start true：替代MQTTv3的cleansession，重启桥接时清理旧会话的未发送消息，释放资源（若无需持久化出站消息）

4. 连接稳定性优化 #

• keepalive_interval 60：调整心跳间隔，避免高负载下因心跳超时导致连接断开

调整后的参考配置 #

connection remote-broker
address {address:port}
topic data/# out 0 "" remoter/namespace/
topic data/debug_control in 1 "" remoter/namespace/
clean_start true
notifications false
remote_clientid Testing
remote_password {username}
remote_username {password}
start_type automatic
try_private true
bridge_cafile {user_cafile}
bridge_insecure false
bridge_certfile {user_certfile}
bridge_keyfile {user_keyfile}
bridge_protocol_version mqttv50

# 出站资源限制
bridge_outgoing_qos 0
bridge_max_queued_messages 100
bridge_discard_outgoing true
max_inflight_messages 10

# 线程隔离
bridge_threaded true

# MQTTv5流量控制
receive_maximum 64
maximum_packet_size 1048576

# 连接优化
keepalive_interval 60

内容的提问来源于stack exchange，提问作者Lucas Rønne Jeppesen