最新main 2.0.8代码，发布订阅 Qos 2主题时，订阅方总是收到两条消息

最新main 2.0.8代码，发布订阅 Qos 2主题时，订阅方总是收到两条消息，如下图示：
![输入图片说明](https://foruda.gitee.com/images/1681435505779617230/852d66b1_93131.png "2023-04-14 09-22-42屏幕截图.png")
log日志如下:
2023-04-14 09:14:03 [smqttx-cluster-io-epoll-4] INFO  org.casbin.jcasbin
 - Request: mqttx_5bf97223:127.0.0.1, /v1/devices/84212836132F0Df7/command, PUBLISH ---> true
2023-04-14 09:14:03 [smqttx-cluster-io-epoll-4] INFO  i.g.quickmsg.common.log.LogManager
 - 172.17.0.1|127.0.0.1:40708|mqttx_5bf97223|PUBLISH|success|{"messageId":58693,"event":"publish","topic":"/v1/devices/84212836132F0Df7/command","qos":2,"retain":false,"body":{"msg":"helasd"},"time":"2023-04-14 09:14:03","clientId":"mqttx_5bf97223"}
2023-04-14 09:14:03 [smqttx-cluster-io-epoll-4] INFO  i.g.quickmsg.common.log.LogManager
 - 172.17.0.1|192.168.123.218:59372|84212836132F0Df7|WRITE|success|{"qos":2,"retain":false,"body":{"msg":"helasd"},"connectTime":"2023-04-14 09:14:03","clientId":"mqttx_5bf97223","topic":"/v1/devices/84212836132F0Df7/command","originTopic":"/v1/devices/84212836132F0Df7/command","channelId":2}
2023-04-14 09:14:03 [smqttx-cluster-io-epoll-3] INFO  i.g.quickmsg.common.log.LogManager
 - 172.17.0.1|192.168.123.218:59372|84212836132F0Df7|PUBLISH_REC|success|{"messageId":3,"time":"2023-04-14 09:14:03","event":"pubAck"}
2023-04-14 09:14:03 [smqttx-cluster-io-epoll-4] INFO  i.g.quickmsg.common.log.LogManager
 - 172.17.0.1|127.0.0.1:40708|mqttx_5bf97223|PUBLISH_REL|success|{"messageId":58693,"time":"2023-04-14 09:14:03","event":"pubAck","timestamp":0}
2023-04-14 09:14:03 [smqttx-cluster-io-epoll-4] INFO  i.g.quickmsg.common.log.LogManager
 - 172.17.0.1|127.0.0.1:40708|mqttx_5bf97223|PUBLISH|success|{"messageId":58693,"time":"2023-04-14 09:14:03","event":"pubAck","timestamp":0}
2023-04-14 09:14:03 [smqttx-cluster-io-epoll-4] INFO  i.g.quickmsg.common.log.LogManager
 - 172.17.0.1|192.168.123.218:59372|84212836132F0Df7|WRITE|success|{"qos":2,"retain":false,"body":{"msg":"helasd"},"connectTime":"2023-04-14 09:14:03","clientId":"mqttx_5bf97223","topic":"/v1/devices/84212836132F0Df7/command","originTopic":"/v1/devices/84212836132F0Df7/command","channelId":2}
2023-04-14 09:14:03 [smqttx-cluster-io-epoll-3] INFO  i.g.quickmsg.common.log.LogManager
 - 172.17.0.1|192.168.123.218:59372|84212836132F0Df7|PUBLISH_COMP|success|{"messageId":3,"time":"2023-04-14 09:14:03","event":"pubAck"}
2023-04-14 09:14:03 [smqttx-cluster-io-epoll-3] INFO  i.g.quickmsg.common.log.LogManager
 - 172.17.0.1|192.168.123.218:59372|84212836132F0Df7|PUBLISH_REC|success|{"messageId":4,"time":"2023-04-14 09:14:03","event":"pubAck"}
2023-04-14 09:14:03 [parallel-12] INFO  i.g.q.s.rocketmq.RocketmqSourceBean
 - rocketMq send status SEND_OK
2023-04-14 09:14:03 [smqttx-cluster-io-epoll-3] INFO  i.g.quickmsg.common.log.LogManager
 - 172.17.0.1|192.168.123.218:59372|84212836132F0Df7|PUBLISH_COMP|success|{"messageId":4,"time":"2023-04-14 09:14:03","event":"pubAck"}
2023-04-14 09:14:03 [smqttx-cluster-io-epoll-3] INFO  org.casbin.jcasbin
 - Request: 84212836132F0Df7:192.168.123.218, /v1/devices/84212836132F0Df7/command_reply, PUBLISH ---> true
2023-04-14 09:14:03 [smqttx-cluster-io-epoll-3] INFO  i.g.quickmsg.common.log.LogManager
 - 172.17.0.1|192.168.123.218:59372|84212836132F0Df7|PUBLISH|success|{"messageId":1,"event":"publish","topic":"/v1/devices/84212836132F0Df7/command_reply","qos":2,"retain":false,"body":{"msg":"helasd"},"time":"2023-04-14 09:14:03","clientId":"84212836132F0Df7"}
2023-04-14 09:14:03 [smqttx-cluster-io-epoll-3] INFO  i.g.quickmsg.common.log.LogManager
 - 172.17.0.1|127.0.0.1:40708|mqttx_5bf97223|WRITE|success|{"qos":2,"retain":false,"body":{"msg":"helasd"},"connectTime":"2023-04-14 09:14:03","clientId":"84212836132F0Df7","topic":"/v1/devices/+/command_reply","originTopic":"/v1/devices/84212836132F0Df7/command_reply","channelId":1}
2023-04-14 09:14:03 [smqttx-cluster-io-epoll-3] INFO  i.g.quickmsg.common.log.LogManager
 - 172.17.0.1|192.168.123.218:59372|84212836132F0Df7|PUBLISH_REL|success|{"messageId":1,"time":"2023-04-14 09:14:03","event":"pubAck","timestamp":0}
2023-04-14 09:14:03 [smqttx-cluster-io-epoll-3] INFO  i.g.quickmsg.common.log.LogManager
 - 172.17.0.1|192.168.123.218:59372|84212836132F0Df7|PUBLISH|success|{"messageId":1,"time":"2023-04-14 09:14:03","event":"pubAck","timestamp":0}
2023-04-14 09:14:03 [smqttx-cluster-io-epoll-4] INFO  i.g.quickmsg.common.log.LogManager
 - 172.17.0.1|127.0.0.1:40708|mqttx_5bf97223|PUBLISH_REC|success|{"messageId":3,"time":"2023-04-14 09:14:03","event":"pubAck"}
2023-04-14 09:14:03 [smqttx-cluster-io-epoll-4] INFO  i.g.quickmsg.common.log.LogManager
 - 172.17.0.1|127.0.0.1:40708|mqttx_5bf97223|PUBLISH_COMP|success|{"messageId":3,"time":"2023-04-14 09:14:03","event":"pubAck"}
2023-04-14 09:14:03 [parallel-18] INFO  i.g.q.s.rocketmq.RocketmqSourceBean
 - rocketMq send status SEND_OK
2023-04-14 09:14:03 [smqttx-cluster-io-epoll-3] INFO  org.casbin.jcasbin
 - Request: 84212836132F0Df7:192.168.123.218, /v1/devices/84212836132F0Df7/command_reply, PUBLISH ---> true
2023-04-14 09:14:03 [smqttx-cluster-io-epoll-3] INFO  i.g.quickmsg.common.log.LogManager
 - 172.17.0.1|192.168.123.218:59372|84212836132F0Df7|PUBLISH|success|{"messageId":1,"event":"publish","topic":"/v1/devices/84212836132F0Df7/command_reply","qos":2,"retain":false,"body":{"msg":"helasd"},"time":"2023-04-14 09:14:03","clientId":"84212836132F0Df7"}
2023-04-14 09:14:03 [smqttx-cluster-io-epoll-3] INFO  i.g.quickmsg.common.log.LogManager
 - 172.17.0.1|127.0.0.1:40708|mqttx_5bf97223|WRITE|success|{"qos":2,"retain":false,"body":{"msg":"helasd"},"connectTime":"2023-04-14 09:14:03","clientId":"84212836132F0Df7","topic":"/v1/devices/+/command_reply","originTopic":"/v1/devices/84212836132F0Df7/command_reply","channelId":1}
2023-04-14 09:14:03 [smqttx-cluster-io-epoll-3] INFO  i.g.quickmsg.common.log.LogManager
 - 172.17.0.1|192.168.123.218:59372|84212836132F0Df7|PUBLISH_REL|success|{"messageId":1,"time":"2023-04-14 09:14:03","event":"pubAck","timestamp":0}
2023-04-14 09:14:03 [smqttx-cluster-io-epoll-3] INFO  i.g.quickmsg.common.log.LogManager
 - 172.17.0.1|192.168.123.218:59372|84212836132F0Df7|PUBLISH|success|{"messageId":1,"time":"2023-04-14 09:14:03","event":"pubAck","timestamp":0}
2023-04-14 09:14:03 [smqttx-cluster-io-epoll-4] INFO  i.g.quickmsg.common.log.LogManager
 - 172.17.0.1|127.0.0.1:40708|mqttx_5bf97223|PUBLISH_REC|success|{"messageId":4,"time":"2023-04-14 09:14:03","event":"pubAck"}
2023-04-14 09:14:03 [smqttx-cluster-io-epoll-4] INFO  i.g.quickmsg.common.log.LogManager
 - 172.17.0.1|127.0.0.1:40708|mqttx_5bf97223|PUBLISH_COMP|success|{"messageId":4,"time":"2023-04-14 09:14:03","event":"pubAck"}
2023-04-14 09:14:03 [parallel-22] INFO  i.g.q.s.rocketmq.RocketmqSourceBean
 - rocketMq send status SEND_OK

quickmsg/smqttx

内容风险标识

评论 (0)

quickmsg/smqttx .gitee-modal { width: 500px !important; }

内容风险标识