EF Core3.0+ 通过拦截器实现读写分离与SQL日志记录
前言
本文主要是讲解EF Core3.0+ 通过拦截器实现读写分离与SQL日志记录
注意拦截器只有EF Core3.0+ 支持,2.1请考虑上下文工厂的形式实现.
说点题外话..
一晃又大半年没更新技术博客..唉,去年一年发生了太多事情..博主真的 一言难尽..
有兴趣的可以去看看:记录一下,也许是转折,也许是结束,也许是新希望的一年
正文
1.通过拦截器实现读写分离
先讲一下本文实现的方式吧
SQL 通过数据库本身的功能 实现主从备份 大概原理如图:
EF Core在查询的时候通过DbCommandInterceptor 拦截器(PS:这个功能在EF6.0+中也实现了)来拦截对数据库的访问,从而切换主从数据库
下面直接上代码吧
首先我们创建一个类 继承DbCommandInterceptor:
public class DbMasterSlaveCommandInterceptor : DbCommandInterceptor
{private string _masterConnectionString;private string _slaveConnectionString;public DbMasterSlaveCommandInterceptor(string masterConnectionString, string slaveConnectionString){_masterConnectionString = masterConnectionString;_slaveConnectionString = slaveConnectionString;}
}
通过构造函数传递主库连接地址与从库地址(可有多个 通过"|"分割)
添加一个随机分配从表读取连接的方法(PS:这里只是demo所以很简陋的随机,如果正式要用,应包含权重判断,定时心跳从库连接情况,请自行修改):
/// <summary>
/// 通过随机数分配获取多个从库/// </summary>/// <returns></returns>private string GetSlaveConnectionString(){var readArr = _slaveConnectionString.Split(new char[] { '|' }, StringSplitOptions.RemoveEmptyEntries);var resultConn = string.Empty;if (readArr != null && readArr.Any()){resultConn = readArr[Convert.ToInt32(Math.Floor((double)new Random().Next(0, readArr.Length)))];}return resultConn;}
添加判断是否主从操作连接方法:
private void UpdateToSlave(DbCommand command)
{//判断是否配置了主从分离if (!string.IsNullOrWhiteSpace(GetSlaveConnectionString()))//如果配置了读写分离,就进入判断{//判断是否为插入语句(EF 插入语句会通过Reader执行并查询主键),否则进入if (command.CommandText.ToLower().StartsWith("insert", StringComparison.InvariantCultureIgnoreCase) == false){// 判断当前会话是否处于分布式事务中bool isDistributedTran = Transaction.Current != null &&Transaction.Current.TransactionInformation.Status !=TransactionStatus.Committed;//判断该 context 是否处于普通数据库事务中bool isDbTran = command.Transaction != null;//如果不处于事务中,则执行从服务器查询if (!isDbTran && !isDistributedTran){command.Connection.Close();command.Connection.ConnectionString = GetSlaveConnectionString();command.Connection.Open();}}}}
重载DbCommandInterceptor当中的拦截方法,代码如下:
//如果是写入,则正常执行public override InterceptionResult<int> NonQueryExecuting(DbCommand command, CommandEventData eventData, InterceptionResult<int> result){return base.NonQueryExecuting(command, eventData, result);}public override Task<InterceptionResult<int>> NonQueryExecutingAsync(DbCommand command, CommandEventData eventData, InterceptionResult<int> result, CancellationToken cancellationToken = default){return base.NonQueryExecutingAsync(command, eventData, result, cancellationToken);}public override InterceptionResult<DbDataReader> ReaderExecuting(DbCommand command, CommandEventData eventData, InterceptionResult<DbDataReader> result){this.UpdateToSlave(command);return base.ReaderExecuting(command, eventData, result);}public override Task<InterceptionResult<DbDataReader>> ReaderExecutingAsync(DbCommand command, CommandEventData eventData, InterceptionResult<DbDataReader> result, CancellationToken cancellationToken = default){this.UpdateToSlave(command);return base.ReaderExecutingAsync(command, eventData, result, cancellationToken);}public override InterceptionResult<object> ScalarExecuting(DbCommand command, CommandEventData eventData, InterceptionResult<object> result){this.UpdateToSlave(command);return base.ScalarExecuting(command, eventData, result);}public override Task<InterceptionResult<object>> ScalarExecutingAsync(DbCommand command, CommandEventData eventData, InterceptionResult<object> result, CancellationToken cancellationToken = default){this.UpdateToSlave(command);return base.ScalarExecutingAsync(command, eventData, result, cancellationToken);}
最后在EF core的上下文中注入拦截器(PS:我这里使用的Autofac模块注入):
builder.Register(c =>{var optionsBuilder = new DbContextOptionsBuilder<TestEFContext>();//注入拦截器optionsBuilder.AddInterceptors(new DbMasterSlaveCommandInterceptor(WriteConnect, ReadConnect));//MaxBatchSize 处理批量操作BUGoptionsBuilder.UseMysql(WriteConnect, b=>b.MaxBatchSize(1));return optionsBuilder.Options;}).As<DbContextOptions<TestEFContex>>().SingleInstance();
这样就实现了通过拦截器实现读写分离.
2.通过拦截器实现SQL日志记录
同理,我们可以通过拦截器实现EF Core SQL语句的记录与调试
首先我们创建一个新的拦截器DBlogCommandInterceptor 如下:
public class DBlogCommandInterceptor : DbCommandInterceptor{//创建一个队列记录SQL执行时间static readonly ConcurrentDictionary<DbCommand, DateTime> MStartTime = new ConcurrentDictionary<DbCommand, DateTime>();private ILogger<DBlogCommandInterceptor> _logger { get; set; }//通过构造函数注入日志public DBlogCommandInterceptor(ILogger<DBlogCommandInterceptor> Logger){_logger = Logger;}
}
创建2个私有的方法,一个记录执行开始时间,一个记录SQL
//记录SQL开始执行的时间 private void OnStart(DbCommand command){MStartTime.TryAdd(command, DateTime.Now);}//通过_logger输出日志private void Log(DbCommand command){DateTime startTime;TimeSpan duration;//得到此command的开始时间MStartTime.TryRemove(command, out startTime);if (startTime != default(DateTime)){duration = DateTime.Now - startTime;}else{duration = TimeSpan.Zero;}var parameters = new StringBuilder();//循环获取执行语句的参数值foreach (DbParameter param in command.Parameters){parameters.AppendLine(param.ParameterName + " " + param.DbType + " = " + param.Value);}_logger.LogInformation("{starttime}开始执行SQL语句:{sql},参数:{canshu},执行时间{readtime}",startTime.ToString(), command.CommandText, parameters.ToString(), duration.TotalSeconds);}
最后重载拦截器的方法:
public override InterceptionResult<int> NonQueryExecuting(DbCommand command, CommandEventData eventData, InterceptionResult<int> result){OnStart(command);return base.NonQueryExecuting(command, eventData, result);}public override Task<InterceptionResult<int>> NonQueryExecutingAsync(DbCommand command, CommandEventData eventData, InterceptionResult<int> result, CancellationToken cancellationToken = default){OnStart(command);return base.NonQueryExecutingAsync(command, eventData, result, cancellationToken);}public override int NonQueryExecuted(DbCommand command, CommandExecutedEventData eventData, int result){Log(command);return base.NonQueryExecuted(command, eventData, result);}public override Task<int> NonQueryExecutedAsync(DbCommand command, CommandExecutedEventData eventData, int result, CancellationToken cancellationToken = default){Log(command);return base.NonQueryExecutedAsync(command, eventData, result, cancellationToken);}public override InterceptionResult<object> ScalarExecuting(DbCommand command, CommandEventData eventData, InterceptionResult<object> result){OnStart(command);return base.ScalarExecuting(command, eventData, result);}public override Task<InterceptionResult<object>> ScalarExecutingAsync(DbCommand command, CommandEventData eventData, InterceptionResult<object> result, CancellationToken cancellationToken = default){OnStart(command);return base.ScalarExecutingAsync(command, eventData, result, cancellationToken);}public override object ScalarExecuted(DbCommand command, CommandExecutedEventData eventData, object result){Log(command);return base.ScalarExecuted(command, eventData, result);}public override Task<object> ScalarExecutedAsync(DbCommand command, CommandExecutedEventData eventData, object result, CancellationToken cancellationToken = default){Log(command);return base.ScalarExecutedAsync(command, eventData, result, cancellationToken);}public override InterceptionResult<DbDataReader> ReaderExecuting(DbCommand command, CommandEventData eventData, InterceptionResult<DbDataReader> result){OnStart(command);return base.ReaderExecuting(command, eventData, result);}public override Task<InterceptionResult<DbDataReader>> ReaderExecutingAsync(DbCommand command, CommandEventData eventData, InterceptionResult<DbDataReader> result, CancellationToken cancellationToken = default){OnStart(command);return base.ReaderExecutingAsync(command, eventData, result, cancellationToken);}public override Task<DbDataReader> ReaderExecutedAsync(DbCommand command, CommandExecutedEventData eventData, DbDataReader result, CancellationToken cancellationToken = default){Log(command);return base.ReaderExecutedAsync(command, eventData, result, cancellationToken);}public override DbDataReader ReaderExecuted(DbCommand command, CommandExecutedEventData eventData, DbDataReader result){Log(command);return base.ReaderExecuted(command, eventData, result);}
这样,我们就实现了通过拦截器实现SQL日志记录~效果如下:
调试SQL语句就方便了很多~
EF Core3.0+ 通过拦截器实现读写分离与SQL日志记录相关推荐
- EF通用数据层封装类(支持读写分离,一主多从)
浅谈orm 记得四年前在学校第一次接触到 Ling to Sql,那时候瞬间发现不用手写sql语句是多么的方便,后面慢慢的接触了许多orm框架,像 EF,Dapper,Hibernate,Servic ...
- 自定义Flume拦截器,并将收集的日志存储到Kafka中(案例)
1.引入POM文件 如果想调用Flume,需要引入flume相关的jar包依赖,jar包依赖如下: <?xml version="1.0" encoding="UT ...
- Spring 事务 以及拦截器的前后关系实验 Mybatis 日志拦截
背景:当一个线程中,如果需要拦截所有当SQL日志,然后统一发送到一个同步器,就可以实现多个数据库实现同步主库,在进行红绿上线,或者灰度部署时候,可以实现生产库与测试库实时同步,从而达到实时可切换的效果 ...
- Entity Framework Core——9.日志记录与拦截器
https://docs.microsoft.com/zh-cn/ef/core/logging-events-diagnostics/ 文章目录 1.机制 2. 简单的日志记录 2.1 日志的详细信 ...
- Spring+SpringMVC+MyBatis深入学习及搭建(十七)——SpringMVC拦截器
转载请注明出处:http://www.cnblogs.com/Joanna-Yan/p/7098753.html 前面讲到:Spring+SpringMVC+MyBatis深入学习及搭建(十六)--S ...
- java web 过滤器跟拦截器的区别和使用
2019独角兽企业重金招聘Python工程师标准>>> 1.首先要明确什么是拦截器.什么是过滤器 1.1 什么是拦截器: 拦截器,在AOP(Aspect-Oriented Progr ...
- java元婴期(31)----java进阶(springmvc(5)---数据回显数据交互拦截器)
数据回显 什么数据回显 提交后,如果出现错误,将刚才提交的数据回显到刚才的提交页面. pojo数据回显方法 1.springmvc默认对pojo数据进行回显. pojo数据传入controller方法 ...
- spring mvc拦截器HandlerInterceptor
本文主要介绍springmvc中的拦截器,包括拦截器定义和的配置,然后演示了一个链式拦截的测试示例,最后通过一个登录认证的例子展示了拦截器的应用 拦截定义 定义拦截器,实现HandlerInterce ...
- Struts2 拦截器: 拦截器与过滤器区别
1.首先要明确什么是拦截器.什么是过滤器 1.1 什么是拦截器: 拦截器,在AOP(Aspect-Oriented Programming)中用于在某个方法或字段被访问之前,进行拦截然后在之前或之后加 ...
最新文章
- 2022-2028年中国电熔镁行业市场研究及发展趋势分析报告
- 大数据笔记2019.5.6
- windows安装64位Pygame方法
- hihocoder A Game 区间dp
- Adobe Experience Design是什么软件?xd mac版下载安装教程 XD 2021发布
- 【算法与数据结构实战】线性表操作-实现A并B,结果放入A中
- Spring:@Transactional 注解使用讲解
- TensorFlow实战5——TensorFlow实现AlexNet
- c语言 滑窗法_滑窗算法
- html中css的注释怎么写,html注释和css、js注释的写法,使用场景以及性能优化问题...
- Android 动态更换app图标
- 安装pytorch1.10.0/cu111时报错:no matching distribution found for torchvision==0.11.0+cu111
- 利用特性、泛型、反射生成sql操作语句(待修改
- 《HelloGitHub》第 61 期
- Windows利用系统自带的Dism命令挂载wim文件
- 文件管理器和FTP客户端:ForkLift for Mac
- matlab心碎的心,让人撕心裂肺的心痛网名,心碎绝望的伤感昵称
- android平板苹果,苹果界面让人生厌 5款Android平板推荐
- 聚水潭完成3亿元B3轮融资,红杉资本中国基金独家投资
- python条形码识别系统_基于Python与Zbar的无人机盘点条形码识别研究
热门文章
- Mysql InnoDB Plugin安装 install
- [USACO10DEC] Treasure Chest
- eclipse启动tomcat无法访问
- 从浏览器地址栏输入url到显示页面的步骤
- Android中常用到的权限
- 【慢慢学算法】:查找第k小数
- xml.query() 实例演示
- html模板 循环里if,django模板里循环变量table里想要两个一行如何控制
- 如何在Microsoft Excel中将文本转换为日期值
- python 新闻摘要_每日新闻摘要:Microsoft内部禁止应用程序,这样就可以了