Переглянути джерело

判断连接是否再活动中

易涛 3 роки тому
батько
коміт
afd6eded21

+ 1 - 1
src/main/java/com/persagy/netty/client/NettyClient.java

@@ -69,7 +69,7 @@ public class NettyClient {
             kafkaProducer.send(msg);
         }else {
             log.info("给云端发送数据:[{}]", msg);
-            if (channel.isWritable()) {
+            if (channel.isActive()&&channel.isWritable()) {
                 try {
                     //!!!!!!注意,NettyMessage<T>是有泛型的,如果把发送一个数据,接收方必须有一个和<T>的全限定类名完全一样的实体类,
                     //发送方不应该限制接收方,所有使用JSONObject.parseObject(msg.toString(), NettyMessage.class)操作让泛型擦除掉