ShardingSphere-Proxy5搭建使用过程分析

 更新时间:2022年10月11日 11:50:56   作者:monoL  
ShardingSphere-Proxy是跨语言的数据库代理服务端,主要用来处理:分表、分库、读写分离 等,这篇文章主要介绍了ShardingSphere-Proxy5搭建使用过程,需要的朋友可以参考下

Apache ShardingSphere 是一款开源分布式数据库生态项目,旨在碎片化的异构数据库上层构建生态,在最大限度的复用数据库原生存算能力的前提下,进一步提供面向全局的扩展和叠加计算能力。其核心采用可插拔架构,对上以数据库协议及 SQL 方式提供诸多增强功能,包括数据分片、访问路由、数据安全等     

 ShardingSphere-Proxy是跨语言的数据库代理服务端,主要用来处理:分表、分库、读写分离 等。      【默认端口 3307 】

   官网地址:https://shardingsphere.apache.org/index_zh.html

Apache ShardingSphere下的一个产品,定位为透明化的数据库代理端,与mycat类似,所有的分片都由其完成。

ShardingSphere-Proxy5下载安装

官网提供三种安装方式,这里主要记录两种

二进制包安装

  • 官网下载二进制包apache-shardingsphere-5.2.0-shardingsphere-proxy-bin.tar.gz
  • 下载MySQL驱动mysql-connector-java-8.0.22.jar(根据所使用的mysql下载对应版本)
  • 将MySQl驱动放至shardingsphere-proxy解压目录中的ext-lib目录
  • 修改配置conf/server.yaml
    server.yaml是与shardingsphere-proxy服务相关的配置,这里主要配置下权限
rules:
 - !AUTHORITY
   users: # 配置连接shardingsphere-proxy的用户
     - root@127.0.0.1:root
     - sharding@:sharding
   provider: # 授权模式
     type: ALL_PERMITTED # 不用授权,获取所有权限
  • 启动shardingsphere-proxy
# windows
# 指定端口号和配置文件目录, 默认端口为3307
bin/start.bat ${proxy_port} ${proxy_conf_directory}

![[Pasted image 20220922095217.png]]
出现以上信息代表部署成功
6. 连接测试
连接方式与mysql差不多,可以用mysql命令行连接,也可以用navicat连接。

Docker 方式安装

# 拉取镜像
docker pull apache/shardingsphere-proxy

# 启动临时容器
docker run -d --name tmp --entrypoint=bash apache/shardingsphere-proxy:5.2.0

# 配置文件拷贝
docker cp tmp:/opt/shardingsphere-proxy/conf /mnt/data/shardingsphere-proxy/
#删除临时容器
docker rm tmp

# 注意镜像的扩张依赖需要放在ext-lib目录,不能直接覆盖lib目录
docker run --name shardingsphere-proxy -d -v /mnt/data/shardingsphere-proxy/conf:/opt/shardingsphere-proxy/conf -v /mnt/data/shardingsphere-proxy/ext-lib:/opt/shardingsphere-proxy/ext-lib -e PORT=3307 -p 33307:3307 apache/shardingsphere-proxy:5.2.0

docker run --name shardingsphere-proxy -d -v /mnt/data/shardingsphere-proxy/conf:/opt/shardingsphere-proxy/conf -e PORT=3307 -p 33307:3307 apache/shardingsphere-proxy:5.2.0

ShardingSphere-Proxy5分库分表

创建数据源

修改config-sharding.yaml文件添加数据源配置

databaseName: sharding_db ##逻辑库。配置多个逻辑库时需要创建其他的配置文件,并且配置文件格式需为config-sharding***.yaml

dataSources: ## 数据源,连接真实物理库,注意物理库必须有相应的库存在,负责proxy无法启动。
ds_0:
url: jdbc:mysql://127.0.0.1:13307/demo_ds_0?serverTimezone=UTC&useSSL=false
username: root
password: sunday
connectionTimeoutMilliseconds: 30000
idleTimeoutMilliseconds: 60000
maxLifetimeMilliseconds: 1800000
maxPoolSize: 50
minPoolSize: 1
ds_1:
url: jdbc:mysql://127.0.0.1:3306/demo_ds_1?serverTimezone=UTC&useSSL=false
username: root
password: sunday
connectionTimeoutMilliseconds: 30000
idleTimeoutMilliseconds: 60000
maxLifetimeMilliseconds: 1800000
maxPoolSize: 50
minPoolSize: 1

配置分片规则

继续修改config-sharding.yaml文件添加数据分片规则

databaseName: sharding_db

dataSources: ## 数据源,连接真实物理库,注意物理库必须有相应的库存在,负责proxy无法启动。
ds_0:
url: jdbc:mysql://127.0.0.1:13307/demo_ds_0?serverTimezone=UTC&useSSL=false
username: root
password: sunday
connectionTimeoutMilliseconds: 30000
idleTimeoutMilliseconds: 60000
maxLifetimeMilliseconds: 1800000
maxPoolSize: 50
minPoolSize: 1
ds_1:
url: jdbc:mysql://127.0.0.1:3306/demo_ds_1?serverTimezone=UTC&useSSL=false
username: root
password: sunday
connectionTimeoutMilliseconds: 30000
idleTimeoutMilliseconds: 60000
maxLifetimeMilliseconds: 1800000
maxPoolSize: 50
minPoolSize: 1
## 分片规则配置
rules:
- !SHARDING
tables:
t_order: # 分片表
actualDataNodes: ds_${0..1}.t_order${0..1}
databaseStrategy: # 分库规则
standard: # 标准类型分片,目前官方有四种分片类型
shardingColumn: user_id
shardingAlgorithmName: alg_mod # 算法名称
tableStrategy: # 分表规则
standard:
shardingColumn: order_no
shardingAlgorithmName: alg_hash_mod # 算法名称,具体使用哪一种算法下面会根据算法名称配置
keyGenerateStrategy: # 主键生成规则
column: id
keyGeneratorName: snowflake
# bindingTables: # 绑定表。对于相同分片算法的表,设置绑定,避免相互关联时产生笛卡尔关联
# broadcastTables: # 广播表

keyGenerators: # 主键生成规则配置
snowflake:
type: SNOWFLAKE

shardingAlgorithms: # 分片算法配置,根据上面的算法名称配置算法的类型和算法接收的参数
alg_mod:
type: MOD
props:
sharding-count: 2
alg_hash_mod:
type: HASH_MOD
props:
sharding-count: 2

配置完成后重启proxy。

连接proxy创建分片表

配置分片表后,并没有生成相应的分片表,需要连接上sharding-proxy,在proxy中执行建表语句,在创建逻辑表时分片表会被proxy自动按照配置的规则进行创建。

CREATE TABLE `t_order` (
`id` bigint(20) NOT NULL AUTO_INCREMENT,
`order_no` varchar(30) DEFAULT NULL,
`user_id` bigint(20) DEFAULT NULL,
`amount` decimal(10,2) DEFAULT NULL,
PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=779468255126355969 DEFAULT CHARSET=utf8mb4;

插入测试数据

INSERT INTO `sharding_db`.`t_order`(`id`, `order_no`, `user_id`, `amount`) VALUES (779468213359476737, '22', 22, 22.00);
INSERT INTO `sharding_db`.`t_order`(`id`, `order_no`, `user_id`, `amount`) VALUES (779468285585391617, '44', 44, 44.00);
INSERT INTO `sharding_db`.`t_order`(`id`, `order_no`, `user_id`, `amount`) VALUES (779468168534949888, '11', 11, 11.00);
INSERT INTO `sharding_db`.`t_order`(`id`, `order_no`, `user_id`, `amount`) VALUES (779468255126355968, '33', 33, 33.00);

插入后,观察物理库的表数据存储情况。

到此这篇关于ShardingSphere-Proxy5搭建使用过程的文章就介绍到这了,更多相关ShardingSphere-Proxy使用内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

相关文章

  • Java中filter用法完整代码示例

    Java中filter用法完整代码示例

    这篇文章主要介绍了Java中filter用法完整代码示例,分享了浏览器不缓存页面的过滤器,检测用户是否登陆的过滤器等相关实例,小编觉得还是挺不错的,这里分享给大家,需要的朋友可以参考下
    2018-01-01
  • String.replaceAll方法详析(正则妙用)

    String.replaceAll方法详析(正则妙用)

    这篇文章主要给大家介绍了关于String.replaceAll方法,正则妙用的相关资料,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面来一起学习学习吧
    2019-07-07
  • jsp、servlet前后端交互对数据处理及展示的简单实现

    jsp、servlet前后端交互对数据处理及展示的简单实现

    Servlet和JSP是Java Web开发中的两个重要概念,在Servlet和JSP中前后端交互可以通过一些方式来实现,这篇文章主要给大家介绍了关于jsp、servlet前后端交互对数据处理及展示的简单实现,需要的朋友可以参考下
    2023-12-12
  • Java实现从Html文本中提取纯文本的方法

    Java实现从Html文本中提取纯文本的方法

    今天小编就为大家分享一篇Java实现从Html文本中提取纯文本的方法,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧
    2018-05-05
  • java FileOutputStream输出流的使用解读

    java FileOutputStream输出流的使用解读

    这篇文章主要介绍了java FileOutputStream输出流的使用解读,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2022-12-12
  • 深入解析Java中的内部类

    深入解析Java中的内部类

    这篇文章主要介绍了Java中的内部类,是Java入门学习中的基础知识,需要的朋友可以参考下
    2015-07-07
  • 关于Redis的缓存穿透问题

    关于Redis的缓存穿透问题

    这篇文章主要介绍了关于Redis的缓存穿透问题,缓存穿透是指客户端请求的数据在缓存中和数据库中都不存在,这样缓存永远不会生效,这些请求都会打到数据库,需要的朋友可以参考下
    2023-08-08
  • Java哈希表和有序表实例代码讲解

    Java哈希表和有序表实例代码讲解

    这篇文章主要介绍了Java哈希表和有序表,哈希表也称散列表,是一种以键值对形式存储记录的数据结构,该数据结构支持根据键的内容直接访问在内存特定位置的值,并且可以进行查找、添加和删除操作
    2023-04-04
  • 使用SpringCache进行缓存数据库查询方式

    使用SpringCache进行缓存数据库查询方式

    这篇文章主要介绍了使用SpringCache进行缓存数据库查询方式,具有很好的参考价值,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2021-10-10
  • Java的增强for循环修改数组元素的问题小结

    Java的增强for循环修改数组元素的问题小结

    增强for循环的元素变量x,就是一个局部变量,它是引用数组当前元素引用的副本(就相当于上文所说的你复刻朋友的钥匙),或者是基本数据类型的值的副本,这篇文章主要介绍了Java的增强for循环修改数组元素的问题小结,需要的朋友可以参考下
    2024-02-02

最新评论