sharding-sphere 安装使用

青旅半醒 2022-04-23 05:24 167阅读 0赞

# **分布式主键** #

传统数据库软件开发中，主键自动生成技术是基本需求。而各个数据库对于该需求也提供了相应的支持，比如MySQL的自增键，Oracle的自增序列等。 数据分片后，不同数据节点生成全局唯一主键是非常棘手的问题。同一个逻辑表内的不同实际表之间的自增键由于无法互相感知而产生重复主键。 虽然可通过约束自增主键初始值和步长的方式避免碰撞，但需引入额外的运维规则，使解决方案缺乏完整性和可扩展性。

io.shardingsphere.core.keygen.DefaultKeyGenerator

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3o3ODU0OTUyOTU_size_16_color_FFFFFF_t_70][]

# **Sharding-proxy介绍** #

Sharding-Proxy是ShardingSphere的第二个产品。 它定位为透明化的数据库代理端，提供封装了数据库二进制协议的服务端版本，用于完成对异构语言的支持。 目前先提供MySQL版本，它可以使用任何兼容MySQL协议的访问客户端(如：MySQL Command Client, MySQL Workbench等)操作数据，对DBA更加友好。

# **Atlas介绍：** #

Atlas是由 Qihoo 360公司Web平台部基础架构团队开发维护的一个基于MySQL协议的数据中间层项目。它在MySQL官方推出的MySQL-Proxy 0.8.2版本的基础上，修改了大量bug，添加了很多功能特性。目前该项目在360公司内部得到了广泛应用，很多MySQL业务已经接入了Atlas平台，每天承载的读写请求数达几十亿条。同时，有超过50家公司在生产环境中部署了Atlas，超过800人已加入了我们的开发者交流群，并且这些数字还在不断增加。

主要功能：

[https://github.com/Qihoo360/Atlas/blob/master/README\_ZH.md][https_github.com_Qihoo360_Atlas_blob_master_README_ZH.md]

## **Proxy部署流程：** ##

## **架构图** ##

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3o3ODU0OTUyOTU_size_16_color_FFFFFF_t_70 1][]

# **1、环境** #

192.168.0.156（数据库地址）

192.168.0.31（proxy地址）

# **2、部署** #

## **2.1下载** ##

下载地址：（最新版本还没有提供下载地址，需要下载源码，自行编译打包）

[https://github.com/sharding-sphere/sharding-sphere-doc/raw/master/dist/sharding-proxy-3.0.0.tar.gz][https_github.com_sharding-sphere_sharding-sphere-doc_raw_master_dist_sharding-proxy-3.0.0.tar.gz]

目前最新版本3.1.0支持分布式事务。没找到下载地址的，我这儿发给大家。

## **2.2解压：** ##

tar -zxvf sharding-proxy-3.0.0.tar.gz

## **2.3 配置：** ##

解压之后进入到conf目录

修改：conf/config-xxx.yaml

修改：conf/server.yaml

不同版本配置不一样，官网文档是3.0.0的版本，如果用最新版本从源码里面copy文件。

config-sharding.yaml

<table style="width:568px;"> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> &nbsp; schemaName: sharding_db &nbsp; dataSources: &nbsp; ds_0: &nbsp;&nbsp;&nbsp; url: jdbc:mysql://127.0.0.1:3306/demo_ds_0?serverTimezone=UTC&amp;useSSL=false &nbsp;&nbsp;&nbsp; username: root &nbsp;&nbsp;&nbsp; password: &nbsp;&nbsp;&nbsp; connectionTimeoutMilliseconds: 30000 &nbsp;&nbsp;&nbsp; idleTimeoutMilliseconds: 60000 &nbsp;&nbsp;&nbsp; maxLifetimeMilliseconds: 1800000 &nbsp;&nbsp;&nbsp; maxPoolSize: 50 &nbsp; ds_1: &nbsp;&nbsp; &nbsp;url: jdbc:mysql://127.0.0.1:3306/demo_ds_1?serverTimezone=UTC&amp;useSSL=false &nbsp;&nbsp;&nbsp; username: root &nbsp;&nbsp;&nbsp; password: &nbsp;&nbsp;&nbsp; connectionTimeoutMilliseconds: 30000 &nbsp;&nbsp;&nbsp; idleTimeoutMilliseconds: 60000 &nbsp;&nbsp;&nbsp; maxLifetimeMilliseconds: 1800000 &nbsp;&nbsp;&nbsp; maxPoolSize: 50 &nbsp; shardingRule: &nbsp; tables: &nbsp;&nbsp;&nbsp; t_order: &nbsp;&nbsp;&nbsp;&nbsp;&nbsp; actualDataNodes: ds_${0..1}.t_order_${0..1} &nbsp;&nbsp;&nbsp;&nbsp;&nbsp; tableStrategy: &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; inline: &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; shardingColumn: order_id &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; algorithmExpression: t_order_${order_id % 2} &nbsp;&nbsp;&nbsp;&nbsp;&nbsp; keyGeneratorColumnName: order_id &nbsp;&nbsp;&nbsp; t_order_item: &nbsp;&nbsp;&nbsp;&nbsp;&nbsp; actualDataNodes: ds_${0..1}.t_order_item_${0..1} &nbsp;&nbsp;&nbsp;&nbsp;&nbsp; tableStrategy: &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; inline: &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; shardingColumn: order_id &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; algorithmExpression: t_order_item_${order_id % 2} &nbsp;&nbsp;&nbsp;&nbsp;&nbsp; keyGeneratorColumnName: order_item_id &nbsp; bindingTables: &nbsp;&nbsp;&nbsp; - t_order,t_order_item &nbsp; defaultDatabaseStrategy: &nbsp;&nbsp;&nbsp; inline: &nbsp;&nbsp;&nbsp;&nbsp;&nbsp; shardingColumn: user_id &nbsp;&nbsp;&nbsp;&nbsp;&nbsp; algorithmExpression: ds_${user_id % 2} &nbsp; defaultTableStrategy: &nbsp;&nbsp;&nbsp; none: &nbsp; defaultKeyGeneratorClassName: io.shardingsphere.core.keygen.DefaultKeyGenerator </td> 
 </tr> 
 </tbody> 
</table>

server.yaml

<table style="width:568px;"> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> orchestration: &nbsp; name: orchestration_ds &nbsp; overwrite: true &nbsp; registry: &nbsp;&nbsp;&nbsp; namespace: orchestration serverLists: localhost:2181 #依赖了zk地址 &nbsp; authentication: &nbsp; username: root &nbsp; password: &nbsp; props: &nbsp; executor.size: 16 &nbsp; sql.show: true &nbsp; proxy.transaction.type: XA &nbsp; </td> 
 </tr> 
 </tbody> 
</table>

## **2.4 启动服务** ##

启动服务之前，需要先启动zookeeper

启动服务：sh start.sh

停止服务：sh stop.sh

## **2.5验证是否成功** ##

tail -f ../logs/stdout.log 查看是否有错误。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3o3ODU0OTUyOTU_size_16_color_FFFFFF_t_70 2][]

用客户端测试连接下，如果可以访问说明服务成功。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3o3ODU0OTUyOTU_size_16_color_FFFFFF_t_70 3][]

# #

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3o3ODU0OTUyOTU_size_16_color_FFFFFF_t_70]: /images/20220323/137c8888873146c0a30f4c3dc447c273.png
[https_github.com_Qihoo360_Atlas_blob_master_README_ZH.md]: https://github.com/Qihoo360/Atlas/blob/master/README_ZH.md
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3o3ODU0OTUyOTU_size_16_color_FFFFFF_t_70 1]: /images/20220323/458028d9f87e41d2a58c9045b52c1bf2.png
[https_github.com_sharding-sphere_sharding-sphere-doc_raw_master_dist_sharding-proxy-3.0.0.tar.gz]: https://github.com/sharding-sphere/sharding-sphere-doc/raw/master/dist/sharding-proxy-3.0.0.tar.gz
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3o3ODU0OTUyOTU_size_16_color_FFFFFF_t_70 2]: /images/20220323/80949b1381004bd899643ed574b85466.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3o3ODU0OTUyOTU_size_16_color_FFFFFF_t_70 3]: /images/20220323/acbe11f2d4564109aecd7bc0cda80fde.png