diff --git a/src/main/java/org/redkale/net/AsyncConnection.java b/src/main/java/org/redkale/net/AsyncConnection.java
index f642f95a4..e60af3094 100644
--- a/src/main/java/org/redkale/net/AsyncConnection.java
+++ b/src/main/java/org/redkale/net/AsyncConnection.java
@@ -208,10 +208,10 @@ public abstract class AsyncConnection implements Channel, AutoCloseable {
     /**
      * 快速发送
      *
-     * @see org.redkale.net.AsyncNioConnection#pipelineWrite(org.redkale.net.PipelinePacket)
-     * @param packet  PipelinePacket
+     * @see org.redkale.net.AsyncNioConnection#pipelineWrite(org.redkale.net.PipelinePacket...)
+     * @param packets  PipelinePacket[]
      */
-    public abstract void pipelineWrite(PipelinePacket packet);
+    public abstract void pipelineWrite(PipelinePacket... packets);
 
     public abstract boolean isTCP();
 
diff --git a/src/main/java/org/redkale/net/AsyncNioConnection.java b/src/main/java/org/redkale/net/AsyncNioConnection.java
index 33d0255b5..4536d065b 100644
--- a/src/main/java/org/redkale/net/AsyncNioConnection.java
+++ b/src/main/java/org/redkale/net/AsyncNioConnection.java
@@ -158,7 +158,7 @@ abstract class AsyncNioConnection extends AsyncConnection {
     }
 
     @Override
-    public final void pipelineWrite(PipelinePacket packet) {
+    public final void pipelineWrite(PipelinePacket... packets) {
         if (pipelineWriteQueue == null) {
             pipelineLock.lock();
             try {
@@ -169,7 +169,9 @@ abstract class AsyncNioConnection extends AsyncConnection {
                 pipelineLock.unlock();
             }
         }
-        this.pipelineWriteQueue.offer(packet);
+        for (PipelinePacket packet : packets) {
+            this.pipelineWriteQueue.offer(packet);
+        }
         this.ioWriteThread.execute(this::pipelineDoWrite);
     }