Broker用的是Apollo,publisher与subscribe均使用了python下的paho.mqtt库,publish与subscribe部署在两台机器上,publish每十秒向一个toipic发送消息,subscriber实现on_message并使用loop_start()启动,使用while True保持运行。
现在现象是,publish发送没有问题,on_message回调无误,subscriber只能偶尔收到消息,按一分钟算每6个消息中大概能收到2-3个。求问为啥?
PS:都是内网机器,网络是没问题的。