EasyProgramming

Results 4 comments of EasyProgramming

[Bug] When sending a message with qos=2, according to the MQTT 3.1.1 protocol, MQTTX should first store the message locally and then proceed with sending.

Okay, after MQTTX sends a message with QoS=2 via a PUBLISH packet, if it does not receive a PUBREC packet for a long time, it will delete this message. This...

[Bug] When sending a message with qos=2, according to the MQTT 3.1.1 protocol, MQTTX should first store the message locally and then proceed with sending.

> Okay, after MQTTX sends a message with QoS=2 via a PUBLISH packet, if it does not receive a PUBREC packet for a long time, it will delete this message....

[Bug] When sending a message with qos=2, according to the MQTT 3.1.1 protocol, MQTTX should first store the message locally and then proceed with sending.

步骤一：mqttx与mqtt broker建立连接，cleanSession为false 步骤二：mqttx订阅了topic a，之后，向topic a发送了一条qos2的消息（publis报文） 步骤三：mqtt broker收到了mqttx发送的publish报文，但是向mqttx发送pubrec报文之前，发生了宕机，导致pubrec报文未发送 经过了这三个步骤，mqttx会把发送的这条qos=2的消息删除，这样是不对的，mqttx应该把这条qos=2的消息持久化到本地，然后等待pubrec报文 --- Step one: MQTTX establishes a connection with the MQTT broker with `cleanSession` set to false. Step two: MQTTX subscribes to topic...

Prefix scan didn't work well when enabling the cluster mode

@git-hulk 我这边使用Java的lettuce连接的kvrocks，看了lettuce对scan、hscan、sscan的实现方式，lettuce是以游标返回的是否为字符0来判断是否扫描完成的，所以想问一下，kvrocks这块关于scan、hscan、sscan扫描完成的标志为是否也是字符0呢，这样的话，对于我这边的程序来讲还是可以接受的