omega-gateway/Program.cs

using System.Net;
using System.Net.Sockets;
using System.Text.Json;
using Base;
using Common;
using Extensions;
using Filters;
using Infrastructure;
using Infrastructure.Model;
using Lycoris.Yarp.Nacos.Extensions;
using Microsoft.AspNetCore.Authorization;
using Microsoft.AspNetCore.Server.Kestrel.Core;
using Middleware;
using Nacos.AspNetCore.V2;
using Nacos.V2;
using Nacos.V2.DependencyInjection;
using Nacos.V2.Naming;
using Ocelot.DependencyInjection;
using Ocelot.Middleware;
using Ocelot.Provider.Nacos;
using SummerBoot.Core;
using Util;
using Yarp.ReverseProxy.Configuration;

ThreadPool.SetMinThreads(200, 200);
var builder = WebApplication.CreateBuilder(args);

// Add services to the container.

builder.Services.AddControllers();
// Learn more about configuring Swagger/OpenAPI at https://aka.ms/aspnetcore/swashbuckle
builder.Services.AddEndpointsApiExplorer();
//注入HttpContextAccessor
builder.Services.AddSingleton<IHttpContextAccessor, HttpContextAccessor>();
//IPRatelimit
// builder.Services.AddIPRate(builder.Configuration);
builder.Services.AddSession();
builder.Services.AddHttpContextAccessor();
// builder.Services.AddCors(option => option.AddPolicy("cors", policy => policy.AllowAnyHeader().AllowAnyMethod().AllowCredentials().SetIsOriginAllowed(_ => true)));
builder.Services.Configure<KestrelServerOptions>(x => x.AllowSynchronousIO = true).Configure<IISServerOptions>(x => x.AllowSynchronousIO = true);

string nacosIp = "localhost";
var host = Dns.GetHostEntry(Dns.GetHostName());
foreach (var ip in host.AddressList)
{
    if (ip.AddressFamily == AddressFamily.InterNetwork && !IPAddress.IsLoopback(ip))
    {
        nacosIp = ip.ToString();
    }
}

builder.Configuration["NacosConfig:Ip"] = nacosIp;
//配置中心
builder.Configuration.AddNacosV2Configuration(builder.Configuration.GetSection("NacosConfig"));
//服务注册
builder.Services.AddNacosAspNet(builder.Configuration, "NacosConfig");


//绑定整个对象到Model上
builder.Services.Configure<OptionsSetting>(builder.Configuration);
// builder.Configuration.AddJsonFile("iprate.json");
//配置文件
builder.Services.AddSingleton(new AppSettings(builder.Configuration));
//请求大小限制
builder.Services.AddRequestLimit(builder.Configuration);

//配置文件
builder.Services.AddSingleton(new AppSettings(builder.Configuration));
//app服务注册
builder.Services.AddAppService();

builder.Services.AddMvc(options =>
{
    options.Filters.Add(typeof(GlobalActionMonitor));//全局注册
    options.Filters.Add(typeof(AuthorizationFilter));
})
.AddJsonOptions(options =>
{
    //options.JsonSerializerOptions.NumberHandling = JsonNumberHandling.AllowReadingFromString | JsonNumberHandling.WriteAsString;
    options.JsonSerializerOptions.WriteIndented = true;
    options.JsonSerializerOptions.Converters.Add(new JsonConverterUtil.DateTimeConverter());
    options.JsonSerializerOptions.Converters.Add(new JsonConverterUtil.DateTimeNullConverter());
    options.JsonSerializerOptions.Converters.Add(new StringConverter());
    //PropertyNamingPolicy属性用于前端传过来的属性的格式策略，目前内置的仅有一种策略CamelCase
    options.JsonSerializerOptions.PropertyNamingPolicy = JsonNamingPolicy.CamelCase;
    //options.JsonSerializerOptions.PropertyNameCaseInsensitive = true;//属性可以忽略大小写格式，开启后性能会降低
});

builder.Services.AddSummerBoot();
builder.Services.AddSummerBootFeign();

var initRoutes  = Array.Empty<RouteConfig>();
var initClusters= Array.Empty<ClusterConfig>();
builder.Services.AddSingleton(new InMemoryConfigProvider(initRoutes, initClusters));
builder.Services.AddSingleton<IProxyConfigProvider>(sp =>
    sp.GetRequiredService<InMemoryConfigProvider>());

// 2. 把 Provider 喂给 YARP
builder.Services.AddReverseProxy();

// 注册REDIS 服务
var openRedis = builder.Configuration["RedisServer:open"];
if (openRedis == "1")
{
    RedisServer.Initalize();
}

builder.WebHost.ConfigureKestrel(o =>
{
    o.Limits.MaxRequestBodySize = 100 * 1024 * 1024; // 100 MB
});

builder.Services.AddHostedService<RefreshYarp>();

var app = builder.Build();
InternalApp.ServiceProvider = app.Services;
InternalApp.Configuration = builder.Configuration;
InternalApp.WebHostEnvironment = app.Environment;
//初始化db
// builder.Services.AddDb(app.Environment);
var workId = builder.Configuration["workId"].ParseToInt();
if (app.Environment.IsDevelopment())
{
    workId += 1;
}
SnowFlakeSingle.WorkId = workId;

//使用全局异常中间件
app.UseMiddleware<GlobalExceptionMiddleware>();

app.Use(next => new RequestDelegate(
    async context =>
    {
        context.Request.EnableBuffering();
        await next(context);
    }
));

// Configure the HTTP request pipeline.
if (app.Environment.IsDevelopment())
{
}

app.UseCors();

app.UseHttpsRedirection();

app.UseAuthorization();

app.MapControllerRoute(
    name: "default",
    pattern: "{controller=Home}/{action=Index}/{id?}");

app.MapControllers();

// app.Urls.Add("http://*:8000");

// app.UseOcelot().Wait(); // 使用Ocelot中间件
// app.MapGet("/debug-yarp", (IProxyConfigProvider p) =>
// {
//     var cfg = p.GetConfig();
//     return Results.Json(new
//     {
//         RoutesCount = cfg.Routes.Count,
//         ClustersCount = cfg.Clusters.Count,
//         FirstRoute = cfg.Routes.FirstOrDefault(),
//         FirstCluster = cfg.Clusters.FirstOrDefault()
//     });
// });
// app.MapGet("/debug-proxy-route", (HttpContext ctx, IProxyConfigProvider prov) =>
// {
//     var route = prov.GetConfig().Routes.FirstOrDefault(r =>
//         r.Match.Path == "/noauth/api/{**catch-all}");
//     return Results.Json(route);
// });
app.MapGet("/", (HttpContext ctx, IProxyConfigProvider prov) =>
{
    return Results.Content("OmegaES");
});
app.MapReverseProxy();
app.UseMiddleware<RefererMiddleware>();

app.Run("http://*:8000");