From 02d6778e35a2faa54a4b43d488e402c5442ed2d0 Mon Sep 17 00:00:00 2001
From: XuJiacheng <xujiacheng@blw.com>
Date: Mon, 9 Feb 2026 15:22:05 +0800
Subject: [PATCH] =?UTF-8?q?fix:=20=E6=9B=B4=E6=96=B0=20.gitignore=20?=
 =?UTF-8?q?=E6=96=87=E4=BB=B6=E4=BB=A5=E6=8E=92=E9=99=A4=20Redis=20?=
 =?UTF-8?q?=E5=AE=9A=E9=98=85=E7=9A=84=20obj=20=E6=96=87=E4=BB=B6=EF=BC=9B?=
 =?UTF-8?q?=E4=BC=98=E5=8C=96=20KafkaConsume=20=E6=9C=8D=E5=8A=A1=E4=B8=AD?=
 =?UTF-8?q?=E7=9A=84=E6=B6=88=E8=B4=B9=E8=80=85=E5=90=AF=E5=8A=A8=E9=80=BB?=
 =?UTF-8?q?=E8=BE=91?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .gitignore                            |  1 +
 BLWLogServer/BLWLogServer.csproj.user |  2 +-
 BLWLogServer/Services/KafkaConsume.cs | 15 ++++++---------
 3 files changed, 8 insertions(+), 10 deletions(-)

diff --git a/.gitignore b/.gitignore
index 0e32ff0..4472a76 100644
--- a/.gitignore
+++ b/.gitignore
@@ -90,3 +90,4 @@
 /MyFaster
 /MyFunctioncache
 /mypwsh
+/Redis定阅/obj
diff --git a/BLWLogServer/BLWLogServer.csproj.user b/BLWLogServer/BLWLogServer.csproj.user
index 4418a07..2add57c 100644
--- a/BLWLogServer/BLWLogServer.csproj.user
+++ b/BLWLogServer/BLWLogServer.csproj.user
@@ -1,7 +1,7 @@
 <?xml version="1.0" encoding="utf-8"?>
 <Project ToolsVersion="Current" xmlns="http://schemas.microsoft.com/developer/msbuild/2003">
   <PropertyGroup>
-    <NameOfLastUsedPublishProfile>E:\tian\chongxin\NewGit\Web_BLSKafka_Server_Prod\BLWLogServer\Properties\PublishProfiles\FolderProfile.pubxml</NameOfLastUsedPublishProfile>
+    <NameOfLastUsedPublishProfile>FolderProfile</NameOfLastUsedPublishProfile>
     <Controller_SelectedScaffolderID>ApiControllerEmptyScaffolder</Controller_SelectedScaffolderID>
     <Controller_SelectedScaffolderCategoryPath>root/Common/Api</Controller_SelectedScaffolderCategoryPath>
   </PropertyGroup>
diff --git a/BLWLogServer/Services/KafkaConsume.cs b/BLWLogServer/Services/KafkaConsume.cs
index 15cd3ac..c161750 100644
--- a/BLWLogServer/Services/KafkaConsume.cs
+++ b/BLWLogServer/Services/KafkaConsume.cs
@@ -30,16 +30,13 @@ namespace BLWLogServer.Services
 
         protected async override Task ExecuteAsync(CancellationToken stoppingToken)
         {
-            await Task.Factory.StartNew(async () =>
+            var consumers = new List<Task>();
+            for (int i = 0; i < 3; i++)
             {
-                var consumers = new List<Task>();
-                for (int i = 0; i < 3; i++)
-                {
-                    consumers.Add(Task.Run(() => StartConsumer(stoppingToken)));
-                }
-                await Task.WhenAll(consumers);
-                //await StartConsumer(stoppingToken);
-            }, TaskCreationOptions.LongRunning);
+                consumers.Add(StartConsumer(stoppingToken));
+            }
+            await Task.WhenAll(consumers);
+            //await StartConsumer(stoppingToken);
         }
         private async Task StartConsumer(CancellationToken stoppingToken)
         {