创建mqtt订阅报错

rabbitmq开启mqtt插件用作mqtt服务器
在IotAutoConfiguration配置类中增加获取MqttClient方法

```
    @Bean
    public MqttClient defaultLotOrderMqttClient(DefaultMqttComponent defaultMqttComponent, MqttSubscribeListener mqttSubscribeListener){
        DefaultMqttConnectProperties defaultMqttConnectProperties = new DefaultMqttConnectProperties("127.0.0.1",
                1883,
                "defaultLotOrderMqttClient",
                Arrays.asList(new MqttTopicSubscription("iot.data.topic", MqttQoS.AT_MOST_ONCE)),
                mqttSubscribeListener);
        defaultMqttConnectProperties.setUsername("admin");
        defaultMqttConnectProperties.setPassword("123456");
        return defaultMqttComponent.createNewClientAndConnect(defaultMqttConnectProperties);
    }
```

MqttDebugSubscribeListener

```
@Component
public class MqttDebugSubscribeListener implements MqttSubscribeListener {

private MqttTopicSubscription subscription = new MqttTopicSubscription("iot.data.topic", MqttQoS.AT_MOST_ONCE);

@Override
    public void onSubscribe(DefaultMqttSubscribeProtocol protocol) {
        byte[] message = protocol.requestMessage().getMessage();
        String value = new String(message);
        System.out.println(value);
    }

@Override
    public MqttTopicSubscription topic(DefaultMqttConnectProperties client) {
        return subscription;
    }
}
```
重启项目，SocketClient执行connect方法时开始报错。
具体报错内容如下

```
17:47:38.822 [ERROR] [6094] [IWT-3-1] c.i.i.c.h.ClientServiceHandler           : 客户端处理(MQTT<默认>) 处理异常 - 错误信息: null - 处理方式：已发送异常事件[ExceptionEvent], 创建监听器[ExceptionEventListener]来监听异常事件

java.lang.NullPointerException: null
	at com.iteaj.iot.client.component.SocketClientComponent.getFilter(SocketClientComponent.java:249)
	at com.iteaj.iot.client.handle.ClientServiceHandler.channelActive(ClientServiceHandler.java:111)
	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelActive(AbstractChannelHandlerContext.java:230)
	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelActive(AbstractChannelHandlerContext.java:216)
	at io.netty.channel.AbstractChannelHandlerContext.fireChannelActive(AbstractChannelHandlerContext.java:209)
	at com.iteaj.iot.client.mqtt.MqttClient.channelActive(MqttClient.java:255)
	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelActive(AbstractChannelHandlerContext.java:230)
	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelActive(AbstractChannelHandlerContext.java:216)
	at io.netty.channel.AbstractChannelHandlerContext.fireChannelActive(AbstractChannelHandlerContext.java:209)
	at io.netty.channel.DefaultChannelPipeline$HeadContext.channelActive(DefaultChannelPipeline.java:1398)
	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelActive(AbstractChannelHandlerContext.java:230)
	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelActive(AbstractChannelHandlerContext.java:216)
	at io.netty.channel.DefaultChannelPipeline.fireChannelActive(DefaultChannelPipeline.java:895)
	at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.fulfillConnectPromise(AbstractNioChannel.java:305)
	at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:335)
	at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:707)
	at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:655)
	at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:581)
	at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:493)
	at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989)
	at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
	at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
	at java.lang.Thread.run(Thread.java:748)
```

iteaj/iboot

内容风险标识

评论 (0)