Startup.cs 9.3 KB

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