From f3f84bd5b39d303f1527df6d04208891182055e6 Mon Sep 17 00:00:00 2001
From: redkale <redkale@qq.com>
Date: Sun, 27 Oct 2024 11:38:17 +0800
Subject: [PATCH] pipelineWrite

---
 src/main/java/org/redkale/net/AsyncNioConnection.java        | 5 ++++-
 src/main/java/org/redkale/net/http/WebSocketUserAddress.java | 2 ++
 2 files changed, 6 insertions(+), 1 deletion(-)

diff --git a/src/main/java/org/redkale/net/AsyncNioConnection.java b/src/main/java/org/redkale/net/AsyncNioConnection.java
index 9db399ba7..dfae49ce5 100644
--- a/src/main/java/org/redkale/net/AsyncNioConnection.java
+++ b/src/main/java/org/redkale/net/AsyncNioConnection.java
@@ -169,10 +169,13 @@ abstract class AsyncNioConnection extends AsyncConnection {
                 pipelineLock.unlock();
             }
         }
+        boolean empty = this.pipelineWriteQueue.isEmpty();
         for (PipelinePacket packet : packets) {
             this.pipelineWriteQueue.offer(packet);
         }
-        this.ioWriteThread.execute(this::pipelineDoWrite);
+        if (empty) {
+            this.ioWriteThread.execute(this::pipelineDoWrite);
+        }
     }
 
     private void pipelineDoWrite() {
diff --git a/src/main/java/org/redkale/net/http/WebSocketUserAddress.java b/src/main/java/org/redkale/net/http/WebSocketUserAddress.java
index 8add73345..45137153e 100644
--- a/src/main/java/org/redkale/net/http/WebSocketUserAddress.java
+++ b/src/main/java/org/redkale/net/http/WebSocketUserAddress.java
@@ -9,6 +9,7 @@ import java.io.Serializable;
 import java.net.InetSocketAddress;
 import java.util.Collection;
 import org.redkale.convert.ConvertColumn;
+import org.redkale.convert.ConvertImpl;
 import org.redkale.convert.json.JsonConvert;
 
 /**
@@ -16,6 +17,7 @@ import org.redkale.convert.json.JsonConvert;
  *
  * @author zhangjx
  */
+@ConvertImpl(value = WebSocketUserAddress.SimpleWebSocketUserAddress.class)
 public interface WebSocketUserAddress {
 
     Serializable userid();