Wizzercn / MqttWk

Java + Netty 实现的高并发高可用MQTT服务broker,轻松支持10万并发(有群友实现了130万在线)
Apache License 2.0
635 stars 229 forks source link

您好,想请教一下MessageIdService的处理思路 #5

Closed wangzengjing closed 5 years ago

wangzengjing commented 5 years ago

我是刚刚接触MQTT,找了一个服务端实现的demo,但是我在发送遗嘱消息的时候,用qos1或者2的时候会爆出messageid 为 0,这其中的messageid 需要怎么实现呢?请大佬赐教

Wizzercn commented 5 years ago
    public static MqttMessageIdVariableHeader from(int messageId) {
        if (messageId >= 1 && messageId <= 65535) {
            return new MqttMessageIdVariableHeader(messageId);
        } else {
            throw new IllegalArgumentException("messageId: " + messageId + " (expected: 1 ~ 65535)");
        }
    }

同个消息值一致,不同消息不重复