Apache ShardingSphere Proxy5.5.0实现MySQL分库分表与读写分离

1. 前提准备

1.1 主机IP:192.168.186.77        

version: '3.8'services:mysql-master:image: mysql:latestcontainer_name: mysql-masterenvironment:MYSQL_ROOT_PASSWORD: 123456MYSQL_USER: masterMYSQL_PASSWORD: 123456MYSQL_DATABASE: db1  ports:- "3306:3306"volumes:- mysql-master-data:/var/lib/mysqlcommand: --server-id=1 --log-bin=mysql-bin --binlog-format=ROWcap_add:- SYS_NICEsecurity_opt:- seccomp:unconfinedmysql-slave:image: mysql:latestcontainer_name: mysql-slaveenvironment:MYSQL_ROOT_PASSWORD: 123456MYSQL_USER: slaveMYSQL_PASSWORD: 123456MYSQL_DATABASE: db1ports:- "3307:3306"volumes:- mysql-slave-data:/var/lib/mysqlcommand: --server-id=2 --log-bin=mysql-bin --binlog-format=ROW --relay-log=relay-bin --relay-log-index=relay-bin.indexdepends_on:- mysql-mastercap_add:- SYS_NICEsecurity_opt:- seccomp:unconfinedvolumes:mysql-master-data:mysql-slave-data:

注：3306端口扮演master数据库角色，3307端口扮演salve数据库角色。 

1.2 主机IP:192.168.186.216

version: '3.8'services:mysql-master:image: mysql:latestcontainer_name: mysql-masterenvironment:MYSQL_ROOT_PASSWORD: 123456MYSQL_USER: masterMYSQL_PASSWORD: 123456MYSQL_DATABASE: db2  ports:- "3306:3306"volumes:- mysql-master-data:/var/lib/mysqlcommand: --server-id=3 --log-bin=mysql-bin --binlog-format=ROWcap_add:- SYS_NICEsecurity_opt:- seccomp:unconfinedmysql-slave:image: mysql:latestcontainer_name: mysql-slaveenvironment:MYSQL_ROOT_PASSWORD: 123456MYSQL_USER: slaveMYSQL_PASSWORD: 123456MYSQL_DATABASE: db2  ports:- "3307:3306"volumes:- mysql-slave-data:/var/lib/mysqlcommand: --server-id=4 --log-bin=mysql-bin --binlog-format=ROW --relay-log=relay-bin --relay-log-index=relay-bin.indexdepends_on:- mysql-mastercap_add:- SYS_NICEsecurity_opt:- seccomp:unconfinedvolumes:mysql-master-data:mysql-slave-data:

 1.3 主机IP:192.168.186.216

version: '3.8'services:mysql-master:image: mysql:latestcontainer_name: mysql-masterenvironment:MYSQL_ROOT_PASSWORD: 123456MYSQL_USER: masterMYSQL_PASSWORD: 123456MYSQL_DATABASE: db3  ports:- "3306:3306"volumes:- mysql-master-data:/var/lib/mysqlcommand: --server-id=5 --log-bin=mysql-bin --binlog-format=ROWcap_add:- SYS_NICEsecurity_opt:- seccomp:unconfinedmysql-slave:image: mysql:latestcontainer_name: mysql-slaveenvironment:MYSQL_ROOT_PASSWORD: 123456MYSQL_USER: slaveMYSQL_PASSWORD: 123456MYSQL_DATABASE: db3 ports:- "3307:3306"volumes:- mysql-slave-data:/var/lib/mysqlcommand: --server-id=6 --log-bin=mysql-bin --binlog-format=ROW --relay-log=relay-bin --relay-log-index=relay-bin.indexdepends_on:- mysql-mastercap_add:- SYS_NICEsecurity_opt:- seccomp:unconfinedvolumes:mysql-master-data:mysql-slave-data:

注：每个 MySQL 实例必须有一个唯一的 server-id。这是必要的，因为在主从复制设置中，主服务器和从服务器需要能够互相识别，并避免循环复制和冲突。       

1.4 简单主从搭建过程

1.4.1 连接主服务器

1.4.2 连接从服务器 

1.4.3 配置主服务器
# 创建一个具有复制权限的用户
CREATE USER 'master_slave'@'%' IDENTIFIED BY '123456' REQUIRE SSL;
GRANT REPLICATION SLAVE ON *.* TO 'master_slave'@'%';
FLUSH PRIVILEGES;
SHOW MASTER STATUS;

1.4.4 配置从服务器
CHANGE MASTER TOMASTER_HOST ='192.168.186.216', # 主服务器的 IP 地址MASTER_USER ='master_slave', # 主服务器上配置的复制用户MASTER_PASSWORD ='123456', # 复制用户的密码MASTER_LOG_FILE ='mysql-bin.000003', # 主服务器的日志文件名MASTER_LOG_POS =920, # 日志文件的位置MASTER_SSL=1;
START SLAVE;
SHOW SLAVE STATUS;

        其余两台使用同样的方式进行配置。 

2. 安装 Apache ShardingSphere Proxy

2.1 安装合适的JDK版本

sudo apt install openjdk-8-jdk -y

2.2 验证JDK版本

java -version

liber@liber-VMware-Virtual-Platform:/home/sp$ java -version
openjdk version "1.8.0_412"
OpenJDK Runtime Environment (build 1.8.0_412-8u412-ga-1~24.04.2-b08)
OpenJDK 64-Bit Server VM (build 25.412-b08, mixed mode)

2.3 使用wget下载Apache ShardingSphere Proxy

sudo wget https://dlcdn.apache.org/shardingsphere/5.5.0/apache-shardingsphere-5.5.0-shardingsphere-proxy-bin.tar.gz

2.4 解压Apache ShardingSphere Proxy文件

 sudo tar -zxvf apache-shardingsphere-5.5.0-shardingsphere-proxy-bin.tar.gz

2.5 进入Apache ShardingSphere Proxy解压后的目录 

cd apache-shardingsphere-5.5.0-shardingsphere-proxy-bin

2.5 查看MySQL的版本 

        找台主服务器或者从服务器输入查看数据库的版本。

SELECT VERSION();

2.6 下载并安装MySQL Connector/J 8.0.27

sudo wget https://downloads.mysql.com/archives/get/p/3/file/mysql-connector-java-8.0.27.tar.gz

 

2.7 解压MySQL文件

sudo tar -zxvf mysql-connector-java-8.0.27.tar.gz

2.8 进入解压后的MySQL目录

cd mysql-connector-java-8.0.27

 2.9 将 JAR 文件放置到合适的位置

 需要将JAR文件复制到Apache ShardingSphere-Proxy解压目录的lib 目录中，因为我在Apache ShardingSphere-Proxy的解压目录中下载的MySQL压缩包，解压后只需要将JAR文件移动到上一级的lib目录即可。

sudo mv mysql-connector-java-8.0.27.jar  ../lib

  2.10 global.yaml

# 回退上一级目录
cd ..# 进入conf目录
cd conf# 编辑global.yaml文件
sudo nano global.yaml

      global.yaml 内容如下：

# 释放注解
authority:users:- user: root@%password: 123456- user: shardingpassword: 123456privilege:type: ALL_PERMITTED
sqlParser:sqlStatementCache:initialCapacity: 2000maximumSize: 65535parseTreeCache:initialCapacity: 128maximumSize: 1024
props:proxy-default-port: 3308 #修改端口，因为被占用了3307所以我修改了3308sql-show: true

2.11 创建物理表

use db1; # 每个主服务器都需要创建，只需要把db1，改db2，db3即可。CREATE TABLE t_order_0
(order_id   INT PRIMARY KEY,user_id    INT,order_date DATE,status     VARCHAR(15)
);CREATE TABLE t_order_1
(order_id   INT PRIMARY KEY,user_id    INT,order_date DATE,status     VARCHAR(15)
);

注： 每个主服务器的数据库都需要建立结构相同的物理表，只是库不一样db1，db2，db3。

2.12 database-sharding.yaml

sudo nano database-sharding.yaml
2.1.1 配置数据库源
dataSources:# 主库配置ds_77_master:url: jdbc:mysql://192.168.186.77:3306/db1?serverTimezone=UTC&useSSL=false&allowPublicKeyRetrieval=trueusername: root  # 数据库用户名password: 123456  # 数据库密码connectionTimeoutMilliseconds: 30000  # 连接超时时间，单位毫秒idleTimeoutMilliseconds: 60000  # 空闲连接超时时间，单位毫秒maxLifetimeMilliseconds: 1800000  # 连接最大生命周期，单位毫秒maxPoolSize: 50  # 连接池最大连接数minPoolSize: 1  # 连接池最小连接数# 从库配置ds_77_slave:url: jdbc:mysql://192.168.186.77:3307/db1?serverTimezone=UTC&useSSL=false&allowPublicKeyRetrieval=trueusername: slave  # 数据库用户名password: 123456  # 数据库密码connectionTimeoutMilliseconds: 30000  # 连接超时时间，单位毫秒idleTimeoutMilliseconds: 60000  # 空闲连接超时时间，单位毫秒maxLifetimeMilliseconds: 1800000  # 连接最大生命周期，单位毫秒maxPoolSize: 50  # 连接池最大连接数minPoolSize: 1  # 连接池最小连接数ds_216_master:url: jdbc:mysql://192.168.186.216:3306/db2?serverTimezone=UTC&useSSL=false&allowPublicKeyRetrieval=trueusername: rootpassword: 123456connectionTimeoutMilliseconds: 30000idleTimeoutMilliseconds: 60000maxLifetimeMilliseconds: 1800000maxPoolSize: 50minPoolSize: 1ds_216_slave:url: jdbc:mysql://192.168.186.216:3307/db2?serverTimezone=UTC&useSSL=false&allowPublicKeyRetrieval=trueusername: slavepassword: 123456connectionTimeoutMilliseconds: 30000idleTimeoutMilliseconds: 60000maxLifetimeMilliseconds: 1800000maxPoolSize: 50minPoolSize: 1ds_18_master:url: jdbc:mysql://192.168.186.18:3306/db3?serverTimezone=UTC&useSSL=false&allowPublicKeyRetrieval=trueusername: rootpassword: 123456connectionTimeoutMilliseconds: 30000idleTimeoutMilliseconds: 60000maxLifetimeMilliseconds: 1800000maxPoolSize: 50minPoolSize: 1ds_18_slave:url: jdbc:mysql://192.168.186.18:3307/db3?serverTimezone=UTC&useSSL=false&allowPublicKeyRetrieval=trueusername: slavepassword: 123456connectionTimeoutMilliseconds: 30000idleTimeoutMilliseconds: 60000maxLifetimeMilliseconds: 1800000maxPoolSize: 50minPoolSize: 1# 设置逻辑数据库名称
databaseName: my_database
2.1.2 读写分离规则
rules:- !READWRITE_SPLITTING# 定义用于读写分离的数据源配置dataSources:# 第一组读写分离规则，命名为 "readwrite_77"readwrite_77:writeDataSourceName: ds_77_master  # 指定写操作的数据源为 ds_77_master（主库）readDataSourceNames:- ds_77_slave  # 指定读操作的数据源列表，这里只包括 ds_77_slave（从库）transactionalReadQueryStrategy: PRIMARY  # 事务中的读查询策略设为 PRIMARY，即事务中所有读操作都将指向主库loadBalancerName: random  # 使用随机策略从可用的从库中选择readwrite_216:writeDataSourceName: ds_216_master  readDataSourceNames:- ds_216_slave  transactionalReadQueryStrategy: PRIMARY loadBalancerName: random  readwrite_18:writeDataSourceName: ds_18_master  # 主库readDataSourceNames:- ds_18_slave  transactionalReadQueryStrategy: PRIMARY  loadBalancerName: random  # 定义负载均衡器的配置loadBalancers:random:type: RANDOM  # 指定负载均衡器的类型为 RANDOM，随机选择读库
2.1.3 分库分表规则
- !SHARDING# 分片表的配置tables:t_order:# 定义分片表t_order在各个数据源的具体分布actualDataNodes: readwrite_77.t_order_${0..1}, readwrite_216.t_order_${0..1}, readwrite_18.t_order_${0..1}# 表的分片策略配置tableStrategy:standard:shardingColumn: order_id  # 使用订单ID作为分片键shardingAlgorithmName: t_order_inline  # 分片算法名称，指向后面定义的内联算法# 主键生成策略，用于插入操作时自动生成主键keyGenerateStrategy:column: order_id  # 主键列keyGeneratorName: snowflake  # 使用雪花算法生成主键# 默认数据库分片策略defaultDatabaseStrategy:standard:shardingColumn: user_id  # 使用用户ID作为分片键shardingAlgorithmName: database_inline  # 数据库分片使用的算法名称，指向后面定义的内联算法# 默认的表分片策略，此处未定义分片策略defaultTableStrategy:none:# 绑定表组，确保相互关联的表在同一数据库分片中bindingTables:- t_order  # 把t_order表标记为绑定表# 定义使用的分片算法shardingAlgorithms:# 定义数据库分片的内联算法database_inline:type: INLINEprops:algorithm-expression: "readwrite_${(user_id % 3 == 0) ? '77' : ((user_id % 3 == 1) ? '216' : '18')}"# 根据用户ID的值进行模3运算来决定数据分配到哪个数据源# 定义表分片的内联算法t_order_inline:type: INLINEprops:algorithm-expression: "t_order_${order_id % 2}"# 根据订单ID的值进行模2运算来决定数据存储在哪个分表# 主键生成器配置，指定使用雪花算法生成主键keyGenerators:snowflake:type: SNOWFLAKEprops:worker-id: 123  # 设置雪花算法的工作节点ID
2.1.4 完整配置信息 
dataSources:ds_77_master:url: jdbc:mysql://192.168.186.77:3306/db1?serverTimezone=UTC&useSSL=false&allowPublicKeyRetrieval=trueusername: rootpassword: 123456connectionTimeoutMilliseconds: 30000idleTimeoutMilliseconds: 60000maxLifetimeMilliseconds: 1800000maxPoolSize: 50minPoolSize: 1ds_77_slave:url: jdbc:mysql://192.168.186.77:3307/db1?serverTimezone=UTC&useSSL=false&allowPublicKeyRetrieval=trueusername: slavepassword: 123456connectionTimeoutMilliseconds: 30000idleTimeoutMilliseconds: 60000maxLifetimeMilliseconds: 1800000maxPoolSize: 50minPoolSize: 1ds_216_master:url: jdbc:mysql://192.168.186.216:3306/db2?serverTimezone=UTC&useSSL=false&allowPublicKeyRetrieval=trueusername: rootpassword: 123456connectionTimeoutMilliseconds: 30000idleTimeoutMilliseconds: 60000maxLifetimeMilliseconds: 1800000maxPoolSize: 50minPoolSize: 1ds_216_slave:url: jdbc:mysql://192.168.186.216:3307/db2?serverTimezone=UTC&useSSL=false&allowPublicKeyRetrieval=trueusername: slavepassword: 123456connectionTimeoutMilliseconds: 30000idleTimeoutMilliseconds: 60000maxLifetimeMilliseconds: 1800000maxPoolSize: 50minPoolSize: 1ds_18_master:url: jdbc:mysql://192.168.186.18:3306/db3?serverTimezone=UTC&useSSL=false&allowPublicKeyRetrieval=trueusername: rootpassword: 123456connectionTimeoutMilliseconds: 30000idleTimeoutMilliseconds: 60000maxLifetimeMilliseconds: 1800000maxPoolSize: 50minPoolSize: 1ds_18_slave:url: jdbc:mysql://192.168.186.18:3307/db3?serverTimezone=UTC&useSSL=false&allowPublicKeyRetrieval=trueusername: slavepassword: 123456connectionTimeoutMilliseconds: 30000idleTimeoutMilliseconds: 60000maxLifetimeMilliseconds: 1800000maxPoolSize: 50minPoolSize: 1
databaseName: my_database
rules:- !READWRITE_SPLITTINGdataSources:readwrite_77:writeDataSourceName: ds_77_masterreadDataSourceNames:- ds_77_slavetransactionalReadQueryStrategy: PRIMARYloadBalancerName: randomreadwrite_216:writeDataSourceName: ds_216_masterreadDataSourceNames:- ds_216_slavetransactionalReadQueryStrategy: PRIMARYloadBalancerName: randomreadwrite_18:writeDataSourceName: ds_18_masterreadDataSourceNames:- ds_18_slavetransactionalReadQueryStrategy: PRIMARYloadBalancerName: randomloadBalancers:random:type: RANDOM- !SHARDINGtables:t_order:actualDataNodes: readwrite_77.t_order_${0..1}, readwrite_216.t_order_${0..1}, readwrite_18.t_order_${0..1}tableStrategy:standard:shardingColumn: order_idshardingAlgorithmName: t_order_inlinekeyGenerateStrategy:column: order_idkeyGeneratorName: snowflakedefaultDatabaseStrategy:standard:shardingColumn: user_idshardingAlgorithmName: database_inlinedefaultTableStrategy:none:bindingTables:- t_ordershardingAlgorithms:database_inline:type: INLINEprops:algorithm-expression: "readwrite_${(user_id % 3 == 0) ? '77' : ((user_id % 3 == 1) ? '216' : '18')}"t_order_inline:type: INLINEprops:algorithm-expression: "t_order_${order_id % 2}"keyGenerators:snowflake:type: SNOWFLAKEprops:worker-id: 123

注：分片规则根据 user_id 的值对3取模，决定将数据分片到哪个数据库， 根据 order_id 的值对2取模，决定将数据分片到哪个表。

2.1.5 参考教程文献

 数据分片 :: ShardingSphere

 读写分离 :: ShardingSphere

 混合规则 :: ShardingSphere

2.13 启动程序

# 回退上一级
cd ..
# 进入bin目录
cd bin
# 启动程序
sudo ./start.sh

liber@liber-VMware-Virtual-Platform:/home/sp/apache-shardingsphere-5.5.0-shardingsphere-proxy-bin/conf$ cd ..
liber@liber-VMware-Virtual-Platform:/home/sp/apache-shardingsphere-5.5.0-shardingsphere-proxy-bin$ cd bin
liber@liber-VMware-Virtual-Platform:/home/sp/apache-shardingsphere-5.5.0-shardingsphere-proxy-bin/bin$ sudo ./start.sh
/usr/bin/java
we find java version: java8, full_version=1.8.0_412, full_path=/usr/bin/java
The classpath is /home/sp/apache-shardingsphere-5.5.0-shardingsphere-proxy-bin/conf:/home/sp/apache-shardingsphere-5.5.0-shardingsphere-proxy-bin/conf:.:/home/sp/apache-shardingsphere-5.5.0-shardingsphere-proxy-bin/lib/*:/home/sp/apache-shardingsphere-5.5.0-shardingsphere-proxy-bin/ext-lib/*
main class org.apache.shardingsphere.proxy.Bootstrap -1 /home/sp/apache-shardingsphere-5.5.0-shardingsphere-proxy-bin/conf 0.0.0.0 false
Starting the ShardingSphere-Proxy ... PID: 128452
Please check the STDOUT file: /home/sp/apache-shardingsphere-5.5.0-shardingsphere-proxy-bin/logs/stdout.log #日志路径可以通过cat进行查看
liber@liber-VMware-Virtual-Platform:/home/sp/apache-shardingsphere-5.5.0-shardingsphere-proxy-bin/bin$ 

 2.15 查看日志

cat /home/sp/apache-shardingsphere-5.5.0-shardingsphere-proxy-bin/logs/stdout.log
#显示该信息代表成功
[INFO ] 2024-07-25 15:39:09.724 [main] o.a.s.d.p.c.l.PipelineContextManagerLifecycleListener - mode type is not Cluster, mode type='Standalone', ignore
[INFO ] 2024-07-25 15:39:09.933 [main] o.a.s.p.v.ShardingSphereProxyVersion - Database type is `MySQL`, version is `8.0.27`, database name is `my_database`
[INFO ] 2024-07-25 15:39:09.966 [main] o.a.s.p.frontend.ssl.ProxySSLContext - Proxy frontend SSL/TLS is not enabled.
[INFO ] 2024-07-25 15:39:12.683 [main] o.a.s.p.frontend.ShardingSphereProxy - ShardingSphere-Proxy Standalone mode started successfully

2.16 测试连接 

2.17 分库分表验证 

        在ShardingSphere-Proxy连接的客户端进行操作，因为t_order是ShardingSphere-Proxy创建的逻辑表，所以实际上通过第三方连接工具是看不到存在的实体表，比如我使用的是IDEA自带的MySQL的连接管理工具。

use my_database;INSERT INTO t_order (order_id, user_id, order_date, status) VALUES (1, 10, '2023-07-01', 'NEW');
INSERT INTO t_order (order_id, user_id, order_date, status) VALUES (2, 20, '2023-07-02', 'SHIPPED');
INSERT INTO t_order (order_id, user_id, order_date, status) VALUES (3, 30, '2023-07-03', 'DELIVERED');
INSERT INTO t_order (order_id, user_id, order_date, status) VALUES (14, 40, '2023-07-04', 'RETURNED');

运行日志：

[INFO ] 2024-07-25 15:43:21.874 [ShardingSphere-Command-1] ShardingSphere-SQL - Logic SQL: /* ApplicationName=IntelliJ IDEA 2024.1 */ INSERT INTO t_order (order_id, user_id, order_date, status) VALUES (1, 10, '2023-07-01', 'NEW')
[INFO ] 2024-07-25 15:43:21.874 [ShardingSphere-Command-1] ShardingSphere-SQL - Actual SQL: ds_216_master ::: /* ApplicationName=IntelliJ IDEA 2024.1 */ INSERT INTO t_order_1 (order_id, user_id, order_date, status) VALUES (1, 10, '2023-07-01', 'NEW')
解释：分片规则根据 user_id 的值对3取模，决定将数据分片到哪个数据库， 根据 order_id 的值对2取模，决定将数据分片到哪个表。数据库取模顺序：77=>0,216=>1,18=>2
user_id: 10%3=1，order_id: 1%2=1，所以分片到第2个数据库ds_216_master，t_order_1表。 [INFO ] 2024-07-25 15:43:21.976 [ShardingSphere-Command-1] ShardingSphere-SQL - Logic SQL: /* ApplicationName=IntelliJ IDEA 2024.1 */ INSERT INTO t_order (order_id, user_id, order_date, status) VALUES (2, 20, '2023-07-02', 'SHIPPED')
[INFO ] 2024-07-25 15:43:21.976 [ShardingSphere-Command-1] ShardingSphere-SQL - Actual SQL: ds_18_master ::: /* ApplicationName=IntelliJ IDEA 2024.1 */ INSERT INTO t_order_0 (order_id, user_id, order_date, status) VALUES (2, 20, '2023-07-02', 'SHIPPED')
解释：分片规则根据 user_id 的值对3取模，决定将数据分片到哪个数据库， 根据 order_id 的值对2取模，决定将数据分片到哪个表。数据库取模顺序：77=>0,216=>1,18=>2
user_id: 20%3=2，order_id: 2%2=0，所以分片到第3个数据库ds_18_master，t_order_0表。
[INFO ] 2024-07-25 15:43:22.108 [ShardingSphere-Command-1] ShardingSphere-SQL - Logic SQL: /* ApplicationName=IntelliJ IDEA 2024.1 */ INSERT INTO t_order (order_id, user_id, order_date, status) VALUES (3, 30, '2023-07-03', 'DELIVERED')
[INFO ] 2024-07-25 15:43:22.108 [ShardingSphere-Command-1] ShardingSphere-SQL - Actual SQL: ds_77_master ::: /* ApplicationName=IntelliJ IDEA 2024.1 */ INSERT INTO t_order_1 (order_id, user_id, order_date, status) VALUES (3, 30, '2023-07-03', 'DELIVERED')
解释：分片规则根据 user_id 的值对3取模，决定将数据分片到哪个数据库， 根据 order_id 的值对2取模，决定将数据分片到哪个表。数据库取模顺序：77=>0,216=>1,18=>2
user_id: 30%3=0，order_id: 3%2=1，所以分片到第1个数据库ds_77_master，t_order_1表。

[INFO ] 2024-07-25 15:43:22.248 [ShardingSphere-Command-1] ShardingSphere-SQL - Logic SQL: /* ApplicationName=IntelliJ IDEA 2024.1 */ INSERT INTO t_order (order_id, user_id, order_date, status) VALUES (14, 40, '2023-07-04', 'RETURNED')
[INFO ] 2024-07-25 15:43:22.248 [ShardingSphere-Command-1] ShardingSphere-SQL - Actual SQL: ds_216_master ::: /* ApplicationName=IntelliJ IDEA 2024.1 */ INSERT INTO t_order_0 (order_id, user_id, order_date, status) VALUES (14, 40, '2023-07-04', 'RETURNED')
解释：分片规则根据 user_id 的值对3取模，决定将数据分片到哪个数据库， 根据 order_id 的值对2取模，决定将数据分片到哪个表。数据库取模顺序：77=>0,216=>1,18=>2
user_id: 40%3=1，order_id: 14%2=0，所以分片到第2个数据库ds_216_master，t_order_0表。

2.18 读写分离验证 

select *from t_order;
运行日志：
[INFO ] 2024-07-25 15:57:22.968 [ShardingSphere-Command-2] ShardingSphere-SQL - Logic SQL: /* ApplicationName=IntelliJ IDEA 2024.1 */ select *from t_order
[INFO ] 2024-07-25 15:57:22.969 [ShardingSphere-Command-2] ShardingSphere-SQL - Actual SQL: ds_77_slave ::: /* ApplicationName=IntelliJ IDEA 2024.1 */ select *from t_order_0 UNION ALL /* ApplicationName=IntelliJ IDEA 2024.1 */ select *from t_order_1
[INFO ] 2024-07-25 15:57:22.969 [ShardingSphere-Command-2] ShardingSphere-SQL - Actual SQL: ds_216_slave ::: /* ApplicationName=IntelliJ IDEA 2024.1 */ select *from t_order_0 UNION ALL /* ApplicationName=IntelliJ IDEA 2024.1 */ select *from t_order_1
[INFO ] 2024-07-25 15:57:22.973 [ShardingSphere-Command-2] ShardingSphere-SQL - Actual SQL: ds_18_slave ::: /* ApplicationName=IntelliJ IDEA 2024.1 */ select *from t_order_0 UNION ALL /* ApplicationName=IntelliJ IDEA 2024.1 */ select *from t_order_1

 

3. 总结 

        Ubtun24.04 TLS，JDK8，shardingsphere proxy/5.5.0，MySQL Connector/J 8.0.27，仅供学习交流使用。

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.xdnf.cn/news/1488478.html

如若内容造成侵权/违法违规/事实不符，请联系一条长河网进行投诉反馈，一经查实，立即删除！

相关文章

十一、Dockerfile解析

十一、Dockerfile解析

目录 一、Dockerfile简介 二、dockerfile的构建的三个步骤 三、Dockerfile的构建过程 1、DockerFile内容的基础知识 2、Docker执行Dockerfile的大致流程 四、dockerfile常用的保留字 1、FROM 2、MAINTAINER 3、RUN 4、EXPOSE 5、WORKDIR 6、USER 7、ENV 8、VOLUME …
阅读更多...
Tensorflow2.0全套学习（持续更新中）

Tensorflow2.0全套学习（持续更新中）

0 简介 1.学习目标 两大核心模块：深度学习经典算法与Tensorflow项目实战 从零开始，详细的网络模型架构与框架实现方法 2.tensorflow：核心开源库，深度学习框架，帮助开发和训练机器学习模型 3.版本2比1有哪些优势 …
阅读更多...
企元数智：数字化转型，免费送新零售合规分销系统

企元数智：数字化转型，免费送新零售合规分销系统

企元数智，作为数字化转型领域的领先者，宣布推出一项划时代的举措：免费送出新零售合规分销系统，助力更多企业加速数字化转型进程。 随着新零售潮流的席卷，企业们越来越意识到数字化转型的紧迫性和必要性。然而&#xff…
阅读更多...
LLMs之Llama 3.1：Llama 3.1的简介、安装和使用方法、案例应用之详细攻略

LLMs之Llama 3.1：Llama 3.1的简介、安装和使用方法、案例应用之详细攻略

LLMs之Llama 3.1：Llama 3.1的简介、安装和使用方法、案例应用之详细攻略 导读：2024年7月23日，Meta重磅推出Llama 3.1。本篇文章主要提到了Meta推出的Llama 3.1自然语言生成模型。 背景和痛点 >> 过去开源的大型语言模型在能力和性能上一…
阅读更多...
后台管理系统登录安全和权限要求

后台管理系统登录安全和权限要求

一、前言 几乎所有的系统都有后台管理系统，后台登录需要账号和密码，后台管理员权限需要有控制。所有管理员的操作都应该有操作日志。 二、存在的问题 现在很多系统只需要账号和密码就能登录，有的还是简单账号和简单密码，就是弱口…
阅读更多...
【北京迅为】《i.MX8MM嵌入式Linux开发指南》-第三篇 嵌入式Linux驱动开发篇-第四十六章 自动创建设备节点

【北京迅为】《i.MX8MM嵌入式Linux开发指南》-第三篇 嵌入式Linux驱动开发篇-第四十六章 自动创建设备节点

i.MX8MM处理器采用了先进的14LPCFinFET工艺，提供更快的速度和更高的电源效率;四核Cortex-A53，单核Cortex-M4，多达五个内核 ，主频高达1.8GHz，2G DDR4内存、8G EMMC存储。千兆工业级以太网、MIPI-DSI、USB HOST、WIFI/BT…
阅读更多...
H3CNE（vlan的基础配置）

H3CNE（vlan的基础配置）

目录 9.1 传统以太网的问题 9.2 VLAN基础实现的原理 示例一（vlan配置的基础实现）： 示例二（交换机间配置trunk）： 9.3 hybrid接口类型与打标签的原理 示例三（配置hybrid接口）&#x…
阅读更多...
通过IEC104转MQTT网关轻松接入阿里云平台

通过IEC104转MQTT网关轻松接入阿里云平台

随着智能电网和物联网技术的飞速发展，电力系统中的传统IEC 104协议设备正面临向现代化、智能化转型的迫切需求。阿里云作为全球领先的云计算服务提供商，其强大的物联网平台为IEC 104设备的接入与数据处理提供了强大的支持。本文将深入探讨钡铼网关在MQTT…
阅读更多...
网站被浏览器提示“不安全”，如何解决

网站被浏览器提示“不安全”，如何解决

在互联网时代，网络安全是每个网站所有者和用户共同关心的问题，当网站的数据传输未经过加密时，会被主流浏览器标记为“不安全”时，这不仅会影响用户体验，还可能损害网站的信誉，导致访问量下降。 一、理解警…
阅读更多...
go语言开发Prometheus Exporter（DM数据库）

go语言开发Prometheus Exporter（DM数据库）

一、介绍 源码步骤基于dameng_exporter源码讲解，看完本篇文章可以直接进行二次开发。 dameng exporter的开源地址：https://github.com/gy297879328/dameng_exporter（可直接对接prometheusgrafana 提供表盘） 开发一个exporter 其…
阅读更多...
基于微信小程序+SpringBoot+Vue的自习室选座与门禁系统(带1w+文档)

基于微信小程序+SpringBoot+Vue的自习室选座与门禁系统(带1w+文档)

基于微信小程序SpringBootVue的自习室选座与门禁系统(带1w文档) 基于微信小程序SpringBootVue的自习室选座与门禁系统(带1w文档) 本课题研究的研学自习室选座与门禁系统让用户在小程序端查看座位，预定座位，支付座位价格，该系统让用户预定座位…
阅读更多...
Discourse 如何通过终端工具访问 PGSQL

Discourse 如何通过终端工具访问 PGSQL

PGSQL 在 Discourse 中是通过容器方式运行的，要访问 PGSQL 中的数据那么首先需要进入到容器后才可以。 进入容器的命令为： cd /var/discourse/./launcher enter appsu discoursepsql discourse最后的命令是登录到运行在容器中的 pgsql。 查看 pgsql 上…
阅读更多...
学习笔记之Java篇（0725）

学习笔记之Java篇（0725）

p this 普通方法中，this总是指向调用该方法的对象。 构造方法中，this总是指向正要初始化的对象。 this（）调用必须重载的构造方法，避免相同地址初始化代码，但只能在构造方法中用，比企鹅必须位…
阅读更多...
USB传输类型，常用类型：控制传输和中断传输

USB传输类型，常用类型：控制传输和中断传输

一般包含：控制传输，同步传输，批传输，中断传输，但常见到的控制传输的setup包以及中断传输的IN和OUT包 参考 控制传输 中断传输 usb主机发送的命令功能 hid类命令
阅读更多...
AI有关的学习和python

AI有关的学习和python

一、基本概念 AIGC（AI Generated content AI 生成内容） AI生成的文本、代码、图片、音频、视频。都可以成为AIGC。 Generative AI（生成式AI）所生成的内容就是AIGC AI指代计算机人工智能，模仿人类的智能从而解决问题…
阅读更多...
网站打包封装成app，提高用户体验和商业价值

网站打包封装成app，提高用户体验和商业价值

网站打包封装成app的优势 随着移动互联网的普及，用户对移动应用的需求越来越高。网站打包封装成app可以满足用户的需求，提高用户体验和商业价值。 我的朋友是一名电商平台的运营负责人，他曾经告诉我，他们的网站流量主要来自移动…
阅读更多...
切换数据失败0x1671分析

切换数据失败0x1671分析

1、问题背景 切换双卡数据开关，无法切换成功，且单机必现该问题 2、问题分析 搜索Log发现相关拨号无法建立成功，返回0x1671，无法建立PDN连接。 相关拨号上层未下发相关AT命令，属于上层报错，并非网络问题&…
阅读更多...
Hadoop学习笔记1

Hadoop学习笔记1

hadoop节点规划 服务器集群规划，6台服务器： 一个主节点 两个从节点 三个工作节点 集群服务器用的都是centos7.9.2009的镜像 一、基础环境 1.1配置阿里云yum源 1.下载repo文件 wget http://mirrors.aliyun.com/repo/Centos-7.repo 2.备份并替换系…
阅读更多...
【企业级开发模型】企业级开发流程 | 系统环境开发

【企业级开发模型】企业级开发流程 | 系统环境开发

目录 1.企业级开发流程 2.系统环境开发 1.企业级开发流程 想要交付一个软件项目，至少需要经过以下三个流程。软件代码的开发-------->软件代码的测试------->软件发布上线。只有将软件发布上线之后，用户才可以访问到我们的一个软件。 软件代码的…
阅读更多...
C语言 | Leetcode C语言题解之第284题窥视迭代器

C语言 | Leetcode C语言题解之第284题窥视迭代器

题目： 题解： bool flag;struct PeekingIterator {struct Iterator *iterator;int nextElement; };struct PeekingIterator* Constructor(struct Iterator* iter) {struct PeekingIterator* piter malloc(sizeof(struct PeekingIterator));piter->it…
阅读更多...
最新文章

Copyright @ 2022~2023