src/org/redkale/net/TcpNioAsyncConnection.java

@@ -472,6 +472,7 @@ public class TcpNioAsyncConnection extends AsyncConnection {
             }
 
             if (totalCount > 0 || !hasRemain) {
+                if (writeKey != null) writeKey.interestOps(writeKey.interestOps() & ~SelectionKey.OP_WRITE);
                 CompletionHandler<Integer, Object> handler = this.writeCompletionHandler;
                 Object attach = this.writeAttachment;
                 clearWrite();
@@ -527,4 +528,10 @@ public class TcpNioAsyncConnection extends AsyncConnection {
         this.writeLength = 0;
         this.writePending = false; //必须放最后
     }
+
+    @Override
+    public final void close() throws IOException {
+        super.close();
+        channel.close();
+    }
 }

src/org/redkale/net/nio/NioThread.java

@@ -68,6 +68,7 @@ public class NioThread extends Thread {
                     it.remove();
                     TcpNioAsyncConnection conn = (TcpNioAsyncConnection) key.attachment();
                     if (key.isWritable()) {
+                        //key.interestOps(key.interestOps() & ~SelectionKey.OP_WRITE);
                         conn.doWrite();
                     } else if (key.isReadable()) {
                         conn.doRead();