Учебное пособие по Sharding-JDBC: Spring Boot интегрирует Sharding-JDBC для разделения чтения и записи

Введение в Sharding-JDBC

Sharding-JDBC — это промежуточное ПО для распределенных баз данных. Sharding-JDBC, Sharding-Proxy и Sharding-Sidecar (запланировано) — это 3 независимых продукта, которые имеют одинаковые Сформируйте ShardingSphere. Sharding-JDBC позиционируется как облегченный Java-фреймворк, использующий клиент для прямого подключения к базе данных, его можно понимать как расширенную версию драйвера JDBC, которая полностью совместима с JDBC и различными ORM-фреймворками.

• Работает с любой инфраструктурой ORM на основе Java, такой как: JPA, Hibernate, Mybatis, Spring JDBC Template или с использованием JDBC напрямую.
• На основе любого стороннего пула подключений к базе данных, например: DBCP, C3P0, BoneCP, Druid, HikariCP и т. д.
• Поддерживается любая база данных, реализующая спецификацию JDBC. В настоящее время поддерживаются MySQL, Oracle, SQLServer и PostgreSQL.

Схема архитектуры выглядит следующим образом:

Поддерживаются следующие эффекты:

• Подбиблиотека и подтаблица
• разделение чтения-записи
• гибкие дела
• Распределенный первичный ключ
• Возможности распределенного управления

Инженерная подготовка

В предыдущей статье я подробно объяснил, как построить разделение чтения и записи в Mysql 5.7, и оно было построено. Подробности следующие:

тип базы данных	база данных	ip
хозяин	cool	10.0.0.3
от	cool	10.0.0.13
от	cool	10.0.0.17

Выполните следующий скрипт инициализации базы данных в основной библиотеке:

USE `cool`;

DROP TABLE IF EXISTS `user`;

CREATE TABLE `user` (
  `id` int(12) NOT NULL AUTO_INCREMENT,
  `username` varchar(12) NOT NULL,
  `password` varchar(30) NOT NULL,
  PRIMARY KEY (`id`),
  UNIQUE KEY `idx-username` (`username`)
) ENGINE=InnoDB AUTO_INCREMENT=12 DEFAULT CHARSET=utf8;

В предыдущей статье была построена база данных master-slave, поэтому после выполнения приведенного выше скрипта две подчиненные библиотеки также должны иметь пользовательские таблицы.

Объяснение случая

В этой статье объясняется случай использования Spring Boot 2.0.3+MyBatis+Druid+Sharding-JDBC+MySQL для разделения чтения и записи. Для генерации кода части Mybatis см. https://github.com/forezp/mybatis-generator здесь, а конфигурация и код части Mybatis находятся здесь. Я не буду объяснять это подробно, вы можете просмотреть исходный код для деталей. Структура проекта показана на следующем рисунке:

Внесите следующие зависимости в pom-файл проекта, в том числе spring-boot-starter-web для веб-стартера Spring Boot, mybatis-spring-boot-starter для стартера mybatis, Подключение mysql к машине и пул соединений Druid зависит от druid-spring-boot-starter, а запуск sharding-jdbc зависит от sharding-jdbc-spring-boot-starter. код показывает, как показано ниже:

  <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

        <dependency>
            <groupId>org.mybatis.spring.boot</groupId>
            <artifactId>mybatis-spring-boot-starter</artifactId>
            <version>1.3.2</version>
        </dependency>

        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
        </dependency>

        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>druid-spring-boot-starter</artifactId>
            <version>1.1.10</version>
        </dependency>

        <dependency>
            <groupId>io.shardingsphere</groupId>
            <artifactId>sharding-jdbc-spring-boot-starter</artifactId>
            <version>3.1.0.M1</version>
        </dependency>

Выполните следующую настройку в файле конфигурации проекта весенней загрузки application.yml:

sharding:
  jdbc:
    dataSource:
      names: db-test0,db-test1,db-test2
      # 配置主库
      db-test0: #org.apache.tomcat.jdbc.pool.DataSource
        type: com.alibaba.druid.pool.DruidDataSource
        driverClassName: com.mysql.jdbc.Driver
        url: jdbc:mysql://10.0.0.3:3306/cool?useUnicode=true&characterEncoding=utf8&tinyInt1isBit=false&useSSL=false&serverTimezone=GMT
        username: root
        password:
        #最大连接数
        maxPoolSize: 20
      db-test1: # 配置第一个从库
        type: com.alibaba.druid.pool.DruidDataSource
        driverClassName: com.mysql.jdbc.Driver
        url: jdbc:mysql://10.0.0.13:3306/cool?useUnicode=true&characterEncoding=UTF-8&allowMultiQueries=true&useSSL=false&serverTimezone=GMT
        username: root
        password:
        maxPoolSize: 20
      db-test2: # 配置第二个从库
        type: com.alibaba.druid.pool.DruidDataSource
        driverClassName: com.mysql.jdbc.Driver
        url: jdbc:mysql://10.0.0.17:3306/cool?useUnicode=true&characterEncoding=UTF-8&allowMultiQueries=true&useSSL=false&serverTimezone=GMT
        username: root
        password:
        maxPoolSize: 20
    config:
      masterslave: # 配置读写分离
        load-balance-algorithm-type: round_robin # 配置从库选择策略，提供轮询与随机，这里选择用轮询//random 随机 //round_robin 轮询
        name: db1s2
        master-data-source-name: db-test0
        slave-data-source-names: db-test1,db-test2
    props:
      sql: # 开启SQL显示，默认值: false，注意：仅配置读写分离时不会打印日志！！！
        show: true

sharding.jdbc.dataSource.names настраивает имя базы данных, которое является именем нескольких источников данных. sharding.jdbc.dataSource настраивает несколько источников данных. Вам необходимо настроить имя базы данных, которое соответствует приведенной выше конфигурации. И конфигурация данных, включая тип пула соединений, коннектор, адрес базы данных, Информация о пароле учетной записи базы данных и т. д. Алгоритм балансировки нагрузки для запроса типа sharding.jdbc.config.masterslave.load-balance-algorithm.В настоящее время существует два алгоритма: round_robin (циклический перебор) и random (случайный). sharding.jdbc.config.masterslave.master-data-source-name Имя главного источника данных. sharding.jdbc.config.masterslave.slave-data-source-names из имен источников данных, разделенных запятыми.

Верификация случая

Пишем 2 интерфейса, код такой:

@RestController
public class UserController {

    @Autowired
    private UserService userService;

    @GetMapping("/users")
    public Object list() {
        return userService.list();
    }

    @GetMapping("/add")
    public Object add(@RequestParam Integer id,@RequestParam String username,@RequestParam String  password) {
        User user = new User();
        user.setId(id);
        user.setUsername(username);
        user.setPassword(password);
        return userService.addUser(user);
    }
}

В предыдущей статье журнал CRUD базы данных был включен, а каталог журнала находится в каталоге /var/lib/mysql.

Вызвав два интерфейса, можно просмотреть лог вставленных данных в лог-директорию хоста, соответствующую основной библиотеке:

2019-06-20T02:50:25.183174Z	 2030 Query	select @@session.transaction_read_only
2019-06-20T02:50:25.193506Z	 2030 Query	INSERT INTO user (
          id, username, password
        )
        VALUES (
        134,
        'forezp134',
        '1233edwd'
        )

Просмотрите журнал данных запроса из каталога журнала хоста, соответствующего библиотеке:

2019-06-20T02:41:28.450643Z	 7367 Query	SELECT u.* FROM user u

Это показывает, что Sharding-JDBC реализует разделение базы данных на чтение и запись.

Загрузка исходного кода

GitHub.com/forephotos/День SP…

использованная литература

GitHub.com/Apache/Inc U…

Убейте верхнюю сферу.Apache.org/document/…

GitHub.com/Apache/Inc U…