diff --git a/src/org/redkale/net/TcpAioAsyncConnection.java b/src/org/redkale/net/TcpAioAsyncConnection.java
index 985b272e4..5c3740062 100644
--- a/src/org/redkale/net/TcpAioAsyncConnection.java
+++ b/src/org/redkale/net/TcpAioAsyncConnection.java
@@ -147,10 +147,14 @@ public class TcpAioAsyncConnection extends AsyncConnection {
             return;
         }
         this.writetime = System.currentTimeMillis();
-        if (writeTimeoutSeconds > 0) {
-            channel.write(src, writeTimeoutSeconds, TimeUnit.SECONDS, attachment, newHandler);
-        } else {
-            channel.write(src, attachment, newHandler);
+        try {
+            if (writeTimeoutSeconds > 0) {
+                channel.write(src, writeTimeoutSeconds, TimeUnit.SECONDS, attachment, newHandler);
+            } else {
+                channel.write(src, attachment, newHandler);
+            }
+        } catch (Exception e) {
+            newHandler.failed(e, attachment);
         }
     }
 
@@ -177,7 +181,11 @@ public class TcpAioAsyncConnection extends AsyncConnection {
             return;
         }
         this.writetime = System.currentTimeMillis();
-        channel.write(srcs, offset, length, writeTimeoutSeconds > 0 ? writeTimeoutSeconds : 60, TimeUnit.SECONDS, attachment, newHandler);
+        try {
+            channel.write(srcs, offset, length, writeTimeoutSeconds > 0 ? writeTimeoutSeconds : 60, TimeUnit.SECONDS, attachment, newHandler);
+        } catch (Exception e) {
+            newHandler.failed(e, attachment);
+        }
     }
 
     @Override