From b332fa742cf71ed0ecbd3656caf2730d1a5d7f21 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E5=B0=8F=E8=82=A5=E7=BE=8A?= <1048382248@qq.com>
Date: Thu, 28 Nov 2024 11:48:40 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=20=E9=87=8D=E8=AF=95?=
 =?UTF-8?q?=E6=9C=BA=E5=88=B6=E5=90=8E=20=E5=A4=9A=E6=AC=A1=E6=8E=A5?=
 =?UTF-8?q?=E6=94=B6=E4=BB=BB=E5=8A=A1=E5=AF=BC=E8=87=B4=E5=86=85=E5=AD=98?=
 =?UTF-8?q?=E6=B3=84=E9=9C=B2?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 VideoAnalysisCore/Common/RedisExpand.cs | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/VideoAnalysisCore/Common/RedisExpand.cs b/VideoAnalysisCore/Common/RedisExpand.cs
index 615263a..63db622 100644
--- a/VideoAnalysisCore/Common/RedisExpand.cs
+++ b/VideoAnalysisCore/Common/RedisExpand.cs
@@ -230,14 +230,15 @@ namespace VideoAnalysisCore.Common
                 InsertChannel(lastEnum, oldTask);
                 return;
             }
-
+            if (Subscribe?.IsUnsubscribed == false)//排除重试机制后 多次接收任务导致内存泄露
+                return;
             Subscribe = Redis.SubscribeList(RedisExpandKey.ChannelKey, (taskId) =>
             {
                 if (taskId is null) return;
                 Subscribe?.Dispose();
                 //存储当前机器的任务
                 Redis.Set(RedisExpandKey.IDTask, taskId);
-                Console.WriteLine(DateTime.Now.ToString("HH:mm:ss") + "-> 接收到任务 " + taskId);
+                Console.WriteLine(DateTime.Now.ToString("HH:mm:ss") + "-------------> 接收到任务 " + taskId);
                 InsertChannel(RedisChannelEnum.DownloadFile, taskId);
             });