Startup.cs 8.4 KB

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