崛起于Springboot2.X + mysql读写分离升级版(22)

《SpringBoot2.X心法总纲》java

      介绍:以前写了一篇博客关于mysql的读写分离,那个须要配置多个类,现在读写分离升级了,咱们不须要配置任何java配置文件类就能够,由于有人为咱们封装了,咱们只管添加依赖就行了。mysql

注意:若是您看的不明白,能够去看下以前我写的读写分离,会发现简单不少,读写分离Mysqlgit

一、添加pom依赖

<dependency>
  <groupId>com.alibaba</groupId>
  <artifactId>druid-spring-boot-starter</artifactId>
  <version>1.1.10</version>
</dependency>
<dependency>
  <groupId>com.baomidou</groupId>
  <artifactId>dynamic-datasource-spring-boot-starter</artifactId>
  <version>1.4.0</version>
</dependency>
<dependency>
  <groupId>com.zaxxer</groupId>
  <artifactId>HikariCP</artifactId>
  <version>2.7.0</version>
</dependency>

添加三个依赖,dynamic-datasource-spring-boot-starter 这个是数据库读写分离的主要依赖,druid-spring-boot-starter 咱们使用druid数据库链接池,从库默认HikariCP数据库链接池,Springboot默认数据库链接池就是HikariCPspring

二、添加配置文件

spring:
  datasource:
    druid:
      stat-view-servlet:
        loginUsername: admin
        loginPassword: 123456
    dynamic:
      master:
        username: 
        password: 
        driver-class-name: com.mysql.jdbc.Driver
        url: jdbc:mysql://localhost:3306/point02?characterEncoding=utf8&useSSL=false
        druid:
          initial-size: 3
          max-active: 8
          min-idle: 2
          max-wait: -1
          min-evictable-idle-time-millis: 30000
          max-evictable-idle-time-millis: 30000
          time-between-eviction-runs-millis: 0
          validation-query: select 1
          validation-query-timeout: -1
          test-on-borrow: false
          test-on-return: false
          test-while-idle: true
          pool-prepared-statements: true
          max-open-prepared-statements: 100
          filters: stat,wall
          share-prepared-statements: true
      slave:
        one:
          username: 
          password: 
          driver-class-name: com.mysql.jdbc.Driver
          url: jdbc:mysql://localhost:3306/point02?characterEncoding=utf8&useSSL=false
        two:
          username: 
          password: 
          driver-class-name: com.mysql.jdbc.Driver
          url: jdbc:mysql://localhost:3306/point02?characterEncoding=utf8&useSSL=false
          druid:
            initial-size: 2
            max-active: 6
        three:
          username: 
          password: 
          driver-class-name: com.mysql.jdbc.Driver
          url: jdbc:mysql://localhost:3306/score?characterEncoding=utf8&useSSL=false
          druid:
            initial-size: 3
            max-active: 10
    initialization-mode: always

三、使用 @DS 切换数据源

@DS 能够注解在方法上和类上,同时存在方法注解优先于类上注解,强烈建议注解在service实现或mapper接口方法上。sql

注解 结果
没有@DS 主库
@DS("slave") 存在slave指定slave,不存在主库
@DS 根据DynamicDataSourceStrategy策略,选择一个从库。默认负载均衡策略。
注意

force-master 会判断当前方法和类上是否有@Transational注解,若是有会强制主数据库

 

@DS("one") @DS("two") 表示使用的从库,one指使用从库one,two之使用从库two指的数据库
@DS
public interface UserMapper {

  @Insert("INSERT INTO t_employee (name,cert_num) values (#{name},#{age})")
  boolean addUser(@Param("name") String name, @Param("age") Integer age);

  @Update("UPDATE t_employee set name=#{name}, cert_num=#{age} where employee_id =#{id}")
  boolean updateUser(@Param("id") Integer id, @Param("name") String name, @Param("age") Integer age);

  @Delete("DELETE from t_employee where employee_id =#{id}")
  boolean deleteUser(@Param("id") Integer id);

  @Select("SELECT * FROM t_employee")
  List<User> selectAll();

}
@DS("three")
public interface ScoreMapper {

    @Select({
            "select * from d_import_original_mobile"
    })
    List<Mobile> getAll();
}

在mapper分别使用不一样的数据源,到最后咱们均可以成功,然而,若是你使用的是xml方式的话,您能够把注解加在service层上就能够,最后写controller,就能够成功。app

四、官方详解

    感谢各位大牛的努力成果,详解请点击负载均衡

五、总结

三个依赖+一个配置文件+一个注解(@DS)==实现mysql读写分离。spring-boot

相关文章
相关标签/搜索