Boonlive_RD_Web/Web_BLSKafka_Server_Prod
8
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: 更新 .gitignore 文件以排除 Redis 定阅的 obj 文件；优化 KafkaConsume 服务中的消费者启动逻辑

Browse Source
This commit is contained in:
徐
2026-02-09 15:22:05 +08:00
parent 5e921fab74
commit 02d6778e35
3 changed files with 8 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
.gitignore vendored
View File

@@ -90,3 +90,4 @@
/MyFaster /MyFaster
/MyFunctioncache /MyFunctioncache
/mypwsh /mypwsh
/Redis定阅/obj

2
BLWLogServer/BLWLogServer.csproj.user
View File

@@ -1,7 +1,7 @@
<?xml version="1.0" encoding="utf-8"?> <?xml version="1.0" encoding="utf-8"?>
<Project ToolsVersion="Current" xmlns="http://schemas.microsoft.com/developer/msbuild/2003"> <Project ToolsVersion="Current" xmlns="http://schemas.microsoft.com/developer/msbuild/2003">
<PropertyGroup> <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_SelectedScaffolderID>ApiControllerEmptyScaffolder</Controller_SelectedScaffolderID>
<Controller_SelectedScaffolderCategoryPath>root/Common/Api</Controller_SelectedScaffolderCategoryPath> <Controller_SelectedScaffolderCategoryPath>root/Common/Api</Controller_SelectedScaffolderCategoryPath>
</PropertyGroup> </PropertyGroup>

5
BLWLogServer/Services/KafkaConsume.cs
View File

@@ -29,17 +29,14 @@ namespace BLWLogServer.Services
private static Queue<long> _RCUOnLine = new(10); private static Queue<long> _RCUOnLine = new(10);
protected async override Task ExecuteAsync(CancellationToken stoppingToken) protected async override Task ExecuteAsync(CancellationToken stoppingToken)
{
await Task.Factory.StartNew(async () =>
{ {
var consumers = new List<Task>(); var consumers = new List<Task>();
for (int i = 0; i < 3; i++) for (int i = 0; i < 3; i++)
{ {
consumers.Add(Task.Run(() => StartConsumer(stoppingToken))); consumers.Add(StartConsumer(stoppingToken));
} }
await Task.WhenAll(consumers); await Task.WhenAll(consumers);
//await StartConsumer(stoppingToken); //await StartConsumer(stoppingToken);
}, TaskCreationOptions.LongRunning);
} }
private async Task StartConsumer(CancellationToken stoppingToken) private async Task StartConsumer(CancellationToken stoppingToken)
{ {