@ -1,376 +1,60 @@
using System ;
using System.Collections.Generic ;
using System.IO ;
using System.Linq ;
using System.Text ;
using System.Threading.Tasks ;
using Hangfire ;
using Hangfire.MySql ;
using Lion.AbpPro.Blazor.Layout.AntDesignTheme ;
using Lion.AbpPro.CAP ;
using Lion.AbpPro.ConfigurationOptions ;
using Lion.AbpPro.Blazor.Layout.AntDesignTheme ;
using Lion.AbpPro.EntityFrameworkCore ;
using Lion.AbpPro.Extensions ;
using Lion.AbpPro.MultiTenancy ;
using Lion.AbpPro.Swaggers ;
using Lion.AbpPro.Web.Blazor.Server.Data ;
using LionAbpPro.Extensions.Filters ;
using Microsoft.AspNetCore.Authentication.JwtBearer ;
using Microsoft.AspNetCore.Builder ;
using Microsoft.AspNetCore.DataProtection ;
using Microsoft.Extensions.Configuration ;
using Microsoft.Extensions.DependencyInjection ;
using Microsoft.Extensions.Hosting ;
using Microsoft.IdentityModel.Tokens ;
using Microsoft.OpenApi.Models ;
using Savorboard.CAP.InMemoryMessageQueue ;
using Serilog ;
using StackExchange.Redis ;
using Swashbuckle.AspNetCore.SwaggerUI ;
using Volo.Abp ;
using Volo.Abp.Account ;
using Volo.Abp.Account.Web ;
using Volo.Abp.AspNetCore.Authentication.JwtBearer ;
using Volo.Abp.AspNetCore.Components.Server.Theming ;
using Volo.Abp.AspNetCore.Mvc ;
using Volo.Abp.AspNetCore.Mvc.UI.Theme.Basic ;
using Volo.Abp.AspNetCore.Serilog ;
using Volo.Abp.Autofac ;
using Volo.Abp.BackgroundJobs ;
using Volo.Abp.BackgroundJobs.Hangfire ;
using Volo.Abp.Caching ;
using Volo.Abp.Caching.StackExchangeRedis ;
using Volo.Abp.Modularity ;
namespace Lion.AbpPro.Web.Blazor.Server
{
[ DependsOn ( typeof ( AbpAutofacModule ) ,
typeof ( AbpAspNetCoreSerilogModule ) ,
typeof ( AbpProBlazorLayoutAntDesignThemeModule ) ,
typeof ( AbpProApplicationModule ) ,
typeof ( AbpProHttpApiModule ) ,
typeof ( AbpProEntityFrameworkCoreModule ) ,
typeof ( AbpAccountWebModule ) ,
typeof ( AbpAspNetCoreSerilogModule ) ,
typeof ( AbpAutofacModule ) ,
typeof ( AbpBackgroundJobsHangfireModule ) ,
typeof ( AbpProAbpCapModule ) ,
typeof ( SharedHostingMicroserviceModule ) ,
typeof ( AbpCachingStackExchangeRedisModule ) ,
typeof ( AbpAspNetCoreAuthenticationJwtBearerModule ) ,
typeof ( AbpAspNetCoreComponentsServerThemingModule ) ) ]
typeof ( AbpAspNetCoreMvcUiBasicThemeModule ) ,
typeof ( AbpProBlazorLayoutAntDesignThemeModule )
) ]
public class AbpProWebBlazorServerModule : AbpModule
{
public override void ConfigureServices ( ServiceConfigurationContext context )
{
var configuration = context . Services . GetConfiguration ( ) ;
ConfigureCache ( context ) ;
ConfigureSwaggerServices ( context , configuration ) ;
ConfigureOptions ( context ) ;
ConfigureJwtAuthentication ( context , configuration ) ;
ConfigureHangfireMysql ( context ) ;
ConfigurationCap ( context ) ;
ConfigurationStsHttpClient ( context ) ;
ConfigurationMiniProfiler ( context ) ;
context . Services . AddRazorPages ( ) ;
context . Services . AddServerSideBlazor ( ) ;
context . Services . AddSingleton < WeatherForecastService > ( ) ;
}
public override void OnApplicationInitialization ( ApplicationInitializationContext context )
{
var env = context . GetEnvironment ( ) ;
var app = context . GetApplicationBuilder ( ) ;
var configuration = context . GetConfiguration ( ) ;
app . UseAbpRequestLocalization ( ) ;
app . UseCorrelationId ( ) ;
app . UseStaticFiles ( ) ;
app . UseMiniProfiler ( ) ;
app . UseRouting ( ) ;
app . UseCors ( AbpProWebBlazorServerConsts . DefaultCorsPolicyName ) ;
app . UseAuthentication ( ) ;
if ( MultiTenancyConsts . IsEnabled )
{
app . UseMultiTenancy ( ) ;
}
app . UseAuthorization ( ) ;
app . UseSwagger ( ) ;
app . UseAbpSwaggerUI ( options = >
{
options . SwaggerEndpoint ( "/swagger/AbpPro/swagger.json" , "AbpPro API" ) ;
options . DocExpansion ( DocExpansion . None ) ;
options . DefaultModelsExpandDepth ( - 1 ) ;
} ) ;
app . UseAuditing ( ) ;
app . UseAbpSerilogEnrichers ( ) ;
app . UseSerilogRequestLogging ( opts = >
{
opts . EnrichDiagnosticContext = SerilogToEsExtensions . EnrichFromRequest ;
} ) ;
app . UseUnitOfWork ( ) ;
app . UseConfiguredEndpoints ( endpoints = > { endpoints . MapHealthChecks ( "/health" ) ; } ) ;
app . UseHangfireDashboard ( "/hangfire" , new DashboardOptions ( )
{
Authorization = new [ ] { new CustomHangfireAuthorizeFilter ( ) } ,
IgnoreAntiforgeryToken = true
} ) ;
if ( configuration . GetValue < bool > ( "Consul:Enabled" , false ) )
{
app . UseConsul ( ) ;
}
}
private void ConfigureHangfireMysql ( ServiceConfigurationContext context )
{
Configure < AbpBackgroundJobOptions > ( options = >
{
options . IsJobExecutionEnabled = true ;
} ) ;
context . Services . AddHangfire ( config = >
{
config . UseStorage ( new MySqlStorage (
context . Services . GetConfiguration ( ) . GetConnectionString ( "Default" ) ,
new MySqlStorageOptions ( )
{
//CommandBatchMaxTimeout = TimeSpan.FromMinutes(5),
//SlidingInvisibilityTimeout = TimeSpan.FromMinutes(5),
//QueuePollInterval = TimeSpan.Zero,
//UseRecommendedIsolationLevel = true,
//DisableGlobalLocks = true
} ) ) ;
} ) ;
}
/// <summary>
/// 配置MiniProfiler
/// </summary>
/// <param name="context"></param>
private void ConfigurationMiniProfiler ( ServiceConfigurationContext context )
if ( env . IsDevelopment ( ) )
{
context . Services . AddMiniProfiler ( options = > options . RouteBasePath = "/profiler" )
. AddEntityFramework ( ) ;
}
/// <summary>
/// 配置JWT
/// </summary>
/// <param name="context"></param>
/// <param name="configuration"></param>
private void ConfigureJwtAuthentication ( ServiceConfigurationContext context ,
IConfiguration configuration )
{
context . Services . AddAuthentication ( options = >
{
options . DefaultAuthenticateScheme = JwtBearerDefaults . AuthenticationScheme ;
options . DefaultChallengeScheme = JwtBearerDefaults . AuthenticationScheme ;
} )
. AddJwtBearer ( options = >
{
options . TokenValidationParameters =
new Microsoft . IdentityModel . Tokens . TokenValidationParameters ( )
{
// 是否开启签名认证
ValidateIssuerSigningKey = true ,
ValidateIssuer = true ,
ValidateAudience = true ,
ValidateLifetime = true ,
//ClockSkew = TimeSpan.Zero,
ValidIssuer = configuration [ "Jwt:Issuer" ] ,
ValidAudience = configuration [ "Jwt:Audience" ] ,
IssuerSigningKey =
new SymmetricSecurityKey (
Encoding . ASCII . GetBytes ( configuration [ "Jwt:SecurityKey" ] ) )
} ;
options . Events = new JwtBearerEvents
{
OnMessageReceived = currentContext = >
{
var path = currentContext . HttpContext . Request . Path ;
if ( path . StartsWithSegments ( "/login" ) )
{
return Task . CompletedTask ;
}
var accessToken =
currentContext . Request . Query [ "access_token" ] . FirstOrDefault ( ) ? ?
currentContext . Request . Cookies [
AbpProWebBlazorServerConsts . DefaultCookieName ] ;
if ( accessToken . IsNullOrWhiteSpace ( ) )
{
return Task . CompletedTask ;
}
if ( path . StartsWithSegments ( "/signalr" ) )
{
currentContext . Token = accessToken ;
}
currentContext . Request . Headers . Remove ( "Authorization" ) ;
currentContext . Request . Headers . Add ( "Authorization" ,
$"Bearer {accessToken}" ) ;
// 如果请求来自hangfire 或者cap
if ( path . ToString ( ) . StartsWith ( "/hangfire" ) | |
path . ToString ( ) . StartsWith ( "/cap" ) )
{
// currentContext.HttpContext.Response.Headers.Remove(
// "X-Frame-Options");
currentContext . Token = accessToken ;
}
return Task . CompletedTask ;
app . UseDeveloperExceptionPage ( ) ;
}
} ;
} ) ;
}
/// <summary>
/// 配置options
/// </summary>
/// <param name="context"></param>
private void ConfigureOptions ( ServiceConfigurationContext context )
{
context . Services . Configure < JwtOptions > ( context . Services . GetConfiguration ( )
. GetSection ( "Jwt" ) ) ;
}
/// <summary>
/// Redis缓存
/// </summary>
private void ConfigureCache ( ServiceConfigurationContext context )
{
Configure < AbpDistributedCacheOptions > (
options = > { options . KeyPrefix = "AbpPro:" ; } ) ;
var configuration = context . Services . GetConfiguration ( ) ;
var redis = ConnectionMultiplexer . Connect ( configuration [ "Redis:Configuration" ] ) ;
context . Services
. AddDataProtection ( )
. PersistKeysToStackExchangeRedis ( redis , "AbpPro-Protection-Keys" ) ;
}
private void ConfigurationStsHttpClient ( ServiceConfigurationContext context )
{
context . Services . AddHttpClient ( context . Services . GetConfiguration ( ) . GetSection ( "HttpClient:Sts:Name" ) . Value ,
options = >
{
options . BaseAddress =
new Uri ( context . Services . GetConfiguration ( ) . GetSection ( "HttpClient:Sts:Url" )
. Value ) ;
} ) ;
}
private void ConfigureConventionalControllers ( )
{
Configure < AbpAspNetCoreMvcOptions > ( options = >
{
options . ConventionalControllers . Create ( typeof ( AbpProApplicationModule )
. Assembly ) ;
} ) ;
}
private static void ConfigureSwaggerServices ( ServiceConfigurationContext context ,
IConfiguration configuration )
{
context . Services . AddSwaggerGen (
options = >
{
options . SwaggerDoc ( "AbpPro" ,
new OpenApiInfo { Title = "LionAbpPro API" , Version = "v1" } ) ;
options . DocInclusionPredicate ( ( docName , description ) = > true ) ;
//TODO
// options.EnableAnnotations(); // 启用注解
options . DocumentFilter < HiddenAbpDefaultApiFilter > ( ) ;
options . SchemaFilter < EnumSchemaFilter > ( ) ;
// 加载所有xml注释，这里会导致swagger加载有点缓慢
var xmls = Directory . GetFiles ( AppContext . BaseDirectory , "*.xml" ) ;
foreach ( var xml in xmls )
{
options . IncludeXmlComments ( xml , true ) ;
}
options . AddSecurityDefinition ( JwtBearerDefaults . AuthenticationScheme ,
new OpenApiSecurityScheme ( )
{
Description = "直接在下框输入JWT生成的Token" ,
Name = "Authorization" ,
In = ParameterLocation . Header ,
Type = SecuritySchemeType . Http ,
Scheme = JwtBearerDefaults . AuthenticationScheme ,
BearerFormat = "JWT"
} ) ;
options . AddSecurityRequirement ( new OpenApiSecurityRequirement
{
{
new OpenApiSecurityScheme
{
Reference = new OpenApiReference
{
Type = ReferenceType . SecurityScheme , Id = "Bearer"
}
} ,
new List < string > ( )
}
} ) ;
options . AddSecurityDefinition ( "ApiKey" , new OpenApiSecurityScheme ( )
{
Type = SecuritySchemeType . ApiKey ,
In = ParameterLocation . Header ,
Name = "Accept-Language" ,
Description = "多语言设置，系统预设语言有zh-Hans、en，默认为zh-Hans"
} ) ;
options . AddSecurityRequirement ( new OpenApiSecurityRequirement
{
{
new OpenApiSecurityScheme
else
{
Reference = new OpenApiReference
{ Type = ReferenceType . SecurityScheme , Id = "ApiKey" }
} ,
new string [ ] { }
}
} ) ;
} ) ;
app . UseExceptionHandler ( "/Error" ) ;
}
app . UseStaticFiles ( ) ;
private void ConfigurationCap ( ServiceConfigurationContext context )
{
var configuration = context . Services . GetConfiguration ( ) ;
var enabled = configuration . GetValue < bool > ( "Cap:Enabled" , false ) ;
if ( enabled )
{
context . AddAbpCap ( capOptions = >
{
capOptions . UseEntityFramework < AbpProDbContext > ( ) ;
capOptions . UseRabbitMQ ( option = >
{
option . HostName = configuration . GetValue < string > ( "Cap:RabbitMq:HostName" ) ;
option . UserName = configuration . GetValue < string > ( "Cap:RabbitMq:UserName" ) ;
option . Password = configuration . GetValue < string > ( "Cap:RabbitMq:Password" ) ;
} ) ;
var hostingEnvironment = context . Services . GetHostingEnvironment ( ) ;
bool auth = ! hostingEnvironment . IsDevelopment ( ) ;
capOptions . UseDashboard ( options = > { options . UseAuth = auth ; } ) ;
} ) ;
}
else
{
context . AddAbpCap ( capOptions = >
app . UseRouting ( ) ;
// app.MapBlazorHub();
// app.MapFallbackToPage("/_Host");
app . UseEndpoints ( endpoints = >
{
capOptions . UseInMemoryStorage ( ) ;
capOptions . UseInMemoryMessageQueue ( ) ;
var hostingEnvironment = context . Services . GetHostingEnvironment ( ) ;
bool auth = ! hostingEnvironment . IsDevelopment ( ) ;
capOptions . UseDashboard ( options = > { options . UseAuth = auth ; } ) ;
endpoints . MapBlazorHub ( ) ;
endpoints . MapFallbackToPage ( "/_Host" ) ;
} ) ;
}
}
}
}
王军
4 years ago