Net8将Serilog日记推送ES，附视频 - ToB企服应用市场:ToB评测及商务社交产业平台

using Autofac;
using Autofac.Extensions.DependencyInjection;
using Autofac.Extras.DynamicProxy;
using Microsoft.EntityFrameworkCore;
using SampleDemo.Yzh.Net.Logger;
using SampleDemo.Yzh.Net.Repository;
using SampleDemo.Yzh.Net.Service;
using SampleDemo.Yzh.Net.Core;
using Serilog;
using ILogger = Serilog.ILogger;
var builder = WebApplication.CreateBuilder(args);
// Config
builder.Services.AddSingleton(new AppSettings(builder.Configuration));
// Serilog
builder.Host.AddCustomLog();
// EF
builder.Services.AddDbContextPool<TestContext>
(o => o.UseSqlServer(builder.Configuration.GetConnectionString("NicoLocaldbStr"))
#if DEBUG
.EnableSensitiveDataLogging()
#endif
.UseLoggerFactory(LoggerFactory.Create(builder => builder.AddSerilog())
));
// Http Info
builder.Services.AddHttpContextAccessor();
// Auto Fac
builder.Host.UseServiceProviderFactory(new AutofacServiceProviderFactory());
builder.Host.ConfigureContainer<ContainerBuilder>(containerBuilder =>
{
// 注册AopDemo拦截器为单例模式
containerBuilder.RegisterType<AopDemo>().SingleInstance();
// InterceptedBy指定拦截器
containerBuilder.RegisterType<ValuesService>().As<IValuesService>().EnableInterfaceInterceptors().InterceptedBy(typeof(AopDemo));
// 或者在IValuesService 加标签 [Intercept(typeof(AopDemo))]
//containerBuilder.RegisterType<ValuesService>().As<IValuesService>().EnableInterfaceInterceptors();
//向 Autofac 容器注册 Log.Logger 这个已经存在的日志记录器实例，指定这个实例作为 ILogger 接口的实现，此ILogger为 Serilog的ILogger
//当应用程序中的组件通过依赖注入请求 ILogger 接口的实例时，它们会接收到 Log.Logger 这个单例对象
containerBuilder.RegisterInstance(Log.Logger).As<ILogger>();
});
builder.Services.AddControllers();
var app = builder.Build();
// Middleware
app.UseMiddleware<ResponseLoggingMiddleware>(); //返回客户端响应的日志记录
app.UseAuthorization();
app.MapControllers();
app.Run();

复制代码

builder.Services.AddDbContextPool<TestContext>
(o => o.UseSqlServer(builder.Configuration.GetConnectionString("NicoLocaldbStr"))
#if DEBUG
.EnableSensitiveDataLogging()
#endif
.UseLoggerFactory(LoggerFactory.Create(builder => builder.AddSerilog())
));

复制代码

public static class CustomLogger
{
public static IHostBuilder AddCustomLog(this IHostBuilder builder)
{
Log.Logger = new LoggerConfiguration()
.ReadFrom.Configuration(AppSettings.Configuration)
.Enrich.FromLogContext()
// 输出到控制台
.WriteToConsole()
// 输出到文件
.WriteToFile()
// 输出到Es
.WriteToElasticsearch()
.CreateLogger();
builder.UseSerilog();
return builder;
}
}

复制代码

public static class LoggerConfigurationExtensions
{
/// <summary>
/// 输出在控制台
/// </summary>
/// <param name="loggerConfiguration"></param>
/// <returns></returns>
public static LoggerConfiguration WriteToConsole(this LoggerConfiguration loggerConfiguration)
{
// 输出普通日志
loggerConfiguration = loggerConfiguration.WriteTo.Logger(lg =>
lg.FilterRemoveSqlLog().WriteTo.Console());
// 输出SQL
loggerConfiguration = loggerConfiguration.WriteTo.Logger(lg =>
lg.FilterSqlLog().WriteTo.Console());
return loggerConfiguration;
}
/// <summary>
/// 写入文件
/// </summary>
/// <param name="loggerConfiguration"></param>
/// <returns></returns>
public static LoggerConfiguration WriteToFile(this LoggerConfiguration loggerConfiguration)
{
// SQL语句写入
loggerConfiguration = loggerConfiguration.WriteTo.Logger(lg =>
lg.FilterSqlLog()
.WriteTo.Async(s => s.File(LogContextStatic.Combine(LogContextStatic.EFSql, @"EFSql.txt"), rollingInterval: RollingInterval.Day,
outputTemplate: LogContextStatic.FileMessageTemplate, retainedFileCountLimit: 31)));
// 非SQL写入
loggerConfiguration = loggerConfiguration.WriteTo.Logger(lg =>
lg.FilterRemoveSqlLog()
.WriteTo.Async(s => s.File(LogContextStatic.Combine(LogContextStatic.AuditLogs, @"AuditLog.txt"), rollingInterval: RollingInterval.Hour,
outputTemplate: LogContextStatic.FileMessageTemplate, retainedFileCountLimit: 31)));
return loggerConfiguration;
}
/// <summary>
/// 推送至 ES
/// </summary>
/// <param name="loggerConfiguration"></param>
/// <returns></returns>
public static LoggerConfiguration WriteToElasticsearch(this LoggerConfiguration loggerConfiguration)
{
var esUri = AppSettings.GetValue("ElasticConfiguration:Uri");
loggerConfiguration = loggerConfiguration.WriteTo.Elasticsearch(new ElasticsearchSinkOptions(
new Uri(esUri))
{
AutoRegisterTemplate = true,
IndexFormat = "nico-api-log-{0:yyyy.MM.dd}",
ModifyConnectionSettings = con => con.ServerCertificateValidationCallback((sender, certificate, chain, sslPolicyErrors) => true)
.BasicAuthentication(
AppSettings.GetValue("ElasticConfiguration:Es_UserName"),
AppSettings.GetValue("ElasticConfiguration:Es_Pwd"))
});
return loggerConfiguration;
}
/// <summary>
/// 过滤出 SQL语句的日志
/// </summary>
/// <param name="lc"></param>
/// <returns></returns>
public static LoggerConfiguration FilterSqlLog(this LoggerConfiguration lc)
{
return lc.Filter.ByIncludingOnly(e =>
e.Properties.ContainsKey("SourceContext") &&
e.Properties["SourceContext"].ToString().Contains("Microsoft.EntityFrameworkCore.Database.Command"));
}
/// <summary>
/// 过滤非 SQL语句的日志
/// </summary>
/// <param name="lc"></param>
/// <returns></returns>
public static LoggerConfiguration FilterRemoveSqlLog(this LoggerConfiguration lc)
{
return lc.Filter.ByExcluding(e =>
e.Properties.ContainsKey("SourceContext") &&
e.Properties["SourceContext"].ToString().Contains("Microsoft.EntityFrameworkCore.Database.Command"));
}
}

复制代码

docker network create elastic-net

复制代码

docker run --name es01 --net elastic -p 9200:9200 -p 9300:9300 -e "discovery.type=single-node" -t elasticsearch:8.14.3

复制代码

docker run --name kib01 --net elastic -p 5601:5601 kibana:8.14.3

复制代码

"ConnectionStrings": {
// SQL Server
"NicoLocaldbStr": "Data Source=localhost;Initial Catalog=nicolocaldb;User ID=sa;Password=MyStrongPwd!2#;Trust Server Certificate=True"
}

复制代码

-- SQL Server
CREATE TABLE TestEFTable (
Id INT PRIMARY KEY IDENTITY(1,1), -- Id 列为主键并设置为自增
Name NVARCHAR(255) NULL, -- Name 列，允许 NULL，使用 NVARCHAR 类型来支持 Unicode 字符
LastModifiedAt DATETIMEOFFSET NULL, -- LastModifiedAt 列，允许 NULL，使用 DATETIMEOFFSET 类型
LastModifiedBy INT NOT NULL -- LastModifiedBy 列，不允许 NULL
);

复制代码

"ElasticConfiguration": {
"Uri": "https://localhost:9200", // ES 地址
"Es_UserName": "elastic", // 账号
"Es_Pwd": "_*5O7P+5FKSV7nC_EDEE" // 密码
}

复制代码