SpringBoot中怎么切換主從數(shù)據(jù)源,相信很多沒有經(jīng)驗(yàn)的人對(duì)此束手無策,為此本文總結(jié)了問題出現(xiàn)的原因和解決方法,通過這篇文章希望你能解決這個(gè)問題。
網(wǎng)站建設(shè)哪家好,找創(chuàng)新互聯(lián)!專注于網(wǎng)頁設(shè)計(jì)、網(wǎng)站建設(shè)、微信開發(fā)、小程序開發(fā)、集團(tuán)企業(yè)網(wǎng)站建設(shè)等服務(wù)項(xiàng)目。為回饋新老客戶創(chuàng)新互聯(lián)還提供了泰和免費(fèi)建站歡迎大家使用!
借助spring的【org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource】這個(gè)抽象類實(shí)現(xiàn),來進(jìn)行·數(shù)據(jù)源的路由,并通過Aop 進(jìn)行路由選擇。
# dev server # 多數(shù)據(jù)源時(shí),主數(shù)據(jù)源為 master spring.datasource.master.jdbc-url=jdbc:MySQL://localhost:3306/epoint?characterEncoding=utf8&allowMultiQueries=true&useSSL=false&autoReconnect=true&failOverReadOnly=false spring.datasource.master.username=test spring.datasource.master.password=test # dev server # 多數(shù)據(jù)源時(shí),從數(shù)據(jù)源為 slave spring.datasource.slave.jdbc-url=jdbc:mysql://localhost:3306/epoint2?characterEncoding=utf8&allowMultiQueries=true&useSSL=false&autoReconnect=true&failOverReadOnly=false spring.datasource.slave.username=test spring.datasource.slave.password=test
spring boot :error querying database. Cause: java.lang.IllegalArgumentException: dataSource or dataSourceClassName or jdbcUrl is required 配置多個(gè)數(shù)據(jù)源啟動(dòng)報(bào)錯(cuò),error querying database. Cause: java.lang.IllegalArgumentException: dataSource or dataSourceClassName or jdbcUrl is required, 主要原因是在1.0 配置數(shù)據(jù)源的過程中主要是寫成:spring.datasource.url 和spring.datasource.driverClassName。 而在2.0升級(jí)之后需要變更成:spring.datasource.jdbc-url和spring.datasource.driver-class-name即可解決! 更改配置:spring.datasource.master.url -> spring.datasource.master.jdbc-url
/** * describe:定義HandleDataSource類來獲取當(dāng)前線程的數(shù)據(jù)源類型 * current user Maochao.zhu * current system 2020/9/15 */ public class HandleDataSource { public static final ThreadLocal<String> holder = new ThreadLocal<String>(); /** * 綁定當(dāng)前線程數(shù)據(jù)源 * * @param datasource */ public static void putDataSource(String datasource) { holder.set(datasource); } /** * 獲取當(dāng)前線程的數(shù)據(jù)源 * * @return */ public static String getDataSource() { return holder.get(); } }
注意:因?yàn)樾录恿藬?shù)據(jù)庫線程處理類,和原來存在的多線程處理類沖突,會(huì)造成現(xiàn)有程序“卡頓”或者“死機(jī)”,因此去除原來配置的定時(shí)任務(wù)多線程配置
/** * describe:配置多線程定時(shí)器 * current user Maochao.zhu * current system 2020/1/20 */ @Configuration @EnableScheduling public class ScheduleConfig implements SchedulingConfigurer { @Override public void configureTasks(ScheduledTaskRegistrar taskRegistrar) { Method[] methods = BatchProperties.Job.class.getMethods(); int defaultPoolSize = 3; int corePoolSize = 0; if (methods != null && methods.length > 0) { for (Method method : methods) { Scheduled annotation = method.getAnnotation(Scheduled.class); if (annotation != null) { corePoolSize++; } } if (defaultPoolSize > corePoolSize) corePoolSize = defaultPoolSize; } taskRegistrar.setScheduler(Executors.newScheduledThreadPool(corePoolSize)); } }
/** * describe:定義路由數(shù)據(jù)源的實(shí)現(xiàn)類MyAbstractRoutingDataSource * current user Maochao.zhu * current system 2020/9/15 */ public class MyAbstractRoutingDataSource extends AbstractRoutingDataSource { private final Logger log = LoggerFactory.getLogger(this.getClass()); @Override protected Object determineCurrentLookupKey() { log.info("###請(qǐng)求的數(shù)據(jù)源:{}",HandleDataSource.getDataSource()); return HandleDataSource.getDataSource();//獲取對(duì)應(yīng)的數(shù)據(jù)源 } }
/** * describe:配置數(shù)據(jù)源數(shù)據(jù)源和路由配置 * current user Maochao.zhu * current system 2020/9/15 */ @Configuration public class DataSourceConfig { //主數(shù)據(jù)源 @Bean() @ConfigurationProperties(prefix = "spring.datasource.master") public DataSource MasterDataSource() { return DataSourceBuilder.create().build(); } //從數(shù)據(jù)源 @Bean() @ConfigurationProperties(prefix = "spring.datasource.slave") public DataSource SlaveDataSource() { return DataSourceBuilder.create().build(); } /** * 設(shè)置數(shù)據(jù)源路由,通過該類中的determineCurrentLookupKey決定使用哪個(gè)數(shù)據(jù)源 */ @Bean public AbstractRoutingDataSource routingDataSource() { MyAbstractRoutingDataSource proxy = new MyAbstractRoutingDataSource(); Map<Object, Object> targetDataSources = new HashMap<>(2);//存放對(duì)于數(shù)據(jù)源的映射 targetDataSources.put("master", MasterDataSource()); targetDataSources.put("slave", SlaveDataSource()); proxy.setDefaultTargetDataSource(MasterDataSource()); proxy.setTargetDataSources(targetDataSources); return proxy; } @Bean(name = "SqlSessionFactory") @Primary public SqlSessionFactory MasterSqlSessionFactory(DataSource routingDataSource) throws Exception { SqlSessionFactoryBean bean = new SqlSessionFactoryBean(); bean.setDataSource(routingDataSource);//DataSource使用路由數(shù)據(jù)源 ResourcePatternResolver resolver = new PathMatchingResourcePatternResolver(); try { bean.setMapperLocations(resolver.getResources("classpath*:mapper/**/*.xml")); bean.setConfigLocation(resolver.getResource("classpath:mybatis-config.xml")); return bean.getObject(); } catch (Exception e) { e.printStackTrace(); throw new RuntimeException(e); } } @Bean(name = "TransactionManager") @Primary public DataSourceTransactionManager testTransactionManager(DataSource routingDataSource) { return new DataSourceTransactionManager(routingDataSource); } @Bean(name = "SqlSessionTemplate") @Primary public SqlSessionTemplate MasterSqlSessionTemplate(SqlSessionFactory sqlSessionFactory) throws Exception { return new SqlSessionTemplate(sqlSessionFactory); } }
注意:配置路由設(shè)置后,原來的apache.shiro 權(quán)限讀取不到問題,排查以后確定原因是在使用配置路由設(shè)置,原來在application.properties中配置的mybaits屬性,將不起作用,因此需要新加一個(gè)配置文件(mybatis-config.xml),從中讀取配置信息, 其中ShiroConfig配置類中新增注解支持
/** * 開啟Shiro的注解(如@RequiresRoles,@RequiresPermissions),需借助SpringAOP掃描使用Shiro注解的類,并在必要時(shí)進(jìn)行安全邏輯驗(yàn)證 * 配置以下兩個(gè)bean(DefaultAdvisorAutoProxyCreator和AuthorizationAttributeSourceAdvisor)即可實(shí)現(xiàn)此功能 * @return */ @Bean @ConditionalOnMissingBean public DefaultAdvisorAutoProxyCreator defaultAdvisorAutoProxyCreator(){ DefaultAdvisorAutoProxyCreator advisorAutoProxyCreator = new DefaultAdvisorAutoProxyCreator(); advisorAutoProxyCreator.setProxyTargetClass(true); return advisorAutoProxyCreator; } /** * 開啟shiro aop注解支持. * 使用代理方式;所以需要開啟代碼支持; * @param securityManager * @return * */ @Bean public AuthorizationAttributeSourceAdvisor authorizationAttributeSourceAdvisor(SecurityManager securityManager){ AuthorizationAttributeSourceAdvisor authorizationAttributeSourceAdvisor = new AuthorizationAttributeSourceAdvisor(); authorizationAttributeSourceAdvisor.setSecurityManager(securityManager); return authorizationAttributeSourceAdvisor; }
<?xml version="1.0" encoding="UTF-8"?> <!DOCTYPE configuration PUBLIC "-//mybatis.org//DTD Config 3.0//EN" "http://mybatis.org/dtd/mybatis-3-config.dtd"> <configuration> <settings> <setting name="cacheEnabled" value="true" /> <setting name="lazyLoadingEnabled" value="true" /> <setting name="multipleResultSetsEnabled" value="true" /> <setting name="useColumnLabel" value="true" /> <setting name="useGeneratedKeys" value="false" /> <setting name="defaultExecutorType" value="SIMPLE" /> <setting name="mapUnderscoreToCamelCase" value="true" /> <setting name="logImpl" value="STDOUT_LOGGING" /> </settings> </configuration>
/** * describe:DataSource注解來注釋Mapper接口所要使用的數(shù)據(jù)源 * current user Maochao.zhu * current system 2020/9/15 */ @Retention(RetentionPolicy.RUNTIME) @Target(ElementType.METHOD) public @interface DataSource { String value();//設(shè)置數(shù)據(jù)源類型 }
/** * describe:配置Aop切換路由選擇 * current user Maochao.zhu * current system 2020/9/15 */ @Aspect @Component public class DataSourceAspect { public Logger logger = LoggerFactory.getLogger(this.getClass()); /** * 在dao層方法獲取datasource對(duì)象之前,在切面中指定當(dāng)前線程數(shù)據(jù)源 */ @Pointcut("execution(* com.cn.zx.dao..*.*(..))")//切點(diǎn)為所有的mapper接口 public void pointcut() { } @Before("pointcut()") public void before(JoinPoint point) { System.out.println("before"); Object target = point.getTarget(); String method = point.getSignature().getName(); Class<?>[] classz = target.getClass().getInterfaces();// 獲取目標(biāo)類的接口, 所以@DataSource需要寫在接口上 Class<?>[] parameterTypes = ((MethodSignature) point.getSignature()).getMethod().getParameterTypes(); try { Method m = classz[0].getMethod(method, parameterTypes); if (m != null && m.isAnnotationPresent(DataSource.class)) { DataSource data = m.getAnnotation(DataSource.class); System.out.println("####################用戶選擇數(shù)據(jù)庫庫類型:" + data.value()); HandleDataSource.putDataSource(data.value());// 數(shù)據(jù)源放到當(dāng)前線程中 } logger.info("執(zhí)行接口方法:{}.{}", point.getSignature().getDeclaringTypeName(), point.getSignature().getName()); } catch (Exception e) { e.printStackTrace(); } } }
在對(duì)應(yīng)的mapper方法上使用注解DataSource("master/slave")來設(shè)置數(shù)據(jù)源類型
/** * 調(diào)用主數(shù)據(jù)源 master * @param user * @return */ @DataSource("master") Integer insertUser(User user); /** * 調(diào)用從數(shù)據(jù)源 slave * @param user * @return */ @DataSource("slave") List<User> getUserList(User user);
添加主從數(shù)據(jù)庫以后,事務(wù)就失效了,原因還在找 ,初步定位為: 事務(wù)和切面的執(zhí)行順序問題 @EnableTransactionManagement(order = 2) @Order(2)
解決:
SpringbootApplication啟動(dòng)類增加注解開啟事務(wù)注解,數(shù)據(jù)庫表引擎更改為innodb,如果是myisam,事務(wù)是不起作用的 @EnableTransactionManagement
事務(wù)的管理方式有兩種: 第一種:編程式事務(wù)管理,需要將數(shù)據(jù)庫的自動(dòng)提交等取消,并且需要自己編寫事務(wù)代碼。 第二種:聲明式事務(wù)管理模式,spring利用spring AOP特性編寫了注解。
1.service類標(biāo)簽(一般不建議在接口上)上添加@Transactional,可以將整個(gè)類納入spring事務(wù)管理,在每個(gè)業(yè)務(wù)方法執(zhí)行時(shí)都會(huì)開啟一個(gè)事務(wù),不過這些事務(wù)采用相同的管理方式。并且當(dāng)在某個(gè)service實(shí)現(xiàn)類中某個(gè)方法調(diào)用了另一個(gè)這個(gè)實(shí)現(xiàn)類中的方法,則兩個(gè)方法都必須聲明事務(wù),才能被當(dāng)成一個(gè)事務(wù)進(jìn)行管理 2.@Transactional 注解只能應(yīng)用到 public 可見度的方法上。 如果應(yīng)用在protected、private或者 package可見度的方法上,也不會(huì)報(bào)錯(cuò),不過事務(wù)設(shè)置不會(huì)起作用。 3.默認(rèn)情況下,spring會(huì)對(duì)unchecked異常進(jìn)行事務(wù)回滾;如果是checked異常則不回滾。
那么什么是checked異常,什么是unchecked異常 java里面將派生于Error或者RuntimeException(比如空指針,1/0)的異常稱為unchecked異常,其他繼承自java.lang.Exception得異常統(tǒng)稱為Checked Exception,如IOException、TimeoutException等,通俗一點(diǎn):你寫代碼出現(xiàn)的空指針等異常,會(huì)被回滾,文件讀寫,網(wǎng)絡(luò)出問題,spring就沒法回滾了。
@Transactional(propagation=Propagation.NOT_SUPPORTED,readOnly=true) 只讀標(biāo)志只在事務(wù)啟動(dòng)時(shí)應(yīng)用,否則即使配置也會(huì)被忽略。 啟動(dòng)事務(wù)會(huì)增加線程開銷,數(shù)據(jù)庫因共享讀取而鎖定(具體跟數(shù)據(jù)庫類型和事務(wù)隔離級(jí)別有關(guān))。通常情況下,僅是讀取數(shù)據(jù)時(shí),不必設(shè)置只讀事務(wù)而增加額外的系統(tǒng)開銷。
Propagation枚舉了多種事務(wù)傳播模式,部分列舉如下: 1. REQUIRED(默認(rèn)模式):業(yè)務(wù)方法需要在一個(gè)容器里運(yùn)行。如果方法運(yùn)行時(shí),已經(jīng)處在一個(gè)事務(wù)中,那么加入到這個(gè)事務(wù),否則自己新建一個(gè)新的事務(wù)。 2. NOT_SUPPORTED:聲明方法不需要事務(wù)。如果方法沒有關(guān)聯(lián)到一個(gè)事務(wù),容器不會(huì)為他開啟事務(wù),如果方法在一個(gè)事務(wù)中被調(diào)用,該事務(wù)會(huì)被掛起,調(diào)用結(jié)束后,原先的事務(wù)會(huì)恢復(fù)執(zhí)行。 3. REQUIRESNEW:不管是否存在事務(wù),該方法總匯為自己發(fā)起一個(gè)新的事務(wù)。如果方法已經(jīng)運(yùn)行在一個(gè)事務(wù)中,則原有事務(wù)掛起,新的事務(wù)被創(chuàng)建。 4. MANDATORY:該方法只能在一個(gè)已經(jīng)存在的事務(wù)中執(zhí)行,業(yè)務(wù)方法不能發(fā)起自己的事務(wù)。如果在沒有事務(wù)的環(huán)境下被調(diào)用,容器拋出例外。 5. SUPPORTS:該方法在某個(gè)事務(wù)范圍內(nèi)被調(diào)用,則方法成為該事務(wù)的一部分。如果方法在該事務(wù)范圍外被調(diào)用,該方法就在沒有事務(wù)的環(huán)境下執(zhí)行。 6. NEVER:該方法絕對(duì)不能在事務(wù)范圍內(nèi)執(zhí)行。如果在就拋例外。只有該方法沒有關(guān)聯(lián)到任何事務(wù),才正常執(zhí)行。 7. NESTED:如果一個(gè)活動(dòng)的事務(wù)存在,則運(yùn)行在一個(gè)嵌套的事務(wù)中。如果沒有活動(dòng)事務(wù),則按REQUIRED屬性執(zhí)行。它使用了一個(gè)單獨(dú)的事務(wù),這個(gè)事務(wù)擁有多個(gè)可以回滾的保存點(diǎn)。內(nèi)部事務(wù)的回滾不會(huì)對(duì)外部事務(wù)造成影響。它只對(duì)DataSourceTransactionManager事務(wù)管理器起效。
1. 檢查你方法是不是public的。 2. 你的異常類型是不是unchecked異常??罩羔槷惓J莡nchecked異常,如果我想check異常也想回滾怎么辦,注解上面寫明異常類型即可。 @Transactional(rollbackFor={Exception.class.RuntimeException.class}) 類似的還有norollbackFor,自定義不回滾的異常。如果已經(jīng)在service中進(jìn)行了try catch 操作,由于已經(jīng)被抓獲異常,事務(wù)也不會(huì)回滾 3. 數(shù)據(jù)庫引擎要支持事務(wù),如果是mysql,注意表要使用支持事務(wù)的引擎,比如innodb,如果是myisam,事務(wù)是不起作用的。 4. 是否開啟了對(duì)注解的解析 4.1 SpringMVC中開啟: <tx:annotation-driven transaction-manager="transactionManager" proxy-target-class="true"/> 4.2 pringboot中開啟: 啟動(dòng)類增加注解:@EnableTransactionManagement 類方法中增加注解:@Transactional 5. spring是否掃描到你這個(gè)包,如下是掃描到org.test下面的包 <context:component-scan base-package="org.test" ></context:component-scan>
mysql數(shù)據(jù)庫引擎innodb設(shè)置
show engines;
show variables like 'default_storage_engine';
修改mysql 默認(rèn)的數(shù)據(jù)庫引擎 在配置文件my.ini中的 [mysqld] 下面加入default-storage-engine=INNODB 如果啟動(dòng)不起來,找到 skip-innodb 項(xiàng),將其改為 #skip-innodb(要不然知識(shí)修改了 InnoDB 服務(wù)起不來) 重啟Mysql服務(wù)器,設(shè)置生效。
如數(shù)據(jù)庫名為: epoint,修改數(shù)據(jù)庫表引擎從 MyISAM -> InnoDB
SHOW TABLE STATUS FROM epoint;
SELECT GROUP_CONCAT(CONCAT( 'ALTER TABLE ' ,TABLE_NAME ,' ENGINE=InnoDB; ') SEPARATOR '' ) FROM information_schema.TABLES AS t WHERE TABLE_SCHEMA = 'epoint' AND TABLE_TYPE = 'BASE TABLE';
ALTER TABLE branch ENGINE=InnoDB;
SHOW TABLE STATUS FROM epoint;
修改所有數(shù)據(jù)庫表的引擎為InnoDB結(jié)束
主從數(shù)據(jù)庫數(shù)據(jù)同步問題定位: 1.程序同步。 2.數(shù)據(jù)庫操作同步數(shù)據(jù) 因?yàn)橐x寫分離,肯定要設(shè)置數(shù)據(jù)庫權(quán)限,主數(shù)據(jù)庫可以讀寫,從數(shù)據(jù)庫只能讀,所以這個(gè)方法行不通,只能從數(shù)據(jù)庫方面進(jìn)行設(shè)置主從數(shù)據(jù)同步。
通過mysql命令查看mysql的安裝路徑:
select @@basedir as basePath from dual; SELECT @@basedir;
獲取路徑:C:\Program Files\MySQL\MySQL Server 5.7\
在my.ini 文件中找到[mysqld] 添加如下配置(需要同步的數(shù)據(jù)庫有多少都可以寫進(jìn)去,主從同步會(huì)根據(jù)庫名稱找到對(duì)應(yīng)的叢庫去同步數(shù)據(jù))
server-id=1#主庫和從庫需要不一致 log-bin=mysql-bin binlog-do-db=mstest#同步的數(shù)據(jù)庫 binlog-ignore-db=mysql#不需要同步的數(shù)據(jù)庫
mysql> SHOW VARIABLES LIKE 'server_id'; +---------------+-------+ | Variable_name | Value | +---------------+-------+ | server_id | 1 | +---------------+-------+ 1 row in set mysql> show master status; +------------------+----------+--------------+------------------+-------------------+ | File | Position | Binlog_Do_DB | Binlog_Ignore_DB | Executed_Gtid_Set | +------------------+----------+--------------+------------------+-------------------+ | mysql-bin.000007 | 5138 | epoint | | | +------------------+----------+--------------+------------------+-------------------+ 1 row in set
grant all on *.* to 'user'@'%' identified by 'user';
在my.ini 文件中找到[mysqld] 添加如下配置(需要同步的數(shù)據(jù)庫有多少都可以寫進(jìn)去,主從同步會(huì)根據(jù)庫名稱找到對(duì)應(yīng)的叢庫去同步數(shù)據(jù))
server-id=2#和主庫不一致 replicate-do-db=test#需要同步的庫1 replicate-ignore-db=mysql#不需要同步的庫
STOP SLAVE; #停止從復(fù)制功能的命令 change master to master_host='127.0.0.1',master_port=3306,master_user='slave',master_password='123',master_log_file='mysql-bin.000004',master_log_pos=717;
說明 : 對(duì)應(yīng)著改成 你們自己的配置,master_host:主庫的ip,master_port:主庫的端口,master_user:主庫給叢庫建立的賬號(hào)名稱,master_password:賬號(hào)密碼 關(guān)于master_log_file 和 Position('mysql-bin.000005' 98) 是主庫配置中的"show master status"得到的;
START SLAVE; #啟動(dòng)從復(fù)制功能 RESET SLAVE; #重置從復(fù)制功能的配置,會(huì)清除 master.info 和 relay-log.info 兩個(gè)文件 show slave status; (沒有分號(hào)),查看
其中Slave_IO_Running和Slave_SQL_Running屬性打開,表示開啟
Slave_IO_Running: Yes Slave_SQL_Running: Yes
配置MySQL主從數(shù)據(jù)庫結(jié)束
> 主從Mysql數(shù)據(jù)庫同步:https://blog.csdn.net/fengrenyuandefz/article/details/89420201 > 一臺(tái)電腦裝兩個(gè)MySQL:https://blog.csdn.net/weixin_41953055/article/details/79820221 > server_uuid重復(fù):https://blog.csdn.net/sunbocong/article/details/81634296 > mysql主從同步 binlog-do-db replicate-do-db: https://blog.csdn.net/z69183787/article/details/70183284 > mysql主從數(shù)據(jù)庫同步:https://blog.csdn.net/fengrenyuandefz/article/details/89420201
看完上述內(nèi)容,你們掌握SpringBoot中怎么切換主從數(shù)據(jù)源的方法了嗎?如果還想學(xué)到更多技能或想了解更多相關(guān)內(nèi)容,歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道,感謝各位的閱讀!
網(wǎng)頁名稱:SpringBoot中怎么切換主從數(shù)據(jù)源
本文網(wǎng)址:http://www.rwnh.cn/article30/jipgpo.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供域名注冊(cè)、品牌網(wǎng)站設(shè)計(jì)、全網(wǎng)營銷推廣、網(wǎng)站導(dǎo)航、網(wǎng)站設(shè)計(jì)、定制開發(fā)
聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請(qǐng)盡快告知,我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場,如需處理請(qǐng)聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時(shí)需注明來源: 創(chuàng)新互聯(lián)