Startup.cs 11 KB

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