电脑知识|欧美黑人一区二区三区|软件|欧美黑人一级爽快片淫片高清|系统|欧美黑人狂野猛交老妇|数据库|服务器|编程开发|网络运营|知识问答|技术教程文章 - 好吧啦网

您的位置:首頁技術文章
文章詳情頁

SpringBoot+Mybatis-Plus實現mysql讀寫分離方案的示例代碼

瀏覽:4日期:2023-02-05 17:35:32

1. 引入mybatis-plus相關包,pom.xml文件

SpringBoot+Mybatis-Plus實現mysql讀寫分離方案的示例代碼

2. 配置文件application.property增加多庫配置

mysql 數據源配置

spring.datasource.primary.jdbc-url=jdbc:mysql://xx.xx.xx.xx:3306/portal?useUnicode=true&useJDBCCompliantTimezoneShift=true&useLegacyDatetimeCode=false&serverTimezone=UTC&characterEncoding=utf8&serverTimezone=GMT%2B8spring.datasource.primary.username=rootspring.datasource.primary.password=rootspring.datasource.primary.driver-class-name=com.mysql.cj.jdbc.Driver#mysql slave 數據源配置spring.datasource.slave.jdbc-url=jdbc:mysql://xx.xx.xx.xx:3306/portal?useUnicode=true&useJDBCCompliantTimezoneShift=true&useLegacyDatetimeCode=false&serverTimezone=UTC&characterEncoding=utf8&serverTimezone=GMT%2B8spring.datasource.slave.username=rootspring.datasource.slave.password=rootspring.datasource.slave.driver-class-name=com.mysql.cj.jdbc.Driver

3. 配置數據源及注解

數據源配置 MultiDataSourceConfig.Java

/** * 配置多數據源 */@Profile('dev')//開發模式配置文件@Configuration@MapperScan(basePackages = 'com.csc.portal.mapper')//掃描包public class MultiDataSourceConfig { /** * 主數據源 * @return */ @Bean @ConfigurationProperties(prefix = 'spring.datasource.primary') public DataSource masterDataSource() { return DataSourceBuilder.create().build(); } /** * 從數據源 * @return */ @Bean @ConfigurationProperties(prefix = 'spring.datasource.slave') public DataSource slaveDataSource() { return DataSourceBuilder.create().build(); } /** * 路由數據源,前面兩個數據源是為了創建此數據源 * @param masterDataSource 主數據源 * @param slaveDataSource 從數據源 * @return */ @Bean public DataSource myRoutingDataSource(@Qualifier('masterDataSource') DataSource masterDataSource, @Qualifier('slaveDataSource') DataSource slaveDataSource) { Map<Object, Object> targetDataSources = new HashMap<>(); targetDataSources.put(DBTypeEnum.MASTER, masterDataSource); targetDataSources.put(DBTypeEnum.SLAVE, slaveDataSource); MyRoutingDataSource myRoutingDataSource = new MyRoutingDataSource(); myRoutingDataSource.setDefaultTargetDataSource(slaveDataSource);//設置默認數據源 myRoutingDataSource.setTargetDataSources(targetDataSources);//設置路由表,使用map的key,value方式得到對應數據源 return myRoutingDataSource; }

數據庫枚舉類

public enum DBTypeEnum { MASTER, SLAVE;}

注解

@Target({ElementType.METHOD})@Retention(RetentionPolicy.RUNTIME)public @interface Master {}

@Target({ElementType.METHOD})@Retention(RetentionPolicy.RUNTIME)public @interface Slave {}

4. Mybatis-plus配置

@EnableTransactionManagement@Configuration@MapperScan(basePackages = 'com.csc.portal.mapper')public class MybatisPlusConfig { /** * 分頁插件 */ @Bean public PaginationInterceptor paginationInterceptor() { return new PaginationInterceptor(); } @Resource(name = 'myRoutingDataSource') private DataSource myRoutingDataSource; /** * 使用MyBatis Plus的sqlSessionFactory代替, * 此處注意mybatis與mybatisPlus的配置不同,不然掃描不到對數據操作的方法。會報未綁定錯誤 * @return sqlSessionFactory * @throws Exception */ @Bean public SqlSessionFactory sqlSessionFactory() throws Exception { MybatisSqlSessionFactoryBean sqlSessionFactoryBean = new MybatisSqlSessionFactoryBean(); sqlSessionFactoryBean.setDataSource(myRoutingDataSource); sqlSessionFactoryBean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources('classpath:mapper/*.xml')); MybatisConfiguration mybatisConfiguration = new MybatisConfiguration(); sqlSessionFactoryBean.setConfiguration(mybatisConfiguration); return sqlSessionFactoryBean.getObject(); } /** * 此處為使用mybatis時的sqlsessionFactory配置 * @return * @throws Exception */ /* @Bean public SqlSessionFactory sqlSessionFactory() throws Exception { SqlSessionFactoryBean sqlSessionFactoryBean = new SqlSessionFactoryBean(); sqlSessionFactoryBean.setDataSource(myRoutingDataSource); sqlSessionFactoryBean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources('classpath:mapper/*.xml')); return sqlSessionFactoryBean.getObject(); } */ /** * 事務配置 * @return 事務管理器 */ @Bean public DataSourceTransactionManager transactionManager() { DataSourceTransactionManager tx = new DataSourceTransactionManager(); tx.setDataSource(myRoutingDataSource); return tx; }

5. 增加數據源管理類

DBContextHolder.java

public class DBContextHolder { /** * 外部一個請求將會產生一個線程與之對應,每個線程的變量可用ThreadLocal進行存儲 */ private static final ThreadLocal<DBTypeEnum> contextHolder = new ThreadLocal<>(); public static void set(DBTypeEnum dbType) { contextHolder.set(dbType); } public static DBTypeEnum get() { return contextHolder.get(); } public static void master() { set(DBTypeEnum.MASTER); System.out.println('切換到master'); } public static void slave() { set(DBTypeEnum.SLAVE); System.out.println('切換到slave'); }}

指定選擇數據源

MyRoutingDataSource.java 方法determineCurrentLookupKey決定最終使用哪個數據源進行操作,若為空則使用默認數據源。

public class MyRoutingDataSource extends AbstractRoutingDataSource { @Nullable @Override protected Object determineCurrentLookupKey() { System.out.println('線程名:'+Thread.currentThread().getName()+':'+DBContextHolder.get()); return DBContextHolder.get();/* if (DBContextHolder.get() != null) { System.out.println('線程名:'+Thread.currentThread().getName()+':'+DBContextHolder.get()); return DBContextHolder.get(); } else { System.out.println('未匹配到指定數據庫,默認切換到Master'); return DBTypeEnum.MASTER; }*/ //return DBContextHolder.get(); }}

6. 增加aop切面

@Aspect@Component@Order(0)//配置注解優先級,優于事物注解@Transactional先進行數據源切換,//不然在事物中進行數據源切換無效public class DataSourceAop { @Pointcut(/*'!@annotation(com.csc.portal.annotation.Master) ' + '&& (execution(* com.csc.portal.service..*.select*(..)) ' + '|| execution(* com.csc.portal.service..*.get*(..))'+*/ ' @annotation(com.csc.portal.annotation.Slave)') public void readPointcut() { } @Pointcut('@annotation(com.csc.portal.annotation.Master) ' //+ /* '|| execution(* com.csc.portal.service..*.insert*(..)) ' + '|| execution(* com.csc.portal.service..*.add*(..)) ' + '|| execution(* com.csc.portal.service..*.update*(..)) ' + '|| execution(* com.csc.portal.service..*.edit*(..)) ' + '|| execution(* com.csc.portal.service..*.delete*(..)) ' + '|| execution(* com.csc.portal.service..*.remove*(..))'*/) public void writePointcut() { } @Before('readPointcut()') public void read() { //獲取攔截類 DBContextHolder.slave(); System.out.println(Thread.currentThread().getName()+DBContextHolder.get()); } @Before('writePointcut()') public void write() { //獲取攔截類/* String className = pjp.getTarget().getClass().getName(); System.out.println('當前線程'+Thread.currentThread().getName()+' 攔截類為:' + className); //獲取攔截的方法名 MethodSignature msig = (MethodSignature) pjp.getSignature(); Method currentMethod = null; try { currentMethod = pjp.getTarget().getClass().getMethod(msig.getName(), msig.getParameterTypes()); } catch (NoSuchMethodException e) { e.printStackTrace(); } String methodName = currentMethod.getName(); System.out.println('攔截方法名為:' + methodName);*/ DBContextHolder.master(); System.out.println(Thread.currentThread().getName()+DBContextHolder.get()); } }

6. 實際應用

在service層方法前增加注解@Master表示使用主庫,進行增刪改的操作使用主庫。 在service層方法前增加注解@Slave表示使用從庫,進行查的操作使用從庫,默認使用從庫,可不配置。 @ Transactional注解加到service層,增加了@Transactional注解后,啟用事務后,一個事務內部的connection是復用的,所以就算AOP切了數據源字符串,但是數據源并不會被真正修改。所以@Transactional注解不要寫在controller層,不然在service層也切換不了數據源。 @Transactional與@Master可同時使用,已經配置@Master注解的優先級較高,先切換數據源后執行事務。

到此這篇關于SpringBoot+Mybatis-Plus實現mysql讀寫分離方案的示例代碼的文章就介紹到這了,更多相關SpringBoot Mybatis-Plus mysql讀寫分離內容請搜索好吧啦網以前的文章或繼續瀏覽下面的相關文章希望大家以后多多支持好吧啦網!

標簽: Spring
相關文章:
主站蜘蛛池模板: 东莞办公家具厂家直销-美鑫【免费3D效果图】全国办公桌/会议桌定制 | 整车VOC采样环境舱-甲醛VOC预处理舱-多舱法VOC检测环境仓-上海科绿特科技仪器有限公司 | 衬四氟_衬氟储罐_四氟储罐-无锡市氟瑞特防腐科技有限公司 | 首页 - 张店继勇软件开发工作室 兰州UPS电源,兰州山特UPS-兰州万胜商贸 | 餐饮加盟网_特色餐饮连锁加盟店-餐饮加盟官网 | 北京租车公司_汽车/客车/班车/大巴车租赁_商务会议/展会用车/旅游大巴出租_北京桐顺创业租车公司 | 合肥展厅设计-安徽展台设计-合肥展览公司-安徽奥美展览工程有限公司 | 青州开防盗门锁-配汽车芯片钥匙-保险箱钥匙-吉祥修锁店 | 阳光模拟试验箱_高低温试验箱_高低温冲击试验箱_快速温变试验箱|东莞市赛思检测设备有限公司 | 小程序开发公司-小程序制作-微信小程序开发-小程序定制-咏熠软件 | 大_小鼠elisa试剂盒-植物_人Elisa试剂盒-PCR荧光定量试剂盒-上海一研生物科技有限公司 | 防腐木批发价格_深圳_惠州_东莞防腐木厂家_森源(深圳)防腐木有限公司 | 私人别墅家庭影院系统_家庭影院音响_家庭影院装修设计公司-邦牛影音 | 电动葫芦|防爆钢丝绳电动葫芦|手拉葫芦-保定大力起重葫芦有限公司 | 山东活动策划|济南活动公司|济南公关活动策划-济南锐嘉广告有限公司 | lcd条形屏-液晶长条屏-户外广告屏-条形智能显示屏-深圳市条形智能电子有限公司 | 舞台木地板厂家_体育运动木地板_室内篮球馆木地板_实木运动地板厂家_欧氏篮球地板推荐 | 亮点云建站-网站建设制作平台 | 超声波乳化机-超声波分散机|仪-超声波萃取仪-超声波均质机-精浩机械|首页 | 合肥升降机-合肥升降货梯-安徽升降平台「厂家直销」-安徽鼎升自动化科技有限公司 | 湖南成人高考报名-湖南成考网 | 电缆接头_防水接头_电缆防水接头 - 乐清市新豪电气有限公司 | 酒吧霸屏软件_酒吧霸屏系统,酒吧微上墙,夜场霸屏软件,酒吧点歌软件,酒吧互动游戏,酒吧大屏幕软件系统下载 | 淄博不锈钢,淄博不锈钢管,淄博不锈钢板-山东振远合金科技有限公司 | 苏州工作服定做-工作服定制-工作服厂家网站-尺品服饰科技(苏州)有限公司 | 3d打印服务,3d打印汽车,三维扫描,硅胶复模,手板,快速模具,深圳市精速三维打印科技有限公司 | 留学生辅导网-在线课程论文辅导-留学生挂科申诉机构 | 螺旋压榨机-刮泥机-潜水搅拌机-电动泥斗-潜水推流器-南京格林兰环保设备有限公司 | 基本型顶空进样器-全自动热脱附解吸仪价格-AutoHS全模式-成都科林分析技术有限公司 | 超声波清洗机_大型超声波清洗机_工业超声波清洗设备-洁盟清洗设备 | HDPE储罐_厂家-山东九州阿丽贝防腐设备 | 短信通106短信接口验证码接口群发平台_国际短信接口验证码接口群发平台-速度网络有限公司 | 台湾Apex减速机_APEX行星减速机_台湾精锐减速机厂家代理【现货】-杭州摩森机电 | 活动策划,舞台搭建,活动策划公司-首选美湖上海活动策划公司 | WF2户外三防照明配电箱-BXD8050防爆防腐配电箱-浙江沃川防爆电气有限公司 | 济南菜鸟驿站广告|青岛快递车车体|社区媒体-抖音|墙体广告-山东揽胜广告传媒有限公司 | 耐火浇注料价格-高强高铝-刚玉碳化硅耐磨浇注料厂家【直销】 | 大型果蔬切片机-水果冬瓜削皮机-洗菜机切菜机-肇庆市凤翔餐饮设备有限公司 | 蔬菜配送公司|蔬菜配送中心|食材配送|饭堂配送|食堂配送-首宏公司 | 酒吧霸屏软件_酒吧霸屏系统,酒吧微上墙,夜场霸屏软件,酒吧点歌软件,酒吧互动游戏,酒吧大屏幕软件系统下载 | 聚合氯化铝-碱式氯化铝-聚合硫酸铁-聚氯化铝铁生产厂家多少钱一吨-聚丙烯酰胺价格_河南浩博净水材料有限公司 |