Przeglądaj źródła

kafka nettyMessage兼容

易涛 3 lat temu
rodzic
commit
02538fb75a

+ 3 - 1
src/main/java/com/persagy/entity/NettyMessage.java

@@ -63,7 +63,9 @@ public class NettyMessage<T> extends Packet implements Serializable {
     }
 
     public NettyMessage(int opCode) {
-        this.channelId = NettyClient.channel.id().toString();
+        if(NettyClient.channel!=null){
+            this.channelId = NettyClient.channel.id().toString();
+        }
         this.projectId = CommonConst.projectId;
         this.groupCode = CommonConst.groupCode;
         this.opCode = opCode;

+ 2 - 2
src/main/java/com/persagy/kafka/KafkaProducer.java

@@ -45,9 +45,9 @@ public class KafkaProducer {
     @Order(2)
     public void queryDefine() throws InterruptedException {
         //建立连接
-        nettyClient.sendMessage(new NettyMessage(200,null));
+        nettyClient.sendMessage(new NettyMessage(200));
         //启动的时候发送消息,获取全部报警定义
-        NettyMessage nettyMessage = new NettyMessage(4,null);
+        NettyMessage nettyMessage = new NettyMessage(4);
         JSONObject content = new JSONObject();
         content.put("groupCode", CommonConst.groupCode);
         content.put("projectId", CommonConst.projectId);