jetlinks / netty-mqtt-client

Jet Links 物联网基础平台

----jetlinks
-------|--------jetlinks-core        #核心模块,统一API
-------|--------jetlinks-supports    #默认功能实现
-------|--------rule-engine          #规则引擎

请先在github中添加SSH Key

$ git clone --recursive [email protected]:jetlinks/jetlinks.git

查看演示

本项目为核心模块整合,无法直接运行. 要看演示效果请看这里.

netty-mqtt-client's Issues

MqttChannelHandler.handlePuback()空指针崩溃

private void handlePuback(MqttPubAckMessage message) {
    MqttPendingPublish pendingPublish = this.client.getPendingPublishes().get(message.variableHeader().messageId());
    pendingPublish.getFuture().setSuccess(null);
    pendingPublish.onPubackReceived();
    this.client.getPendingPublishes().remove(message.variableHeader().messageId());
    pendingPublish.getPayload().release();
}

pendingPublish可以是空指针。
必现场景：发送一条QoS1的消息后立刻断网，再连接后会崩溃。原因：
MqttClientImpl.publish函数有一段：

this.pendingPublishes.put(pendingPublish.getMessageId(), pendingPublish);
pendingPublish.startPublishRetransmissionTimer(this.eventLoop.next(), this::sendAndFlushPacket);

这个pendingPublishes变量会在MqttClientImpl.connect()函数里
pendingPublishes.clear();
但是RetransmissionTimer并没有停止，reconnect后仍会发送成功，接着收到Puback。这时pendingPublishes这个Map里已经不存在这个messageId的消息了。