update

jsowell-netty/src/main/java/com/jsowell/netty/server/mqtt/BootNettyMqttChannelInboundHandler.java

@@ -9,14 +9,13 @@ import com.jsowell.netty.service.camera.CameraBusinessService;
 import io.netty.buffer.Unpooled;
 import io.netty.channel.*;
 import io.netty.handler.codec.mqtt.*;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Component;
 
 import java.io.IOException;
 import java.net.InetSocketAddress;
 import java.util.concurrent.ConcurrentHashMap;
 
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.stereotype.Component;
-
 /**
  * MQTT服务端I/O数据读写处理类
  *
@@ -52,7 +51,7 @@ public class BootNettyMqttChannelInboundHandler extends ChannelInboundHandlerAda
             MqttFixedHeader mqttFixedHeader = mqttMessage.fixedHeader();
             Channel channel = ctx.channel();
 
-            if (mqttFixedHeader.messageType().equals(MqttMessageType.CONNECT)) {
+            if (MqttMessageType.CONNECT.equals(mqttFixedHeader.messageType())) {
                 //	在一个网络连接上，客户端只能发送一次CONNECT报文。服务端必须将客户端发送的第二个CONNECT报文当作协议违规处理并断开客户端的连接
                 //	to do 建议connect消息单独处理，用来对客户端进行认证管理等 这里先直接返回一个CONNACK消息
                 BootNettyMqttMsgBack.connack(channel, mqttMessage);