windows环境下QueueServerHosting占用内存过大 about jt808gateway HOT 4 CLOSED

var builder = WebApplication.CreateBuilder(args).Inject();

// 配置服务
builder.Services
    .AddJT808Configure()
    .AddWebApiClientTool(builder.Configuration)
    .AddGateway(builder.Configuration)
    .AddServerKafkaMsgProducer(builder.Configuration)
    .AddServerKafkaMsgReplyConsumer(builder.Configuration)
    .AddServerKafkaSessionProducer(builder.Configuration)
    .AddTcp()
    .AddUdp();

builder.Services.AddCors(options =>
                   options.AddPolicy("jt808", builder =>
                   builder.AllowAnyMethod()
                          .AllowAnyHeader()
                          .AllowCredentials()
                          .SetIsOriginAllowed(o => true)));

// 配置WebHost
builder.WebHost.ConfigureKestrel((context, options) =>
{
    var jT808Configuration = context.Configuration.GetSection(nameof(JT808Configuration)).Get<JT808Configuration>();
    options.ListenAnyIP(jT808Configuration.WebApiPort);
});

// 添加控制器
builder.Services.AddControllers().AddInject();

var app = builder.Build();
app.UseCors();
app.UseAuthorization();
app.UseInject();
app.MapControllers().RequireCors("jt808");

await app.RunAsync();


var builder = WebApplication.CreateBuilder(args).Inject();

var builder = WebApplication.CreateBuilder(args).Inject();
// 配置服务
builder.Services.AddJT808Configure()
            .AddClientKafka()
            .AddMsgConsumer(builder.Configuration)
            .AddMsgReplyProducer(builder.Configuration)
            .AddSessionConsumer(builder.Configuration)
            .AddReplyMessage<JT808QueueReplyMessageHandlerImpl>()
            .AddSessionNotice<JT808SessionNoticeServiceImpl>();



builder.Services.AddRemoteRequest();
builder.Services.AddHostedService<SendCommandJob>();
builder.Services.AddHostedService<AlarmMessageConsumerJob>();
// 添加控制器
builder.Services.AddControllers().AddInject();

var app = builder.Build();

app.UseInject();
app.MapControllers();

await app.RunAsync();