Startup.cs 7.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211
  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 System.IO;
  18. using Yitter.IdGenerator;
  19. namespace Admin.NET.Web.Core;
  20. public class Startup : AppStartup
  21. {
  22. public void ConfigureServices(IServiceCollection services)
  23. {
  24. // 配置选项
  25. services.AddProjectOptions();
  26. // 缓存注册
  27. services.AddCache();
  28. // SqlSugar
  29. services.AddSqlSugar();
  30. // JWT
  31. services.AddJwt<JwtHandler>(enableGlobalAuthorize: true);
  32. // 允许跨域
  33. services.AddCorsAccessor();
  34. // 远程请求
  35. services.AddRemoteRequest();
  36. // 任务调度
  37. services.AddTaskScheduler();
  38. // 脱敏检测
  39. services.AddSensitiveDetection();
  40. //// 结果拦截器
  41. //services.AddMvcFilter<ResultFilter>();
  42. // 日志监听
  43. services.AddMonitorLogging();
  44. services.AddControllersWithViews()
  45. .AddAppLocalization()
  46. .AddNewtonsoftJson(options =>
  47. {
  48. options.SerializerSettings.ContractResolver = new CamelCasePropertyNamesContractResolver(); // 首字母小写(驼峰样式)
  49. options.SerializerSettings.DateFormatString = "yyyy-MM-dd HH:mm:ss"; // 时间格式化
  50. options.SerializerSettings.ReferenceLoopHandling = ReferenceLoopHandling.Ignore; // 忽略循环引用
  51. // options.SerializerSettings.Converters.Add(new LongJsonConverter()); // long转string(防止js精度溢出) 超过16位开启
  52. options.SerializerSettings.NullValueHandling = NullValueHandling.Ignore; // 忽略空值
  53. })
  54. .AddInjectWithUnifyResult<AdminResultProvider>();
  55. // 第三方授权登录
  56. services.AddAuthentication()
  57. .AddWeixin(options =>
  58. {
  59. var opt = App.GetOptions<OAuthOptions>();
  60. options.ClientId = opt.Weixin.ClientId;
  61. options.ClientSecret = opt.Weixin.ClientSecret;
  62. });
  63. // ElasticSearch
  64. services.AddElasticSearch();
  65. // 配置Nginx转发获取客户端真实IP
  66. // 注1:如果负载均衡不是在本机通过 Loopback 地址转发请求的,一定要加上options.KnownNetworks.Clear()和options.KnownProxies.Clear()
  67. // 注2:如果设置环境变量 ASPNETCORE_FORWARDEDHEADERS_ENABLED 为 True,则不需要下面的配置代码
  68. services.Configure<ForwardedHeadersOptions>(options =>
  69. {
  70. options.ForwardedHeaders = ForwardedHeaders.All;
  71. options.KnownNetworks.Clear();
  72. options.KnownProxies.Clear();
  73. });
  74. // 限流服务
  75. services.AddInMemoryRateLimiting();
  76. services.AddSingleton<IRateLimitConfiguration, RateLimitConfiguration>();
  77. // 事件总线
  78. services.AddEventBus(options =>
  79. {
  80. // 不启用事件日志
  81. options.LogEnabled = false;
  82. // 事件执行器(失败重试)
  83. options.AddExecutor<RetryEventHandlerExecutor>();
  84. });
  85. // OSS对象存储(必须一个个赋值)
  86. var ossOpt = App.GetOptions<OSSProviderOptions>();
  87. services.AddOSSService(ossOpt.ProviderName, options =>
  88. {
  89. options.Provider = ossOpt.Provider;
  90. options.Endpoint = ossOpt.Endpoint;
  91. options.AccessKey = ossOpt.AccessKey;
  92. options.SecretKey = ossOpt.SecretKey;
  93. options.Region = ossOpt.Region;
  94. options.IsEnableCache = ossOpt.IsEnableCache;
  95. options.IsEnableHttps = ossOpt.IsEnableHttps;
  96. });
  97. // 电子邮件
  98. services.AddMailKit(options =>
  99. {
  100. options.UseMailKit(App.GetOptions<EmailOptions>());
  101. });
  102. // 模板引擎
  103. services.AddViewEngine();
  104. // 即时通讯
  105. services.AddSignalR();
  106. // logo显示
  107. services.AddLogoDisplay();
  108. // 日志记录
  109. if (App.GetConfig<bool>("Logging:File:Enabled")) // 日志写入文件
  110. {
  111. Array.ForEach(new[] { LogLevel.Information, LogLevel.Warning, LogLevel.Error }, logLevel =>
  112. {
  113. services.AddFileLogging(options =>
  114. {
  115. options.FileNameRule = fileName => string.Format(fileName, DateTime.Now, logLevel.ToString()); // 每天创建一个文件
  116. options.WriteFilter = logMsg => logMsg.LogLevel == logLevel; // 日志级别
  117. options.HandleWriteError = (writeError) => // 写入失败时启用备用文件
  118. {
  119. writeError.UseRollbackFileName(Path.GetFileNameWithoutExtension(writeError.CurrentFileName) + "-oops" + Path.GetExtension(writeError.CurrentFileName));
  120. };
  121. });
  122. });
  123. }
  124. if (App.GetConfig<bool>("Logging:Database:Enabled")) // 日志写入数据库
  125. {
  126. services.AddDatabaseLogging<DatabaseLoggingWriter>();
  127. }
  128. if (App.GetConfig<bool>("Logging:ElasticSearch:Enabled")) // 日志写入ElasticSearch
  129. {
  130. services.AddDatabaseLogging<ElasticSearchLoggingWriter>();
  131. }
  132. // 配置雪花Id算法机器码
  133. YitIdHelper.SetIdGenerator(new IdGeneratorOptions
  134. {
  135. WorkerId = App.GetOptions<SnowIdOptions>().WorkerId
  136. });
  137. }
  138. public void Configure(IApplicationBuilder app, IWebHostEnvironment env)
  139. {
  140. if (env.IsDevelopment())
  141. {
  142. app.UseDeveloperExceptionPage();
  143. app.UseForwardedHeaders();
  144. }
  145. else
  146. {
  147. app.UseExceptionHandler("/Home/Error");
  148. app.UseForwardedHeaders();
  149. app.UseHsts();
  150. }
  151. // 添加状态码拦截中间件
  152. app.UseUnifyResultStatusCodes();
  153. // 配置多语言
  154. app.UseAppLocalization();
  155. // 启用HTTPS
  156. app.UseHttpsRedirection();
  157. app.UseStaticFiles();
  158. app.UseRouting();
  159. app.UseCorsAccessor();
  160. // 限流组件(在跨域之后)
  161. app.UseIpRateLimiting();
  162. app.UseClientRateLimiting();
  163. app.UseAuthentication();
  164. app.UseAuthorization();
  165. // 配置Swagger-Knife4UI(路由前缀一致代表独立,不同则代表共存)
  166. app.UseKnife4UI(options =>
  167. {
  168. options.RoutePrefix = "kapi";
  169. foreach (var groupInfo in SpecificationDocumentBuilder.GetOpenApiGroups())
  170. {
  171. options.SwaggerEndpoint("/" + groupInfo.RouteTemplate, groupInfo.Title);
  172. }
  173. });
  174. app.UseInject();
  175. app.UseEndpoints(endpoints =>
  176. {
  177. // 注册集线器
  178. endpoints.MapHubs();
  179. endpoints.MapControllerRoute(
  180. name: "default",
  181. pattern: "{controller=Home}/{action=Index}/{id?}");
  182. });
  183. }
  184. }