From ce164d3047615e0f633152461b477f3950957b56 Mon Sep 17 00:00:00 2001
From: redkale <redkale@qq.com>
Date: Mon, 23 Oct 2023 23:09:50 +0800
Subject: [PATCH] keepAlive

---
 .../java/org/redkale/net/client/ClientCodec.java    | 13 ++++++++-----
 1 file changed, 8 insertions(+), 5 deletions(-)

diff --git a/src/main/java/org/redkale/net/client/ClientCodec.java b/src/main/java/org/redkale/net/client/ClientCodec.java
index b88b69aa3..e259ff199 100644
--- a/src/main/java/org/redkale/net/client/ClientCodec.java
+++ b/src/main/java/org/redkale/net/client/ClientCodec.java
@@ -73,6 +73,7 @@ public abstract class ClientCodec<R extends ClientRequest, P extends ClientResul
         if (!respResults.isEmpty()) { //存在解析结果
             connection.currRespIterator = null;
             readArray.clear();
+            boolean keepAlive = true;
             for (ClientResponse<R, P> cr : respResults) {
                 connection.doneResponseCounter.increment();
                 if (cr.isError()) {
@@ -89,15 +90,20 @@ public abstract class ClientCodec<R extends ClientRequest, P extends ClientResul
                             return;
                         }
                         responseComplete(false, respFuture, cr.message, cr.cause);
+                        if (cr.message != null && !cr.message.isKeepAlive()) {
+                            keepAlive = false;
+                        }
                     }
                     respPool.accept(cr);
                 }
             }
             respResults.clear();
-
+            if (!keepAlive) {
+                connection.dispose(null);
+            }
             if (buffer.hasRemaining()) { //还有响应数据包
                 decodeResponse(buffer);
-            } else { //队列都已处理完了
+            } else if (keepAlive) { //队列都已处理完了
                 buffer.clear();
                 channel.setReadBuffer(buffer);
                 channel.readRegister(this);
@@ -166,9 +172,6 @@ public abstract class ClientCodec<R extends ClientRequest, P extends ClientResul
                         Traces.removeTraceid();
                     });
                 }
-                if (!message.isKeepAlive()) {
-                    connection.dispose(null);
-                }
             } else { //异常
                 if (workThread == null) {
                     readThread.runWork(() -> {