最新国产好看的视频,伊人天堂AV在线,国产Aaaaaa视频,蜜臀视频在线观看一区,人妻av色图,密臀久久久精品影片,青青视频免费观看毛片,久草在线观看视,国产三级精品色情在线

springboot結(jié)合mysql主從來(lái)實(shí)現(xiàn)讀寫(xiě)分離的方法示例

 更新時(shí)間:2021年04月18日 16:21:48   作者:yancun93  
這篇文章主要介紹了springboot結(jié)合mysql主從來(lái)實(shí)現(xiàn)讀寫(xiě)分離的方法示例,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧

1.實(shí)現(xiàn)的功能

    基于springboot框架,application.yml配置多個(gè)數(shù)據(jù)源,使用AOP以及AbstractRootingDataSource、ThreadLocal來(lái)實(shí)現(xiàn)多數(shù)據(jù)源切換,以實(shí)現(xiàn)讀寫(xiě)分離。mysql的主從數(shù)據(jù)庫(kù)需要進(jìn)行設(shè)置數(shù)據(jù)之間的同步。

2.代碼實(shí)現(xiàn)

    application.properties中的配置

spring.datasource.druid.master.driver-class-name=com.mysql.jdbc.Driver
spring.datasource.druid.master.url=jdbc:mysql://127.0.0.1:3306/node2?useUnicode=true&characterEncoding=UTF-8&allowMultiQueries=true&autoReconnect=true&useSSL=false
spring.datasource.druid.master.username=root
spring.datasource.druid.master.password=123456
 
 
spring.datasource.druid.slave.driver-class-name=com.mysql.jdbc.Driver
spring.datasource.druid.slave.url=jdbc:mysql://127.0.0.1:3306/node1?useUnicode=true&characterEncoding=UTF-8&allowMultiQueries=true&autoReconnect=true&useSSL=false
spring.datasource.druid.slave.username=root
spring.datasource.druid.slave.password=123456

寫(xiě)一個(gè)DataSourceConfig.java來(lái)注入兩個(gè)bean

 @Bean
    @ConfigurationProperties("spring.datasource.druid.master")
    public DataSource masterDataSource() {
        logger.info("select master data source");
        return DruidDataSourceBuilder.create().build();
    }
 
    @Bean
    @ConfigurationProperties("spring.datasource.druid.slave")
    public DataSource slaveDataSource() {
        logger.info("select slave data source");
        return DruidDataSourceBuilder.create().build();
    }

寫(xiě)一個(gè)enum來(lái)標(biāo)識(shí)有哪些數(shù)據(jù)源

public enum DBTypeEnum {
    MASTER, SLAVE;
}

然后寫(xiě)一個(gè)ThreadLocal本地線程的管理類,用于設(shè)置當(dāng)前線程是那一個(gè)數(shù)據(jù)源

private static final ThreadLocal<DBTypeEnum> contextHolder = new ThreadLocal<>();
 
    private static final ThreadLocal<DBTypeEnum> contextHolder2 = ThreadLocal.withInitial(() -> DBTypeEnum.MASTER);
 
    public static void set(DBTypeEnum dbType) {
        contextHolder.set(dbType);
    }
 
    public static DBTypeEnum get() {
        return contextHolder.get();
    }
 
    public static void master() {
        set(DBTypeEnum.MASTER);
        logger.info("切換到master數(shù)據(jù)源");
    }
 
    public static void slave() {
        set(DBTypeEnum.SLAVE);
        logger.info("切換到slave數(shù)據(jù)源");
    }
 
    public static void cleanAll() {
        contextHolder.remove();
    }

然后寫(xiě)一個(gè)DynamicDataSource繼承AbstractRootingDataSource,重寫(xiě)它的determineCurrentLookupKey方法。

public class DynamicDataSource extends AbstractRoutingDataSource {
    private Logger logger = LogManager.getLogger(DynamicDataSource.class);
 
    @Override
    protected Object determineCurrentLookupKey() {
        logger.info("此時(shí)數(shù)據(jù)源為{}", DBContextHolder.get());
        return DBContextHolder.get();
    }
}

最后寫(xiě)一個(gè)AOP來(lái)實(shí)現(xiàn)數(shù)據(jù)源切換

@Aspect
@Order(1)
@Component
public class DataSourceAop {
 
    private Logger logger = LogManager.getLogger(DataSourceAop.class);
 
    @Pointcut("(execution(* com.springboot.demo.service..*.select*(..)) " +
            "|| execution(* com.springboot.demo.service..*.find*(..)) " +
            "|| execution(* com.springboot.demo.service..*.get*(..)))")
    public void readPointcut() {
        logger.info("read only operate ,into slave db");
    }
 
    @Pointcut("execution(* com.springboot.demo.service..*.insert*(..)) " +
            "|| execution(* com.springboot.demo.service..*.update*(..)) " +
            "|| execution(* com.springboot.demo.service..*.delete*(..)) ")
    public void writePointcut() {
        logger.info("read or write operate ,into master db");
    }
 
    @Before("readPointcut()")
    public void read() {
        logger.info("read operate");
        DBContextHolder.slave();
    }
 
    @Before("writePointcut()")
    public void write() {
        logger.info("write operate");
        DBContextHolder.master();
    }
 
    @After("writePointcut(),readPointcut()")
    public void clean() {
        logger.info("dataSource cleanAll");
        DBContextHolder.cleanAll();
    }
}

注意:這里只是使用了偷懶的方法,對(duì)于service里面的select、get、find前綴的方法都使用從庫(kù),對(duì)于insert、update和delete方法都使用主庫(kù)。

可以使用注解如下來(lái)進(jìn)行優(yōu)化:

@Retention(RetentionPolicy.RUNTIME)
@Target(ElementType.METHOD)
public @interface DataSource {
 
    @AliasFor("dataSource")
    DBTypeEnum value() default DBTypeEnum.MASTER;
 
    DBTypeEnum dataSource() default DBTypeEnum.MASTER;

}

使用此注解來(lái)放入到service方法上,

@DataSource(DBTypeEnum.SLAVE)

然后AOP方法修改為:

private static final String POINT = "execution (* com.springboot.demo.service.*.*(..))";
 
 
 @Around(POINT)
    public Object dataSourceAround(ProceedingJoinPoint joinPoint) throws Throwable {
        Object[] args = joinPoint.getArgs();
        Object obj;
        Object target = joinPoint.getTarget();
        String methodName = joinPoint.getSignature().getName();
        Class clazz = target.getClass();
        Class<?>[] parameterTypes = ((MethodSignature) joinPoint.getSignature()).getMethod().getParameterTypes();
        boolean isDynamicDataSourceMethod = false;
        try {
            Method method = clazz.getMethod(methodName, parameterTypes);
            DataSources currentDataSource = null;
            if (method != null && method.isAnnotationPresent(DataSource.class)) {
                isDynamicDataSourceMethod = true;
                currentDataSource = method.getAnnotation(DataSource.class).value();
                DataSourceTypeManager.set(currentDataSource);
                log.info("DataSourceInterceptor Switch DataSource To {}",currentDataSource);
            }
            obj = joinPoint.proceed(args);
            if (isDynamicDataSourceMethod) {
                log.info("DataSourceInterceptor DataSource {} proceed",currentDataSource);
            }
        } finally {
            if (isDynamicDataSourceMethod) {
                DataSourceTypeManager.reset();
                log.info("DataSourceInterceptor Reset DataSource To {}",DataSourceTypeManager.get());
            }
        }
        return obj;
    }

到此這篇關(guān)于springboot結(jié)合mysql主從來(lái)實(shí)現(xiàn)讀寫(xiě)分離的方法示例的文章就介紹到這了,更多相關(guān)springboot 讀寫(xiě)分離內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!

相關(guān)文章

  • Activiti流程引擎對(duì)象及配置原理解析

    Activiti流程引擎對(duì)象及配置原理解析

    這篇文章主要介紹了Activiti流程引擎對(duì)象及配置原理解析,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下
    2020-03-03
  • SpringBoot擴(kuò)展點(diǎn)EnvironmentPostProcessor實(shí)例詳解

    SpringBoot擴(kuò)展點(diǎn)EnvironmentPostProcessor實(shí)例詳解

    這篇文章主要介紹了SpringBoot擴(kuò)展點(diǎn)EnvironmentPostProcessor的相關(guān)知識(shí),本文通過(guò)實(shí)例代碼給大家介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下
    2022-04-04
  • 詳解Java中的pinpoint1.8.5安裝及使用指南

    詳解Java中的pinpoint1.8.5安裝及使用指南

    pinpoint是開(kāi)源在github上的一款A(yù)PM監(jiān)控工具,它是用Java編寫(xiě)的,用于大規(guī)模分布式系統(tǒng)監(jiān)控。這篇文章主要介紹了pinpoint1.8.5安裝及使用指南,非常不錯(cuò),具有一定的參考借鑒價(jià)值,需要的朋友可以參考下
    2019-10-10
  • Java?Stream?API與函數(shù)式編程的實(shí)戰(zhàn)詳解

    Java?Stream?API與函數(shù)式編程的實(shí)戰(zhàn)詳解

    Java?8引入的Stream?API和函數(shù)式編程特性,徹底改變了Java開(kāi)發(fā)者編寫(xiě)代碼的方式,本文將深入探討Java?Stream?API與函數(shù)式編程的核心概念,最佳實(shí)踐以及性能優(yōu)化技巧,感興趣的小伙伴可以了解下
    2025-06-06
  • Java中清空集合列表元素的四種方法

    Java中清空集合列表元素的四種方法

    Java清空列表有多種方式,包括clear()高效直接、創(chuàng)建新列表需注意引用、removeAll需傳入集合、循環(huán)移除效率低,下面就來(lái)介紹一下如何實(shí)現(xiàn),感興趣的可以了解一下
    2025-07-07
  • 關(guān)于json解析多層嵌套并轉(zhuǎn)為對(duì)應(yīng)類(List)

    關(guān)于json解析多層嵌套并轉(zhuǎn)為對(duì)應(yīng)類(List)

    在進(jìn)行JSON解析時(shí),遇到多層嵌套結(jié)構(gòu)可通過(guò)遞歸或?qū)S脦?kù)來(lái)實(shí)現(xiàn),重要的是將嵌套的JSON對(duì)象準(zhǔn)確轉(zhuǎn)化為對(duì)應(yīng)的Java類,通常需要依賴如Gson或Jackson等庫(kù),將JSONObject轉(zhuǎn)為JavaBean時(shí),關(guān)注字段匹配與數(shù)據(jù)類型轉(zhuǎn)換
    2024-10-10
  • 圖解Java線程的生命周期

    圖解Java線程的生命周期

    本文主要介紹了Java中線程的5種狀態(tài)(新建(New)、就緒(Runable)、運(yùn)行(Running)、阻塞(Blocked)和死亡(Dead))之間的轉(zhuǎn)換圖解,有需要的朋友可以參考下
    2014-10-10
  • SpringBoot小程序推送信息的項(xiàng)目實(shí)踐

    SpringBoot小程序推送信息的項(xiàng)目實(shí)踐

    本文主要介紹了SpringBoot小程序推送信息的項(xiàng)目實(shí)踐,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧
    2022-04-04
  • Java SpringBoot模板引擎之 Thymeleaf入門(mén)詳解

    Java SpringBoot模板引擎之 Thymeleaf入門(mén)詳解

    jsp有著強(qiáng)大的功能,能查出一些數(shù)據(jù)轉(zhuǎn)發(fā)到JSP頁(yè)面以后,我們可以用jsp輕松實(shí)現(xiàn)數(shù)據(jù)的顯示及交互等,包括能寫(xiě)Java代碼。但是,SpringBoot首先是以jar的方式,不是war;其次我們的tomcat是嵌入式的,所以現(xiàn)在默認(rèn)不支持jsp
    2021-10-10
  • mybatis攔截器實(shí)現(xiàn)通用權(quán)限字段添加的方法

    mybatis攔截器實(shí)現(xiàn)通用權(quán)限字段添加的方法

    這篇文章主要給大家介紹了關(guān)于mybatis攔截器實(shí)現(xiàn)通用權(quán)限字段添加的相關(guān)資料,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家學(xué)習(xí)或者使用mybatis具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面來(lái)一起學(xué)習(xí)學(xué)習(xí)吧
    2019-09-09

最新評(píng)論

铁力市| 名山县| 安阳市| 海兴县| 醴陵市| 镇原县| 玉林市| 象州县| 西充县| 汶川县| 神木县| 盈江县| 清水县| 海原县| 房山区| 伽师县| 青神县| 闸北区| 扬州市| 区。| 天祝| 白玉县| 建阳市| 南皮县| 梅州市| 寻甸| 普兰县| 溧阳市| 清新县| 内丘县| 龙里县| 镶黄旗| 大渡口区| 大安市| 墨脱县| 朝阳市| 肥城市| 蓬安县| 石屏县| 平凉市| 石柱|