Startup.cs 6.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190
  1. using Admin.NET.Core;
  2. using AspNetCoreRateLimit;
  3. using Furion;
  4. using Furion.SpecificationDocument;
  5. using IGeekFan.AspNetCore.Knife4jUI;
  6. using Microsoft.AspNetCore.Builder;
  7. using Microsoft.AspNetCore.Hosting;
  8. using Microsoft.AspNetCore.HttpOverrides;
  9. using Microsoft.Extensions.DependencyInjection;
  10. using Microsoft.Extensions.Hosting;
  11. using Microsoft.Extensions.Logging;
  12. using NETCore.MailKit.Extensions;
  13. using Newtonsoft.Json;
  14. using Newtonsoft.Json.Serialization;
  15. using OnceMi.AspNetCore.OSS;
  16. using System;
  17. using Yitter.IdGenerator;
  18. namespace Admin.NET.Web.Core;
  19. public class Startup : AppStartup
  20. {
  21. public void ConfigureServices(IServiceCollection services)
  22. {
  23. // 配置选项
  24. services.AddProjectOptions();
  25. // SqlSugar
  26. services.AddSqlSugarSetup();
  27. // JWT
  28. services.AddJwt<JwtHandler>(enableGlobalAuthorize: true);
  29. // 允许跨域
  30. services.AddCorsAccessor();
  31. // 远程请求
  32. services.AddRemoteRequest();
  33. // 任务调度
  34. services.AddTaskScheduler();
  35. // 脱敏检测
  36. services.AddSensitiveDetection();
  37. // 结果拦截器
  38. services.AddMvcFilter<ResultFilter>();
  39. // 日志监听
  40. services.AddMonitorLogging();
  41. services.AddControllersWithViews()
  42. .AddAppLocalization()
  43. .AddNewtonsoftJson(options =>
  44. {
  45. options.SerializerSettings.ContractResolver = new CamelCasePropertyNamesContractResolver(); // 响应驼峰命名
  46. options.SerializerSettings.DateFormatString = "yyyy-MM-dd HH:mm:ss"; // 时间格式化
  47. options.SerializerSettings.ReferenceLoopHandling = ReferenceLoopHandling.Ignore; // 忽略循环引用
  48. // options.SerializerSettings.NullValueHandling = NullValueHandling.Ignore; // 忽略空值
  49. })
  50. .AddInjectWithUnifyResult<AdminResultProvider>();
  51. // 配置Nginx转发获取客户端真实IP
  52. // 注1:如果负载均衡不是在本机通过 Loopback 地址转发请求的,一定要加上options.KnownNetworks.Clear()和options.KnownProxies.Clear()
  53. // 注2:如果设置环境变量 ASPNETCORE_FORWARDEDHEADERS_ENABLED 为 True,则不需要下面的配置代码
  54. services.Configure<ForwardedHeadersOptions>(options =>
  55. {
  56. options.ForwardedHeaders = ForwardedHeaders.All;
  57. options.KnownNetworks.Clear();
  58. options.KnownProxies.Clear();
  59. });
  60. // 限流服务
  61. services.AddInMemoryRateLimiting();
  62. services.AddSingleton<IRateLimitConfiguration, RateLimitConfiguration>();
  63. // 事件总线
  64. services.AddEventBus(builder =>
  65. {
  66. // 订阅日志事件
  67. builder.AddSubscriber<LogEventSubscriber>();
  68. // 事件执行器(失败重试)
  69. builder.AddExecutor<RetryEventHandlerExecutor>();
  70. });
  71. // OSS对象存储(必须一个个赋值)
  72. var opt = App.GetOptions<OSSProviderOptions>();
  73. services.AddOSSService(opt.ProviderName, options =>
  74. {
  75. options.Provider = opt.Provider;
  76. options.Endpoint = opt.Endpoint;
  77. options.AccessKey = opt.AccessKey;
  78. options.SecretKey = opt.SecretKey;
  79. options.Region = opt.Region;
  80. options.IsEnableCache = opt.IsEnableCache;
  81. options.IsEnableHttps = opt.IsEnableHttps;
  82. });
  83. // 电子邮件
  84. services.AddMailKit(options =>
  85. {
  86. options.UseMailKit(App.GetOptions<EmailOptions>());
  87. });
  88. // Redis缓存
  89. services.AddCSRedisSetup();
  90. // 模板引擎
  91. services.AddViewEngine();
  92. // 即时通讯
  93. services.AddSignalR();
  94. // logo显示
  95. services.AddLogoDisplay();
  96. // 日志写入文件-消息、警告、错误
  97. Array.ForEach(new[] { LogLevel.Information, LogLevel.Warning, LogLevel.Error }, logLevel =>
  98. {
  99. services.AddFileLogging("logs/{0:yyyyMMdd}_{1}.log", options =>
  100. {
  101. options.FileNameRule = fileName => string.Format(fileName, DateTime.Now, logLevel.ToString()); // 每天创建一个文件
  102. options.WriteFilter = logMsg => logMsg.LogLevel == logLevel; // 日志级别
  103. options.FileSizeLimitBytes = 10 * 1024 * 1024; // 每个文件10M
  104. options.MaxRollingFiles = 30; // 只保留30个文件
  105. });
  106. });
  107. // 日志写入数据库
  108. services.AddDatabaseLogging<DbLoggingWriter>(options =>
  109. {
  110. options.MinimumLevel = LogLevel.Information;
  111. });
  112. // 设置雪花Id算法机器码
  113. YitIdHelper.SetIdGenerator(new IdGeneratorOptions
  114. {
  115. WorkerId = App.GetOptions<SnowIdOptions>().WorkerId
  116. });
  117. }
  118. public void Configure(IApplicationBuilder app, IWebHostEnvironment env)
  119. {
  120. if (env.IsDevelopment())
  121. {
  122. app.UseDeveloperExceptionPage();
  123. app.UseForwardedHeaders();
  124. }
  125. else
  126. {
  127. app.UseExceptionHandler("/Home/Error");
  128. app.UseForwardedHeaders();
  129. app.UseHsts();
  130. }
  131. // 添加状态码拦截中间件
  132. app.UseUnifyResultStatusCodes();
  133. // 配置多语言
  134. app.UseAppLocalization();
  135. // 启用HTTPS
  136. app.UseHttpsRedirection();
  137. app.UseStaticFiles();
  138. app.UseRouting();
  139. app.UseCorsAccessor();
  140. // 限流组件(在跨域之后)
  141. app.UseIpRateLimiting();
  142. app.UseClientRateLimiting();
  143. app.UseAuthentication();
  144. app.UseAuthorization();
  145. // 配置Swagger-Knife4UI(路由前缀一致代表独立,不同则代表共存)
  146. app.UseKnife4UI(options =>
  147. {
  148. options.RoutePrefix = "kapi";
  149. foreach (var groupInfo in SpecificationDocumentBuilder.GetOpenApiGroups())
  150. {
  151. options.SwaggerEndpoint("/" + groupInfo.RouteTemplate, groupInfo.Title);
  152. }
  153. });
  154. app.UseInject();
  155. app.UseEndpoints(endpoints =>
  156. {
  157. // 注册集线器
  158. endpoints.MapHubs();
  159. endpoints.MapControllerRoute(
  160. name: "default",
  161. pattern: "{controller=Home}/{action=Index}/{id?}");
  162. });
  163. }
  164. }