一、项目结构

1、工程结构

2、模块命名

shard-common-entity：   公共代码块
shard-open-inte：        开放接口管理
shard-eureka-7001：      注册中心
shard-two-provider-8001： 8001 基于两台库的服务
shard-three-provider-8002：8002 基于三台库的服务

3、代码依赖结构

4、项目启动顺序

（1）shard-eureka-7001：        注册中心
（2）shard-two-provider-8001：  8001 基于两台库的服务
（3）shard-three-provider-8002：8002 基于三台库的服务

按照顺序启动，且等一个服务完全启动后，在启动下一个服务，不然可能遇到一些坑。

二、核心代码块

1、8001 服务提供一个对外服务

基于Feign的调用方式
作用：基于两台分库分表的数据查询接口。

import org.springframework.cloud.netflix.feign.FeignClient;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import shard.jdbc.common.entity.TableOne;
/*** shard-two-provider-8001* 对外开放接口*/
@FeignClient(value = "shard-provider-8001")
public interface TwoOpenService {@RequestMapping("/selectOneByPhone/{phone}")TableOne selectOneByPhone(@PathVariable("phone") String phone) ;
}

2、8002 服务提供一个对外服务

基于Feign的调用方式
作用：基于三台分库分表的数据存储接口。

import org.springframework.cloud.netflix.feign.FeignClient;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import shard.jdbc.common.entity.TableOne;/*** 数据迁移服务接口*/
@FeignClient(value = "shard-provider-8002")
public interface MoveDataService {@RequestMapping("/moveData")Integer moveData (@RequestBody TableOne tableOne) ;
}

3、基于8002服务数据查询接口

查询流程图

代码块

/*** 8001 端口 ：基于两台分库分表策略的数据查询接口*/
@Resource
private TwoOpenService twoOpenService ;
@Override
public TableOne selectOneByPhone(String phone) {TableOne tableOne = tableOneMapper.selectOneByPhone(phone);if (tableOne != null){LOG.info("8002 === >> tableOne :"+tableOne);}// 8002 服务没有查到数据if (tableOne == null){// 调用 8001 开放的查询接口tableOne = twoOpenService.selectOneByPhone(phone) ;LOG.info("8001 === >> tableOne :"+tableOne);}return tableOne ;
}

4、基于 8001 数据扫描迁移代码

迁移流程图

代码块

/*** 8002 端口开放的数据入库接口*/
@Resource
private MoveDataService moveDataService ;
/*** 扫描，并迁移数据* 以 库 db_2 的 table_one_1 表为例*/
@Override
public void scanDataRun() {String sql = "SELECT id,phone,back_one backOne,back_two backTwo,back_three backThree FROM table_one_1" ;// dataTwoTemplate 对应的数据库：ds_2List<TableOne> tableOneList = dataTwoTemplate.query(sql,new Object[]{},new BeanPropertyRowMapper<>(TableOne.class)) ;if (tableOneList != null && tableOneList.size()>0){int i = 0 ;for (TableOne tableOne : tableOneList) {String db_num = HashUtil.moveDb(tableOne.getPhone()) ;String tb_num = HashUtil.moveTable(tableOne.getPhone()) ;// 只演示向数据新加库 ds_4 迁移的数据if (db_num.equals("ds_4")){i += 1 ;LOG.info("迁移总数数=>" + i + "=>库位置=>"+db_num+"=>表位置=>"+tb_num+"=>数据：【"+tableOne+"】");// 扫描完成：执行新库迁移和旧库清理过程moveDataService.moveData(tableOne) ;// dataTwoTemplate.update("DELETE FROM table_one_1 WHERE id=? AND phone=?",tableOne.getId(),tableOne.getPhone());}}}
}

三、演示执行流程

1、项目流程图

2、测试执行流程

（1）、访问8002 数据查询端口

http://127.0.0.1:8002/selectOneByPhone/phone20
日志输出：
8001 服务查询到数据
8001 === >> tableOne :+{tableOne}

（2）、执行8001 数据扫描迁移

http://127.0.0.1:8001/scanData

（3）、再次访问8002 数据查询端口

http://127.0.0.1:8002/selectOneByPhone/phone20
日志输出：
8002 服务查询到数据
8002 === >> tableOne :+{tableOne}

四、源代码

https://github.com/cicadasmile/cloud-shard-jdbc

关注公众号号：【知了一笑】，持续更新

基于SpringCloud实现Shard-Jdbc的分库分表模式，数据库扩容方案相关推荐

架构组件：基于Shard-Jdbc分库分表，数据库扩容方案
架构组件:基于Shard-Jdbc分库分表,数据库扩容方案一.数据库扩容 1.业务场景互联网项目中有很多"数据量大,业务复杂度高,需要分库分表"的业务场景. 这样分层的架构 ( ...
MySQL 分库分表及其平滑扩容方案
作者:王克锋出处:https://kefeng.wang/2018/07/22/mysql-sharding/ 众所周知,数据库很容易成为应用系统的瓶颈.单机数据库的资源和处理能力有限,在高并发的分 ...
MySQL关于分库分表及其平滑扩容方案
众所周知,数据库很容易成为应用系统的瓶颈.单机数据库的资源和处理能力有限,在高并发的分布式系统中,可采用分库分表突破单机局限.本文总结了分库分表的相关概念.全局ID的生成策略.分片策略.平滑扩容方案. ...
mysql数据库分表备份脚本_MySQL分库分表备份数据库脚本的操作
MySQL分库分表备份数据库脚本的操作发布时间:2020-05-26 16:52:23 来源:51CTO 阅读:134 作者:三月本篇文章给大家主要讲的是关于MySQL分库分表备份数据库脚本的操作 ...
springcloud mysql库集群_SpringCloud实现分库分表模式下，数据库实时扩容方案
一.项目结构 1.工程结构 2.模块命名 shard-common-entity: 公共代码块 shard-open-inte: 开放接口管理 shard-eureka-7001: 注册中心 shar ...
架构组件：基于shard-jdbc中间件，实现数据分库分表
一.水平分割 1.水平分库 1).概念: 以字段为依据,按照一定策略,将一个库中的数据拆分到多个库中. 2).结果每个库的结构都一样:数据都不一样: 所有库的并集是全量数据: 2.水平分表 1).概 ...
深入理解分布式技术 - 分库分表后的扩容解决方案
文章目录概述路由规则与扩容方案对主键进行哈希取模优点缺点基于数据范围进行拆分结合数据范围和哈希取模小结概述在实际开发中,数据库的扩容和不同的分库分表规则直接相关,今天我们从系统设计 ...
Linux数据库管理——day10——分库分表、数据库硬件优化
分库分表分库分表也称作分片技术,主要作用是将存放在一个数据库中的数据按照特定的方法进行拆分,分散存放在多个数据库中,以达到分散多台设备实现负载均衡垂直分割纵向切分,把一个表 ...
mysql分库分表 ppt_数据库分库分表中间件架构解析.ppt
数据库分库分表中间件架构解析 Processor(1) Processor(n) MySQL MySQL MySQL Cobar结构 Front-end Communication Applicati ...

基于SpringCloud实现Shard-Jdbc的分库分表模式，数据库扩容方案

一、项目结构

1、工程结构

2、模块命名

3、代码依赖结构

4、项目启动顺序

二、核心代码块

1、8001 服务提供一个对外服务

2、8002 服务提供一个对外服务

3、基于8002服务数据查询接口

4、基于 8001 数据扫描迁移代码

三、演示执行流程

1、项目流程图

2、测试执行流程

四、源代码

基于SpringCloud实现Shard-Jdbc的分库分表模式，数据库扩容方案相关推荐

最新文章

热门文章