From 9c55d4e250acfebc57c8e65f52b5323752d6619a Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=99=BA=E8=83=BD=E5=A4=A7=E7=9F=B3=E5=A4=B4?= Date: Fri, 10 Jan 2025 01:33:42 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BD=BF=E7=94=A8=E7=BC=93=E5=86=B2=E6=B5=81Bu?= =?UTF-8?q?fferedStream=E5=8C=85=E8=A3=85=E7=BD=91=E7=BB=9C=E6=B5=81?= =?UTF-8?q?=EF=BC=8C=E5=8A=A0=E9=80=9F=E5=93=8D=E5=BA=94=E6=95=B0=E6=8D=AE?= =?UTF-8?q?=E8=AF=BB=E5=8F=96=E5=88=86=E6=9E=90=E3=80=82=E5=8E=8B=E6=B5=8B?= =?UTF-8?q?=E5=B3=B0=E5=80=BC315=E4=B8=87=E6=AF=8F=E7=A7=92=EF=BC=8C?= =?UTF-8?q?=E6=89=B9=E5=88=A0=E9=99=A4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- NewLife.Redis/RedisClient.cs | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/NewLife.Redis/RedisClient.cs b/NewLife.Redis/RedisClient.cs index 5ad5ecf..21746ab 100644 --- a/NewLife.Redis/RedisClient.cs +++ b/NewLife.Redis/RedisClient.cs @@ -309,12 +309,14 @@ public class RedisClient : DisposeBase /// protected virtual IList GetResponse(Stream ns, Int32 count) { + var ms = new BufferedStream(ns); + Char header; var buf = Pool.Shared.Rent(1); try { // 取巧进行异步操作,只要异步读取到第一个字节,后续同步读取 - var n = ns.Read(buf, 0, 1); + var n = ms.Read(buf, 0, 1); if (n <= 0) return []; header = (Char)buf[0]; @@ -324,7 +326,7 @@ public class RedisClient : DisposeBase Pool.Shared.Return(buf); } - return ParseResponse(ns, count, header); + return ParseResponse(ms, count, header); } /// 异步接收响应