SpringBoot プロジェクトで MySQL の読み取りと書き込みの分離を実現する方法

1. MySQL マスター/スレーブ レプリケーション

しかし、注意深く見てみると、すべてのプロジェクトが単一のデータベースを使用している場合、

• すべての読み取りおよび書き込みのプレッシャーは 1 つのデータベースによって負担されます。高圧

• データベース サーバーのディスクが破損しています。データが失われます。単一障害点です。

上記の 2 つの問題を解決するには、次の 2 つを準備できます (詳細) MySQL、1 つのマスター (Master) サーバー、スレーブ (Slave) サーバー、および データ変更 (書き込み、更新、削除操作)メイン データベースにはスレーブ データベースへの 同期 が必要です (マスター/スレーブ レプリケーション)。ユーザーがプロジェクトにアクセスすると、書き込み操作 (挿入、更新、削除) の場合は、メイン ライブラリを直接操作します。読み取り操作##の場合は、メイン ライブラリを直接操作します。 # ( を選択) してスレーブライブラリを直接操作する この構造が 読み書き分離

です。

この読み書き分離構造では、複数のスレーブ ライブラリが存在する可能性があります

1.1. はじめに

MySQL マスター スレーブ レプリケーションは、 非同期レプリケーション プロセスであり、基礎となる層は、Mysql データベースに付属する binary log 関数に基づいています。これは、1 つ以上の MySQL データベース (スレーブ、つまり スレーブ ライブラリ) が別の MySQL データベース (マスター、つまり メイン ライブラリ) からログをコピーし、ログを取得してそれを自分自身に適用すると、最終的に スレーブ ライブラリ のデータが メイン ライブラリ

のデータと一致していることがわかります。 MySQL マスター/スレーブ レプリケーションは MySQL データベースの組み込み機能であり、サードパーティ ツールを使用する必要はありません。

バイナリ ログ:

バイナリ ログ (BINLOG) には、すべての DDL (データ定義言語) ステートメントと DML (データ操作言語) ステートメントが記録されますが、データ クエリ ステートメントは含まれません。このログは災害時のデータ復旧において非常に重要な役割を果たし、MySQL のマスター/スレーブ レプリケーションはこのバイナリ ログを通じて実装されます。デフォルトでは、MySQL はこのログを有効にしません。

MySQL レプリケーション プロセスは 3 つのステップに分かれています:

• MySQL マスターはデータ変更をバイナリ ログに書き込みます ( binary log

  )

• スレーブはマスターのバイナリ ログをリレー ログにコピーします (リレー ログ

  )

• スレーブはリレー ログ内のイベントをやり直し、データは独自のデータに変更されます

1.2. マスター/スレーブ ライブラリの構築

環境をセットアップする前に、準備する必要がありますサーバーが 2 つあります。裕福な生活を送っており、2 つのクラウド サーバーを使用している場合は、セキュリティ グループ、つまりファイアウォールを開くことを忘れないでください。私より良い生活を送っているにもかかわらず仮想マシンを使用している場合は、最初から始めないことを忘れないでください。メモリが多すぎます。ブルー スクリーンです (どうしてわかるかは聞かないでください)

データベースのインストールとファイアウォールの操作についてはここでは説明しません。リソースはたくさんあると思いますマスター/スレーブ ライブラリを構築するとき、MySQL のバージョンは一貫している必要があるとインターネットで時々見かけましたが、あまり気にせず、以前の MySQL で操作していました。それは自分で確認できます。

1.2.1. メイン ライブラリの設定

サーバー: 192.168.150.100 (これは仮想マシンの IP ですので、ハッキングしないでください)# #1. Mysql データベースの設定ファイル vim /etc/my.cnf を変更します

#

在打开的文件中加入下面两行，其中的server-id不一定是100，确保唯一即可
log-bin=mysql-bin   #[必须]启用二进制日志
server-id=100       #[必须]服务器唯一ID

##2. Mysql サービスを再起動します

こちら MySQL を再起動するには 3 つの方法があります。最も簡単なのは間違いなく、オフにしてからオンにすることです:

net stop mysql;net start mysql;
systemctl restart mysqld
service mysqld restart

3. データ同期用のユーザーを作成し、## を承認します。 #MySQL にログインした後 次のコマンドを実行できるようにします。これは SQL コマンドであるため、Linux はこれが何であるかを知りません。

GRANT REPLICATION SLAVE ON *.* to '用户名'@'开放的地址' identified by '密码';
eg: GRANT REPLICATION SLAVE ON *.* to 'masterDb'@'%' identified by 'Master@123456';
记得刷一下权限
FLUSH PRIVILEGES;

4. マスター同期ステータスを確認します

次のコマンドはまだ SQL コマンドであるため、現時点では MySQL

を終了する必要はありません。次の SQL を実行すると、後で必要な 2 つの重要なパラメータを取得できます。

show master status;

この SQL ステートメントを実行した後は、== メイン データベースを再度操作しないでください。もうメインライブラリを運営しないでください！もうメインライブラリを運営しないでください！ ==メインライブラリを操作すると、赤枠内の 2 つの属性値が変化する可能性があるため、重要なことは 3 回言ってください

.後でエラーが発生した場合、2 つの属性値と同じになる可能性がありますここにセントがあります。関連しています。

1.2.2、从库配置

服务器：192.168.150.101（别试了黑不了的，这也是虚拟机的ip）

1、 修改Mysql数据库的配置文件 vim /etc/my.cnf

这里要注意server-id和主库以及其他从库都不能相同，否则后面将会配置不成功。

2、重启Mysql服务

这里有三个方法都能重启MySQL，最简单的无疑就是一关一开：

net stop mysql;net start mysql;
systemctl restart mysqld
service mysqld restart

3、设置主库地址及同步位置

登录进去MySQL之后才能够执行下面的命令，因为这是SQL命令

设置主库地址和同步位置
change master to master_host='192.168.150.100',master_user='masterDb',master_password='Master@123456',master_log_file='mysql-bin.000010',master_log_pos=68479;
记得记得开启从库配置
start slave;

参数说明：

• master_host: 主库的 IP地址

• master_user: 访问主库进行主从复制的 用户名 ( 上面在主库创建的 )

• master_password: 访问主库进行主从复制的用户名对应的 密码

• master_log_file: 从哪个 日志文件 开始同步 ( 即1.2.1中第4步获取的 File )

• master_log_pos: 从指定日志文件的哪个 位置 开始同步 ( 即1.2.1中第4步获取的 Position )

4、查看从数据库的状态

这个时候还 不用退出MySQL ，因为下面的命令还是SQL命令，执行下面的SQL，可以看到从库的状态信息。通过状态信息中的 Slave_IO_running 和 Slave_SQL_running 可以看出主从同步是否就绪，如果这两个参数全为 Yes ，表示主从同步已经配置完成。

show slave status\G;

1.3、坑位介绍

1.3.1、UUID报错

这可能是由于linux 是复制出来的，MySQL中还有一个 server_uuid 是一样的，我们也需要修改。 vim /var/lib/mysql/auto.cnf

1.3.2、server_id报错

这应该就是各位大牛设置server_id的时候不小心设置相同的id了，修改过来就行，步骤在上面的配置中。

1.3.3、同步异常解决

这是狗子在操作过程中搞出来的一个错误……

出错的原因是在主库中删除了用户信息，但是在从库中同步的时候失败导致同步停止，下面记录自己的操作（是在进入MySQL的操作且是从库）。

MASTER_LOG_POS

STOP SLAVE;
SET GLOBAL SQL_SLAVE_SKIP_COUNTER=1;
START SLAVE;
SHOW SLAVE STATUS\G;

在数据库中操作时，一定要注意当前所在的数据库是哪个，作为一个良好的实践：在SQL语句前加 USE dbname 。

操作不规范，亲人两行泪……

2、项目中实现

2.1、ShardingJDBC

Sharding-JDBC定位为 轻量级Java框架 ，在Java的JDBC层提供的额外服务。 它使用客户端直连数据库，以 jar包 形式提供服务，无需额外部署和依赖，可理解为增强版的JDBC驱动， 完全兼容JDBC和各种ORM框架 。

使用Sharding-JDBC可以在程序中轻松的实现数据库 读写分离 。

Sharding-JDBC具有以下几个特点：

• 适用于任何基于JDBC的ORM框架，如：JPA, Hibernate, Mybatis, Spring JDBC Template或直接使用JDBC。

• 支持任何第三方的数据库连接池，如：DBCP, C3P0, BoneCP, Druid, HikariCP等。

• 支持任意实现JDBC规范的数据库。目前支持MySQL，Oracle，SQLServer，PostgreSQL以及任何遵循SQL92标准的数据库。

下面我们将用ShardingJDBC在项目中实现MySQL的读写分离。

2.2、依赖导入

在pom.xml文件中导入ShardingJDBC的依赖坐标

<!--sharding-jdbc-->
<dependency>
    <groupId>org.apache.shardingsphere</groupId>
    <artifactId>sharding-jdbc-spring-boot-starter</artifactId>
    <version>4.0.0-RC1</version>
</dependency>

2.3、配置文件

在application.yml中增加数据源的配置

spring:
  shardingsphere:
    datasource:
      names:
        master,slave
      # 主数据源
      master:
        type: com.alibaba.druid.pool.DruidDataSource
        driver-class-name: com.mysql.cj.jdbc.Driver
        url: jdbc:mysql://192.168.150.100:3306/db_test?useUnicode=true&characterEncoding=utf-8&useSSL=false
        username: root
        password: 123456
      # 从数据源
      slave:
        type: com.alibaba.druid.pool.DruidDataSource
        driver-class-name: com.mysql.cj.jdbc.Driver
        url: jdbc:mysql://192.168.150.101:3306/db_test?useUnicode=true&characterEncoding=utf-8&useSSL=false
        username: root
        password: 123456
    masterslave:
      # 读写分离配置，设置负载均衡的模式为轮询
      load-balance-algorithm-type: round_robin
      # 最终的数据源名称
      name: dataSource
      # 主库数据源名称
      master-data-source-name: master
      # 从库数据源名称列表，多个逗号分隔
      slave-data-source-names: slave
    props:
      sql:
        show: true #开启SQL显示，默认false
  # 覆盖注册bean，后面创建数据源会覆盖前面创建的数据源
  main:
    allow-bean-definition-overriding: true

2.4、测试跑路

这时我们就可以对我们项目中的配置进行一个测试，下面分别调用一个更新接口和一个查询接口，通过查看日志中记录的数据源来判断是否能够按照我们预料中的跑。

• 更新操作（写操作）

• 查询操作（读操作）

搞定！ ！ ！程式正常按照我們預期的成功跑起來了，成功借助ShardingJDBC在我們專案中實現了資料庫的讀寫分離。

以上がSpringBoot プロジェクトで MySQL の読み取りと書き込みの分離を実現する方法の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。