欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

深入探討Druid動(dòng)態(tài)數(shù)據(jù)源的實(shí)現(xiàn)方式

 更新時(shí)間：2023年08月13日 15:18:38   作者：vker  
Druid是一個(gè)高性能的實(shí)時(shí)分析數(shù)據(jù)庫(kù),它可以處理大規(guī)模數(shù)據(jù)集的快速查詢和聚合操作,在Druid中,動(dòng)態(tài)數(shù)據(jù)源是一種可以在運(yùn)行時(shí)動(dòng)態(tài)添加和刪除的數(shù)據(jù)源,使用動(dòng)態(tài)數(shù)據(jù)源,您可以在Druid中輕松地處理不斷變化的數(shù)據(jù)集,本文講給大家介紹一下Druid動(dòng)態(tài)數(shù)據(jù)源該如何實(shí)現(xiàn)

一、應(yīng)用場(chǎng)景

  • 主從復(fù)制
  • 讀寫分離
  • 分庫(kù)分表

主從復(fù)制與讀寫分離通常是一起使用的。

二、實(shí)現(xiàn)方式

1、技術(shù)棧

  • SpringBoot 2.6.13
  • Druid 1.2.16
  • Spring JDBC
  • MySQL 8.0
  • AOP動(dòng)態(tài)代理

2、Maven 依賴

下邊依賴放入同一個(gè) pom.xml 文件就可以

<properties>
    <java.version>11</java.version>
    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
    <spring-boot.version>2.6.13</spring-boot.version>
</properties>
<dependencies>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-jdbc</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-aop</artifactId>
    </dependency>
    <dependency>
        <groupId>com.mysql</groupId>
        <artifactId>mysql-connector-j</artifactId>
        <scope>runtime</scope>
    </dependency>
    <dependency>
        <groupId>com.alibaba</groupId>
        <artifactId>druid-spring-boot-starter</artifactId>
        <version>1.2.16</version>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-test</artifactId>
        <scope>test</scope>
    </dependency>
</dependencies>
<dependencyManagement>
    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-dependencies</artifactId>
            <version>${spring-boot.version}</version>
            <type>pom</type>
            <scope>import</scope>
        </dependency>
    </dependencies>
</dependencyManagement>

3、數(shù)據(jù)庫(kù)結(jié)構(gòu)

數(shù)據(jù)庫(kù)結(jié)構(gòu)非常簡(jiǎn)單，主要實(shí)現(xiàn)思想，復(fù)雜的都是同一個(gè)操作方式。

image.png

（1）數(shù)據(jù)庫(kù)：db_dynamic1

DROP TABLE IF EXISTS `tb_user`;
CREATE TABLE `tb_user` (
  `id` bigint NOT NULL AUTO_INCREMENT,
  `username` varchar(50) DEFAULT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=4 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci;
BEGIN;
INSERT INTO `tb_user` (`id`, `username`) VALUES (1, '張三');
INSERT INTO `tb_user` (`id`, `username`) VALUES (2, '李四');
INSERT INTO `tb_user` (`id`, `username`) VALUES (3, '王五');
COMMIT;
SET FOREIGN_KEY_CHECKS = 1;

（2）數(shù)據(jù)庫(kù)：db_dynamic2

DROP TABLE IF EXISTS `tb_user`;
CREATE TABLE `tb_user` (
  `id` int NOT NULL AUTO_INCREMENT,
  `username` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci DEFAULT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=4 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci;
BEGIN;
INSERT INTO `tb_user` (`id`, `username`) VALUES (1, 'Vker');
INSERT INTO `tb_user` (`id`, `username`) VALUES (2, 'Jack');
INSERT INTO `tb_user` (`id`, `username`) VALUES (3, 'Lucy');
COMMIT;
SET FOREIGN_KEY_CHECKS = 1;

4、application.yml 配置文件

將下面配置文件的 url , username , password 換成你自己的

spring:
  datasource:
    type: com.alibaba.druid.pool.DruidDataSource
    druid:
      master:
        driver-class-name: com.mysql.cj.jdbc.Driver
        url: jdbc:mysql://127.0.0.1:3306/db_dynamic1?serverTimezone=UTC&useUnicode=true&characterEncoding=UTF8&useSSL=false
        username: root
        password: root_root
      slave:
        driver-class-name: com.mysql.cj.jdbc.Driver
        url: jdbc:mysql://127.0.0.1:3306/db_dynamic2?serverTimezone=UTC&useUnicode=true&characterEncoding=UTF8&useSSL=false
        username: root
        password: root_root
      initial-size: 1
      min-idle: 1
      max-active: 20
      test-on-borrow: true

5、定義一個(gè) DataSources 注解

這個(gè)注解主要用于多數(shù)據(jù)源的選擇，默認(rèn)是 master 

@Target({ElementType.METHOD, ElementType.TYPE})
@Retention(RetentionPolicy.RUNTIME)
public @interface DataSources {
    String value() default "master";
}

6、配置一下動(dòng)態(tài)數(shù)據(jù)源

這個(gè)類主要用于配置多數(shù)據(jù)源，不要忘記 @Primary 注解，否則會(huì)報(bào)錯(cuò)。

@Component
@Primary
public class DynamicDataSources extends AbstractRoutingDataSource {
    public static ThreadLocal<String> name = new ThreadLocal<>();
    @Resource
    DataSource master;
    @Resource
    DataSource slave;
    @Override
    protected Object determineCurrentLookupKey() {
        return name.get();
    }
    @Override
    public void afterPropertiesSet() {
        Map<Object, Object> ds = new HashMap<>();
        ds.put("master", master);
        ds.put("slave", slave);
        super.setTargetDataSources(ds);
        super.setDefaultTargetDataSource(master);
        super.afterPropertiesSet();
    }
}

7、寫一個(gè)基于 DataSources 注解的動(dòng)態(tài)代理

這個(gè)動(dòng)態(tài)代理用于檢查類或者方法上的 @DataSources 注解，取到注解中的 value 值，將值傳入動(dòng)態(tài)數(shù)據(jù)源配置類 DynamicDataSources 的 ThreadLocal 中，用于選擇數(shù)據(jù)源。

@Component
@Aspect
public class DynamicDataSourcesAspect {
    Logger logger = LoggerFactory.getLogger(DynamicDataSourcesAspect.class);
    @Before("@annotation(dataSources)")
    public void before(DataSources dataSources) {
        String value = dataSources.value();
        DynamicDataSources.name.set(value);
        logger.info("進(jìn)入AOP代理: {}", value);
    }
}

8、再來(lái)寫一個(gè)讀數(shù)據(jù)庫(kù)配置信息的配置類

這個(gè)配置類主要將 application.yml 中的數(shù)據(jù)庫(kù)配置信息的配置信息進(jìn)行加載，然后使用數(shù)據(jù)源事務(wù)管理器 DataSourceTransactionManager 進(jìn)行注冊(cè)。

@Configuration
public class DynamicDataSourcesConfig {
    @Bean
    @ConfigurationProperties(prefix = "spring.datasource.druid.master")
    public DataSource master() {
        return DruidDataSourceBuilder.create().build();
    }
    @Bean
    @ConfigurationProperties(prefix = "spring.datasource.druid.slave")
    public DataSource slave() {
        return DruidDataSourceBuilder.create().build();
    }
    @Bean
    public DataSourceTransactionManager dataSourceTransactionManager1(@Qualifier("master") DataSource master) {
        DataSourceTransactionManager dataSourceTransactionManager =
                new DataSourceTransactionManager();
        dataSourceTransactionManager.setDataSource(master);
        return dataSourceTransactionManager;
    }
    @Bean
    public DataSourceTransactionManager dataSourceTransactionManager2(@Qualifier("slave") DataSource slave) {
        DataSourceTransactionManager dataSourceTransactionManager =
                new DataSourceTransactionManager();
        dataSourceTransactionManager.setDataSource(slave);
        return dataSourceTransactionManager;
    }
}

重點(diǎn)的都做完了，接下來(lái)就寫一下基本的業(yè)務(wù)層代碼吧，注釋就不寫了，我相信小伙伴們都能看懂。

1、實(shí)體類

public class User {
    private Long id;
    private String username;
   // 省略了 getter setter
}

2、Dao 數(shù)據(jù)層

public interface UserMapper {
    List<User> selectAllUser();
}
@Repository
public class UserMapperImpl implements UserMapper {
    @Resource
    private JdbcTemplate jdbcTemplate;
    @Override
    public List<User> selectAllUser() {
        String sql = "select * from tb_user";
        return jdbcTemplate.query(sql,
                new BeanPropertyRowMapper<>(User.class));
    }
}

3、Service 服務(wù)層

public interface UserService {
    List<User> list();
}
@Service
public class UserServiceImpl implements UserService {
    @Resource
    private UserMapper userMapper;
    @Override
    public List<User> list() {
        return userMapper.selectAllUser();
    }
}

4、Controller 控制層

這里說(shuō)一下，你可以將注解 @DataSources 注解放到你想使用不同數(shù)據(jù)源的方法上，如下，默認(rèn) master 可以不寫。

@RestController
public class UserController {
    @Resource
    private UserService userService;
    @GetMapping("list1")
    public List<User> list1() {
        return userService.list();
    }
    @GetMapping("list2")
    @DataSources("slave")
    public List<User> lis2t() {
        return userService.list();
    }
}

5、最后來(lái)看一下啟動(dòng)類

需要把 DataSourceAutoConfiguration 排除掉哦

@SpringBootApplication(exclude = {DataSourceAutoConfiguration.class})
public class DynamicDatasourceDemoApplication {
    public static void main(String[] args) {
        SpringApplication.run(DynamicDatasourceDemoApplication.class, args);
    }
}

6、測(cè)試結(jié)果

list1接口

image.png

list2接口

image.png

好了，以上就是動(dòng)態(tài)數(shù)據(jù)源的實(shí)現(xiàn)方式了，歡迎小伙伴們留言，下期我們看看，如何實(shí)現(xiàn) 主從復(fù)制 和 讀寫分離 。

以上就是深入探討Druid動(dòng)態(tài)數(shù)據(jù)源的實(shí)現(xiàn)方式的詳細(xì)內(nèi)容，更多關(guān)于Druid動(dòng)態(tài)數(shù)據(jù)源的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章！

相關(guān)文章

  • 如何更好的使用Java8中方法引用詳解

    如何更好的使用Java8中方法引用詳解

    在Java8中，我們可以直接通過(guò)方法引用來(lái)簡(jiǎn)寫lambda表達(dá)式中已經(jīng)存在的方法，這種特性就叫做方法引用(Method Reference)。下面這篇文章主要給大家介紹了關(guān)于如何更好的使用Java8中方法引用的相關(guān)資料，需要的朋友可以參考下。
    2017-09-09
  • SpringBoot?替換?if?的參數(shù)校驗(yàn)示例代碼

    SpringBoot?替換?if?的參數(shù)校驗(yàn)示例代碼

    Spring?Validation是對(duì)hibernate?validation的二次封裝，用于支持spring?mvc參數(shù)自動(dòng)校驗(yàn)，接下來(lái)，我們以spring-boot項(xiàng)目為例，介紹Spring?Validation的使用,需要的朋友可以參考下
    2022-12-12
  • Java Spring IOC圖文詳解

    Java Spring IOC圖文詳解

    IoC是一種讓服務(wù)消費(fèi)者不直接依賴于服務(wù)提供者的組件設(shè)計(jì)方式，是一種減少類與類之間依賴的設(shè)計(jì)原則。下面通過(guò)本文給大家分享spring中ioc的概念，感興趣的朋友一起看看吧
    2021-09-09
  • mybatis中<choose>標(biāo)簽的用法說(shuō)明

    mybatis中<choose>標(biāo)簽的用法說(shuō)明

    這篇文章主要介紹了mybatis中<choose>標(biāo)簽的用法說(shuō)明，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教
    2022-06-06
  • Netty學(xué)習(xí)教程之Netty與Marshalling結(jié)合發(fā)送對(duì)象

    Netty學(xué)習(xí)教程之Netty與Marshalling結(jié)合發(fā)送對(duì)象

    Netty是由JBOSS提供的一個(gè)Java開源框架，之前已經(jīng)給大家簡(jiǎn)單介紹了一些基礎(chǔ)與使用，下面這篇文章主要給大家介紹了關(guān)于Netty與Marshalling結(jié)合發(fā)送對(duì)象的相關(guān)資料，需要的朋友可以參考借鑒，下面來(lái)一起看看吧。
    2017-05-05
  • Java全面解析string類型的xml字符串

    Java全面解析string類型的xml字符串

    這篇文章主要介紹了Java全面解析string類型的xml字符串，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教
    2022-03-03
  • JavaWeb學(xué)習(xí)筆記之Filter和Listener

    JavaWeb學(xué)習(xí)筆記之Filter和Listener

    這篇文章主要給大家介紹了關(guān)于JavaWeb學(xué)習(xí)筆記之Filter和Listener的相關(guān)資料，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧
    2021-03-03
  • Java利用Redis實(shí)現(xiàn)消息隊(duì)列的示例代碼

    Java利用Redis實(shí)現(xiàn)消息隊(duì)列的示例代碼

    本篇文章主要介紹了Java利用Redis實(shí)現(xiàn)消息隊(duì)列的示例代碼，小編覺(jué)得挺不錯(cuò)的，現(xiàn)在分享給大家，也給大家做個(gè)參考。一起跟隨小編過(guò)來(lái)看看吧
    2017-07-07
  • 分享J2EE的13種核心技術(shù)

    分享J2EE的13種核心技術(shù)

    在本文中我將解釋支撐J2EE的13種核心技術(shù)：JDBC, JNDI, EJBs, RMI, JSP, Java servlets, XML, JMS, Java IDL, JTS, JTA, JavaMail 和 JAF，對(duì)j2ee的13種核心技術(shù)感興趣的朋友一起學(xué)習(xí)吧
    2015-11-11
  • java webservice上傳下載文件代碼分享

    java webservice上傳下載文件代碼分享

    這篇文章主要為大家詳細(xì)介紹了java webservice上傳下載文件代碼，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下
    2016-08-08

最新評(píng)論