深刻讨论为什么要读写分离？

为了服务器承载更多的用户？提升了网站的响应速度？分摊数据库服务器的压力？就是为了双机热备又不想浪费备份服务器？上面这些回答，我认为都不是错误的，但也都不是完全正确的。「读写分离」并不是多么神奇的东西，也带不来多么大的性能提升，也许更多的作用的就是数据安全的备份吧。

从一个库到读写分离，从理论上对服务器压力来说是会带来一倍的性能提升，但你仔细思考一下，你的应用服务器真的很需要这一倍的提升么？那倒不如你去试着在服务器使用一下缓存系统，如 Memcached、Redis 这些分布式缓存，那性能可能是几十倍的提升。而且，在服务器硬件异常强悍及性能廉价的今天，完全更没必要了，所以，在今天，我认为它更多的职责就是为了数据安全而设计的，同时又提升了一些性能，这样也挺好。

可能我们更应该称之为主从分离。

利用 AOP 实现读写分离

读写分离方式很简单，就是在你读数据是去连接从库，在你写数据的时候去连接主库，具体代码实现当然就是连接时候去操作了，这没什么难度，在代码里写就是了。可是，有追求的程序猿都是不是这么解决问题的呢！

 其实通过上篇的 Spring AOP 拦截器的基本实现 我们知道 AOP 可以实现在方法开始执行前后插入执行我们想要的代码，那这样，我们是不是可以在执行数据库操作前根据业务来动态切换数据源呢？

思考一下这个方式理论上好像是可行的，这种方式首先不需要在业务代码中去做切换，二是可能以后我们不需要读写分离了，把 AOP 切换的代码去掉就行了，三是可能就是拓展性好了。

等不了了，开始撸代码

你可能想深入的了解的话，我这里给你几个程序里用到的关键字enum（枚举）、annotation（自定义注解）、JoinPoint（注入点）、AbstractRoutingDataSource（数据源接口子类），你理解了这些就知道了，其实你并不需要深入某些深层的东西，了解下即可。

一、建立JdbcContextHolder.java类

public class JdbcContextHolder {

 private static final ThreadLocal<String> contextHolder = new ThreadLocal<String>();

 public static void setJdbcType(String jdbcType) {
 contextHolder.set(jdbcType);
 }

 public static void setSlave() {
 setJdbcType("slave");
 }

 public static void setMaster() {
 clearJdbcType();
 }

 public static String getJdbcType() {
 return (String) contextHolder.get();
 }

 public static void clearJdbcType() {
 contextHolder.remove();
 }
}

这个类的作用就是用来设置、获取数据源连接

二、新建DynamicDataSource.java类，继承于AbstractRoutingDataSource

import org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource;

import cn.mayongfa.common.JdbcContextHolder;

public class DynamicDataSource extends AbstractRoutingDataSource {

 @Override
 protected Object determineCurrentLookupKey() {
 // 获取当前数据源连接
 return JdbcContextHolder.getJdbcType();
 }
}

通过研究，我们知道determineCurrentLookupKey方法是获取相关数据源连接的，所以重写determineCurrentLookupKey方法就可以啦，然后我们去通过刚刚我们建立的JdbcContextHolder类去获取。那怎么设置呢？

三、建立数据源DataSourceType.java枚举类

public enum DataSourceType {

 //主库
 Master("master"),

 //从库
 Slave("slave");

 private DataSourceType(String name) {
 this.name = name;
 }

 private String name;

 public String getName() {
 return name;
 }
 public void setName(String name) {
 this.name = name;
 }
}

这个枚举类的作用其实就是为了设置数据源而生的，它的目的就是让设置数据源时更方便，如丝般顺滑。

四、新建DataSource.java Annotation（自定义注解）类

import java.lang.annotation.Documented;
import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;

@Retention(RetentionPolicy.RUNTIME) 
@Target(ElementType.METHOD)
@Documented
public @interface DataSource { 

 DataSourceType value() default DataSourceType.Master;

} 

自定义注解的意义不再过多讨论，一句话来说就是可以让你在类或方法名上以打标签的形式让该方法变得不一样。具体怎么「不一样」，这个在于你。

五、新建DataSourceChoose.java数据库切换类

import java.lang.reflect.Method;

import org.aspectj.lang.JoinPoint;
import org.aspectj.lang.reflect.MethodSignature;

import cn.mayongfa.common.JdbcContextHolder;

public class DataSourceChoose {

//方法执行前
public void before(JoinPoint point){
 Object target = point.getTarget(); 
 String method = point.getSignature().getName(); 
 Class<?>[] classz = target.getClass().getInterfaces(); 
 MethodSignature methodSignature = (MethodSignature)point.getSignature();
 Class<?>[] parameterTypes = methodSignature.getMethod().getParameterTypes();
 try {
  Method m = classz[0].getMethod(method, parameterTypes); 
  if (m!=null && m.isAnnotationPresent(DataSource.class)) { 
  DataSource data = m.getAnnotation(DataSource.class); 
  JdbcContextHolder.clearJdbcType();
  JdbcContextHolder.setJdbcType(data.value().getName());
  } 
 } catch (Exception e) { 
  // TODO: handle exception 
 } 
}
}

这个其实是一个拦截器类，主要作用就是拦截那些方法名上有@DataSource这个自定义注解的，完了根据获取注解的value()值，来做相应的数据源切换。

到这里，整个读写分离的分析及业务逻辑和具体代码都完了，以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。

# spring  # aop  # 读写分离 

相关栏目： 【 网站优化151355 】 【 网络推广146373 】 【 网络技术251813 】 【 AI营销90571 】

相关推荐： Laravel Sail是什么_基于Docker的Laravel本地开发环境Sail入门  Laravel路由怎么定义_Laravel核心路由系统完全入门指南  如何挑选高效建站主机与优质域名？  制作网站软件推荐手机版,如何制作属于自己的手机网站app应用？  如何在阿里云完成域名注册与建站？  Win11怎么设置默认图片查看器_Windows11照片应用关联设置  大型企业网站制作流程,做网站需要注册公司吗？  Laravel Eloquent：优雅地将关联模型字段扁平化到主模型中  JavaScript如何实现音频处理_Web Audio API如何工作？  Bootstrap整体框架之CSS12栅格系统  jQuery中的100个技巧汇总  网站制作软件有哪些,制图软件有哪些？  Python制作简易注册登录系统  Laravel如何实现全文搜索功能？（Scout和Algolia示例）  Laravel如何实现API版本控制_Laravel版本化API设计方案  Laravel的辅助函数有哪些_Laravel常用Helpers函数提高开发效率  php增删改查怎么学_零基础入门php数据库操作必知基础【教程】  如何在橙子建站中快速调整背景颜色？  详解MySQL数据库的安装与密码配置  HTML透明颜色代码在Angular里怎么设置_Angular透明颜色使用指南【详解】  北京网站制作费用多少,建立一个公司网站的费用.有哪些部分,分别要多少钱？  Laravel如何构建RESTful API_Laravel标准化API接口开发指南  微信小程序 HTTPS报错整理常见问题及解决方案  Android Socket接口实现即时通讯实例代码  Laravel如何配置和使用队列处理异步任务_Laravel队列驱动与任务分发实例  绝密ChatGPT指令：手把手教你生成HR无法拒绝的求职信  美食网站链接制作教程视频,哪个教做美食的网站比较专业点？  Laravel如何使用API Resources格式化JSON响应_Laravel数据资源封装与格式化输出  Laravel distinct去重查询_Laravel Eloquent去重方法  北京网页设计制作网站有哪些,继续教育自动播放怎么设置？  Win11怎么关闭资讯和兴趣_Windows11任务栏设置隐藏小组件  合肥制作网站的公司有哪些,合肥聚美网络科技有限公司介绍？  bing浏览器学术搜索入口_bing学术文献检索地址  零服务器AI建站解决方案：快速部署与云端平台低成本实践  QQ浏览器网页版登录入口 个人中心在线进入  制作公司内部网站有哪些,内网如何建网站？  如何在景安云服务器上绑定域名并配置虚拟主机？  Laravel如何实现数据导出到CSV文件_Laravel原生流式输出大数据量CSV【方案】  想要更高端的建设网站，这些原则一定要坚持！  详解Nginx + Tomcat 反向代理 负载均衡 集群 部署指南  Laravel用户认证怎么做_Laravel Breeze脚手架快速实现登录注册功能  Laravel如何正确地在控制器和模型之间分配逻辑_Laravel代码职责分离与架构建议  Laravel怎么实现模型属性的自动加密  Android GridView 滑动条设置一直显示状态(推荐)  如何制作公司的网站链接,公司想做一个网站，一般需要花多少钱？  Laravel如何升级到最新的版本_Laravel版本升级流程与兼容性处理  千问怎样用提示词获取健康建议_千问健康类提示词注意事项【指南】  Laravel如何实现数据导出到PDF_Laravel使用snappy生成网页快照PDF【方案】  如何做网站制作流程,*游戏网站怎么搭建？  Laravel如何实现用户注册和登录？（Auth脚手架指南）