Sharding

网友投稿 324 2022-08-14


Sharding

目录Sharding-Proxy分库分表和数据加密使用场景配置文件讲解server.yamlconfig-sharding.yamlconfig-encrypt.yaml其他使用情况总结

Sharding-Proxy分库分表和数据加密

主要将实际项目中使用shardingshpere-proxy的经历经验,总结分享一下。

使用场景

公司规划研发了两款针对政务新媒体和数字乡村的SaaS平台,作为新的利润增长点。考虑到以后的用户数量和数据数量,决定按照租户(签约客户)进行分库分表。对于一些敏感数据,例如身份证号、手机号等,使用数据库级别的加密解密,不存储明文数据。考察了网上已有的一些数据库中间件和分库分表解决方案,公司决定使用Sharding-Proxy作为分库分表和数据加密的数据库中间件。主要原因是,它对代码的侵入性很小,开发人员也不需要关注它,减少了学习成本,对DBA也很友好。另一方面,ShardingSphere已进入Apache孵化器,它完全开源免费,社区也很活跃,版本迭代也很快。本次使用的ShardingSphere-5.0

配置文件讲解

server.yaml

resources文件夹,conf文件夹下面主要有注册中心配置、登录连接配置和基础配置

mode:

http://type: Cluster # 集群

repository:

type: ZooKeeper # 使用zookeeper

props:

namespace: governance_ds

server-lists: 192.168.1.100:2181

retryIntervalMilliseconds: 50000

timeToLiveSeconds: 60

maxRetries: 3

operationTimeoutMilliseconds: 50000

overwrite: true

mode.type: Cluster使用集群配置,单个部署也可以设置为Cluster,没影响mode.repository 配置存储方式,可以选择使用ZooKeepermode.overwrite,配置加载方式,本地配置是否覆盖配置中心配置。true是可覆盖,以本地为准,将本地配置同步到zookeeper;false则以zookeeper为准下面还有一些基础配置,是否打印SQL等,暂时可都是要默认

config-sharding.yaml

resources文件夹,conf文件夹下面schemaName 数据库连接,数据库名称dataSources 数据源rules 规则!SHARDING 分库分表规则LRGFMtables 表actualDataNodes 实际对于库表databaseStrategy 分库策略 none 不分库分表defaultDatabaseStrategy 默认分库策略defaultTableStrategy 默认分表策略defaultKeyGenerateStrategy 默认主键策略shardingAlgorithms 自定义分片算法keyGenerators 主键生成策略

config-encrypt.yaml

resources文件夹,conf文件夹下面schemaName 数据库连接,数据库名称dataSources 数据源rules 规则!ENCRYPT 数据加密encryptors 加密策略,可选择AES或MD5,在下面具体字段可选则加密策略aes_encryptor,aes可以配置加盐tables 表columns 字段sid_number 逻辑字段plainColumn 原字段cipherColumn 加密字段encryptorName 加密策略queryWithCipherColumn 查询时是否使用加密字段

其他

可以下载源码或者下载程序看看,里面的功能,都有配置文件案例,是注释掉的,一款PostgreSQL的,一款mysql的目前就使用这2个功能,其他功能暂时没研究,就不多说了实际使用时,分库分表和数据加密是一起使用的,所以只用了一个配置文件,都放在rules下面后面我会把我的配置文件贴上去

使用情况

政务新媒体SaaS平台暂时只使用分库分表数字乡村SaaS平台,使用了分库分表和数据加密分库分表,主要做了基于租户分库,部分表,又根据某些业务字段做了分表分表策略,默认分8个表写法algorithm-expression: monitor_record_${media_id % 8}我们基于租户的哈希进行分库,但对于某些租户,又想指定数据库,这就需要自定义分库分表策略要求分库支持哈希和指定,写了自定义分库策略类,有一个静态map,解析执行SQL时,先从map里获取,获取不到,则根据哈希获取数据加密,主要是添加加密字段和对历史数据处理可以写一个静态方法,对已存在数据进行处理

总结

sharding-proxy对于按照租户分库分表,以及数据加密,是完全支持的,足够我们使用使用起来很简单,下载最新稳定版安装即可如果没有自定义分库分表策略要求,只使用已有的策略,那只需要修改配置文件部署即可如果需要自定义分库分表策略,也不复杂,写好类打包好,放入ext-lib下即可配置文件部分示例

schemaName: digital_village

dataSources:

ds:

url: jdbc:postgresql://192.168.1.xxx:5432/digital_village?currentSchema=public&serverTimezone=UTC&useSSL=false

username: postgres

password: xxxxxx

connectionTimeoutMilliseconds: 30000

idleTimeoutMilliseconds: 60000

maxLifetimeMilliseconds: 1800000

maxPoolSize: 120

minPoolSize: 1

ds_0:

url: jdbc:postgresql://192.168.1.xxx:5432/digital_village_0?currentSchema=public&serverTimezone=UTC&useSSL=false

ds_1:

url: jdbc:postgresql://192.168.1.xxx:5432/digital_village_1?currentSchema=public&serverTimezone=UTC&useSSL=false

password: xxxxx

rules:

- !SHARDING

tables:

# 需要分库的表,根据租户id分库

cms_basic_info:

actualDataNodes: ds_${0..3}.cms_basic_info

cms_column:

actualDataNodes: ds_${0..3}.cms_column

cms_content:

actualDataNodes: ds_${0..3}.cms_content

cms_content_text:

actualDataNodes: ds_${0..3}.cms_content_text

cms_menu_column_bind:

actualDataNodes: ds_${0..3}.cms_menu_column_bind

cms_message_board:

actualDataNodes: ds_${0..3}.cms_message_board

# 不需要分库分表的表,全部存储在 ds 数据源

auth_cfg_catalog_data_permission:

actualDataNodes: ds.auth_cfg_catalog_data_permission

databaseStrategy:

none:

auth_cfg_column_data_permission:

actualDataNodes: ds.auth_cfg_column_data_permission

databaseStrategy:

# 默认分库策略

defaultDatabaseStrategy:

standard:

shardingColumn: customer_id #分库字段

shardingAlgorithmName: customer_id_inline #分库规则:

defaultTableStrategy:

none:

# 默认主键策略

defaultKeyGenerateStrategy:

column: id

keyGeneratorName: snowflake

# 自定义分片算法

shardingAlgorithms:

customer_id_inline:

type: CLASS_BASED

props:

strategy: standard

algorithmClassName: cn.lonsun.dv.DigitalVillageShardingAlgorithm

# 主键生成策略

keyGenerators:

snowflake:

type: SNOWFLAKE

worker-id: 123

- !ENCRYPT

encryptors:

aes_encryptor:

type: AES

aes-key-value: xxxwwaS213123SAD

md5_encryptor:

type: MD5

party_position:

columns:

mobile:

plainColumn: mobile

cipherColumn: mobile_cipher

encryptorName: aes_encryptor

village_population:

id_number:

plainColumn: id_number

cipherColumn: id_number_cipher

queryWithCipherColumn: true


版权声明:本文内容由网络用户投稿,版权归原作者所有,本站不拥有其著作权,亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容,请联系我们jiasou666@gmail.com 处理,核实后本网站将在24小时内删除侵权内容。

上一篇:利用Java实现简单的猜数字小游戏
下一篇:Java利用Socket和IO流实现文件的上传与下载
相关文章

 发表评论

暂时没有评论,来抢沙发吧~