keeplived 虚拟a和b两个mqtt客户端,虚拟ip为c(192.168.2.218),两个jar包通过虚拟ip(192.168.2.218)连接mqtt(正常),并且都订阅1000个共享topic,通过模拟程序往mqtt推送数据,发现两个jar包都能接到回调消息,不重复的回调,用的共享订阅的hash模式!
日志如下:
2023-09-21T11:43:47.968300+08:00 [debug] gate201con0linuxgatewaytestv12@192.168.2.218:40234 [MQTT] RECV PUBLISH(Q0, R0, D0Topic=sys/46tcmx0k6xxf/46tcqpymaedf/thing/event/property/post, PacketId=undefined, Payload={“msgid”:0,“params”:{“paradi1”:0},“ts”:1695267827925})
2023-09-21T11:43:47.968564+08:00 [info] gate201con0linuxgatewaytestv12@192.168.2.218:40234 PUBLISH to sys/46tcmx0k6xxf/46tcqpymaedf/thing/event/property/post: <<“{"msgid":0,"params":{"paradi1":0},"ts":1695267827925}”>>
2023-09-21T11:43:47.969291+08:00 [debug] EmqClientSubscribe_48zh5o7hsb80@192.168.2.183:42090 [MQTT] SEND PUBLISH(Q0, R0, D0Topic=sys/46tcmx0k6xxf/46tcqpymaedf/thing/event/property/post, PacketId=undefined, Payload={“msgid”:0,“params”:{“paradi1”:0},“ts”:1695267827925})
2023-09-21T11:43:48.048471+08:00 [debug] gate201con0linuxgatewaytestv12@192.168.2.218:40234 [MQTT] RECV PUBLISH(Q0, R0, D0Topic=sys/46tcmx0k6xxf/470ox9itrd3y/thing/event/property/post, PacketId=undefined, Payload={“msgid”:70,“params”:{“paradi1”:0},“ts”:1695267827940})
2023-09-21T11:43:48.048637+08:00 [info] gate201con0linuxgatewaytestv12@192.168.2.218:40234 PUBLISH to sys/46tcmx0k6xxf/470ox9itrd3y/thing/event/property/post: <<“{"msgid":70,"params":{"paradi1":0},"ts":1695267827940}”>>
2023-09-21T11:43:48.049310+08:00 [debug] EmqClientSubscribe_48zh6nvj396m@192.168.2.218:51952 [MQTT] SEND PUBLISH(Q0, R0, D0Topic=sys/46tcmx0k6xxf/470ox9itrd3y/thing/event/property/post, PacketId=undefined, Payload={“msgid”:70,“params”:{“paradi1”:0},“ts”:1695267827940})