优化tcpclient

longqingzhao · Feb 16, 2019 · 20ae358 · 20ae358
1 parent 61735ce
commit 20ae358
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/onlinecrash/src/main/java/zlq/com/onlinecrash/data/TcpClient.java b/onlinecrash/src/main/java/zlq/com/onlinecrash/data/TcpClient.java
@@ -134,6 +134,9 @@ public void run() {
                 while (selector.select() > 0) {
                     //返回的是select的key集合并遍历（如果一个key所指的对象为空会报异常）
                     for (SelectionKey key : selector.selectedKeys()) {
+                        if (sc == null || !sc.isConnected()) {
+                            return;
+                        }
                         //如果该SelectionKey对应的Channel中有可读的数据
                         if (key.isReadable()) {
                             ByteBuffer buff = ByteBuffer.allocate(1024);
@@ -148,9 +151,6 @@ public void run() {
                             if (nioResponse != null) {
                                 nioResponse.receive(content.toString());
                             }
-                            if (sc == null || !sc.isConnected()) {
-                                return;
-                            }
                             //为下一次读取作准备
                             key.interestOps(SelectionKey.OP_READ);
                         }