如今微服务技术越来越成熟#xff0c;很多企业都采用微服务架构来支撑内部及对外的业务#xff0c;尤其是在高

并发大流量的电商业务场景下#xff0c;微服务…随着互联网的不断发展互联网企业的业务在飞速变化推动着系统架构也在不断地发生变化。

如今微服务技术越来越成熟很多企业都采用微服务架构来支撑内部及对外的业务尤其是在高

并发大流量的电商业务场景下微服务更是企业首选的架构模式。

随着业务发展壮大用户量暴

涨单节点处理能力就会成为瓶颈如果并发量居高不下服务器很容易因负载过高而导致崩溃

宕机。

出于高并发高可用的考虑项目就应该演变到分布式架构了。

然而分布式环境下我们又

会面临更多的挑战需要去应对。

比如1、分布式系统中接口繁多重试机制必不可少接口幂等性问题2、如果下单、付款分布在不同的服务上如何保证跨服务事务?3、高并发场景下资源共享问题4、分库分表后引发了ID重复问题那么我们需要如何解决分布式呢文章目录分布式全局唯一ID分布式全局唯一ID解决方案什么是雪花算法SonwFlake雪花算法SonwFlake落地实现雪花算法SonwFlake落地实现之Mybatis

Plus分布式全局唯一ID

随着系统数据量越来越大单数据库压力太大无法维持性能所以可能就需要变成一主多从这样读写分离随着继续扩大一主多从也无法支撑了。

这时就需要分库分表这样的话就会出现不同库表之间的数据id不能再依赖数据库自增的id而需要外部一种方式生成全局统一的唯一id。

分布式ID需要满足什么条件

⭐高性能不能在生成id上浪费过多的时间使其成为功能的性能瓶颈。

⭐趋势递增这个不是必须的但是最好还是满足因为比如innodb索引就是按照键值排序的所以有序性可以让维护索引的效率提高。

分布式全局唯一ID解决方案

Java本身提供了UUID这是一个唯一的字符串它可以不依赖其他工具在本地生成。

⭐代码实现简单

一个数据库压力大就搞多个数据库之后搞一个Step步长的概念每个数据库的自增起始值不同但是他们的增长Step相同。

如下图所示。

⭐返回的分布式ID是趋势递增的id唯一。

解决了单点问题即使一个宕机其他的还可以提供服务。

⭐单点压力还是很大因为DB本身写操作就耗时间。

最主要的问题还是扩容困难比如要加一台DB3是很难加进来的除非停机将所有DB的id进行修改同时修改步长。

号段模式

它没有采用新插入记录返回id的方案而是一个业务类型就是一行数据用一行数据来维护这个业务的自增id。

服务来修改这行数据的max_id比如当前max_id值是0那么来给max_id加上1000如果返回成功就代表这个服务获得了1-1000这段分布式id之后将这段缓存在服务内部用完之后再来表中取。

⭐效率很高db的压力减小而且一张表可以维护很多业务的分布式id。

Redis自增key方案

SnowFlake生成的是一个Long类型的值Long类型的数据占用8个字节也就是64位。

SnowFlake将64进行拆分每个部分具有不同的含义当然机器码、序列号的位数可以自定义也可以。

⭐时钟回拨问题强烈依赖于服务器的时间如果时间出现时间回拨就可能出现重复的id。

Snowflake常称为雪花算法是Twitter开源的分布式ID生成算法生成后是一个64bit的long型数值组成部分引入了时间戳基本保持了自增。

雪花算法作用

依赖系统时间如果系统时间被回调或者改变可能会造成ID冲突或者重复

雪花算法组成

⭕1位不用二进制中的最高位是符号位1表示负数0表示正数由于我们生成的雪花算法都是正整数所以这里是0

⭕41位这里的时间戳是表示的是从起始时间算起到生成id时间所经历的时间戳也就是(当前时间戳-起始时间戳(固定))

⭕10位这里的10位代表工作机器id一共可以部署在2^101024台机器上面10位又可以分为前面五位是数据中心id(0~31)后面五位是机器id(0-31)

雪花算法SonwFlake落地实现

Hutool是一个小而全的Java工具类库通过静态方法封装降低相关API的学习成本提高工作效率使Java拥有函数式语言般的优雅让Java语言也可以“甜甜的”。

引入相关依赖

https://mvnrepository.com/artifact/cn.hutool/hu

tool-all

dependencygroupIdcn.hutool/groupIdartifactIdhutool-all/artifactIdversion5.7.13/version

/dependencySnowflake

分布式系统中有一些需要使用全局唯一ID的场景有些时候我们希望能使用一种简单一些的ID并且希望ID能够按照时间有序生成。

Twitter的Snowflake

//参数1为机器标识

snowflake.getSnowflakeNextIdStr();雪花算法SpringBoot引用

config文件

org.springframework.stereotype.Component;

import

javax.annotation.PostConstruct;

Slf4j

init(){try{//获取本机的ip地址编码workerId

NetUtil.ipv4ToLong(NetUtil.getLocalhostStr());log.info(当前机器的workerId:

workerId);}catch

e){e.printStackTrace();log.warn(当前机器的workerId获取失败

---

NetUtil.getLocalhostStr().hashCode();}}/**

Mybatis

dependenciesdependencygroupIdorg.springframework.boot/groupIdartifactIdspring-bootstarter/artifactId/dependencydependencygroupIdorg.projectlombok/groupIdartifactIdlombok/artifactIdoptionaltrue/optional/dependencydependencygroupIdcom.baomidou/groupIdartifactIdmybatis-plus-bootstarter/artifactIdversion3.4.2/version/dependencydependencygroupIdmysql/groupIdartifactIdmysql-connectorjava/artifactId/dependencydependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-startertest/artifactIdscopetest/scopeexclusionsexclusiongroupIdorg.junit.vintage/groupIdartifactIdjunit-vintageengine/artifactId/exclusion/exclusions/dependency/dependencies编写相关配置

application.yml

spring.datasource.driver-classnamecom.mysql.cj.jdbc.Driver

spring.datasource.urljdbc:mysql://192.168.66.1

spring.datasource.password123456开启MapperScan扫描

Spring

MapperScan(com.itbaizhan.sonwflake.mapper)

public

{SpringApplication.run(Application.class,

args);}

User();user.setName(张三);user.setAge(18);user.setEmail(23472qq.com);userMapper.insert(user);}