Apache ShardingSphere 在转转亿级交易系统落地实践

2023-11-23 05:18

本文主要是介绍Apache ShardingSphere 在转转亿级交易系统落地实践,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

、背景与挑战

这几年随着转转二手业务的快速发展,订单系统的基础性能问题也愈发严重,作为系统运转的基石,订单库压力不容小觑。

面临的问题:

  • 大促期间 DB 压力大,单库查询 qps 上万占用大量数据库资源,写性能大大降低;

  • 数据与日剧增,单库中包含非常多数据量过数亿的大表,占用空间接近服务器的容量上限;

  • 数据量太大,数据备份和恢复需要耗费很长时间,极端情况下丢失数据的风险越高。

二、为什么选 ShardingSphere

迫于上述所说的 DB 压力问题,起初我们做了一些缓解措施,其中包括:

  • 优化大事务,缩小事务范围,甚至消除事务

33da38dedfbae0b0e88ae19eff0a6d3f.png

通过调整原有业务逻辑顺序将核心的生单步骤放置在最后,仅在订单主表保持事务,主表操作异常时其他订单相关的表允许有脏数据产生。

  • 订单数据添加缓存

1fb41391173d061802af41bee2c02dec.png

缓存这块最重要同时最麻烦的地方是保证数据的一致性,订单信息涉及结算抽佣等,数据的不实时或不一致会造成严重事故。

严格保证缓存数据的一致性,代码实现比较复杂同时会降低系统的并发,因此缓存方案实现这块我们做了一定的妥协:
  1. 允许数据缓存失败情况下请求直接查库;
  2. 给缓存 key 添加版本号,通过读最新版本号的数据确保数据的实时性。

  • 复杂查询走 ES、主从分离、一些大表进行冷热数据分离等

e03558f8022468c96e18e631a7715d68.png

通过上述几个方面的优化 DB 压力虽有所下降,但面对大促等一些高并发场景时仍显得力不从心。为了从根本上解决订单库的性能问题,我们决定对订单库进行数据分片(分库分表)改造,使得未来 3-5 年内不需要担心订单容量问题。

数据分片组件选型这块,我们从效率、稳定性、学习成本和时间多个方面对比,最终选择了 ShardingSphere。

ShardingSphere 优势如下:

  • 提供标准化的数据分片、分布式事务和数据库治理功能,可适用于如 Java 同构、异构语言、容器、云原生等各种多样化的应用场景;

  • 分片策略灵活,支持多种分片方式;

  • 集成方便、业务侵入程度低;

  • 文档丰富、社区活跃。

ShardingSphere 提出 DB Plus 的理念,采用可插拔的架构设计,模块相互独立,可以单独使用,亦可以灵活组合使用。目前 ShardingSphere 由 JDBC、Proxy 和 Sidecar(规划中)这 3 款既能够独立部署,又支持混合部署配合使用的产品组成。

3 款产品特性对比如下:

6c86e547b158bb043bb4ae321e2a9cb0.png

通过上图对比,结合订单高并发特性,本次数据分片中间件选择了 ShardingSphere-JDBC。

ShardingSphere-JDBC 定位为轻量级 Java 框架,在 JDBC 层提供的额外服务。它使用客户端直连数据库,以 jar 包形式提供服务,无需额外部署和依赖,可理解为增强版的 JDBC 驱动,完全兼容 JDBC 和各种 ORM 框架。

0b1541b0256b5cfeab4541e585112b55.png

随着 5.x 版本的发布,ShardingSphere 还提供了许多新特性:

  1. 全新 distsql 用于加载及展示 shardingsphere 配置信息

  2. 支持跨不同数据库实例的分片 join sql 查询

  3. 增加数据网关能力,支持异构数据库存储

  4. 支持在线动态创建及修改用户权限

  5. 新增自动化探针模块

三、项目落地中的关键点

  • 分片 key 的选择

当前订单 id 的生成,采用了时间戳+用户标识码+机器码+递增序列的方式,其中用户标识码取自买家 id 的第 9~16 位,该码是用户 id 生成时的真随机位,很适合作为分片 key。

  • 选择该用户标识码作为分片 key 有如下优势:

    • 可以使分到各个库表的数据尽可能均匀;

    • 无论是以订单 id、还是以买家 id 作为查询条件,都可以快速定位到具体分片位置;

    • 同一买家的数据能分布到相同的库表,方便买家维度的聚合查询。

98b4a9582ff2ea29234c5765163b39e1.png

具体分片策略上:我们采用了 16 库 16 表,用户标识码取模分库,用户标识码高四位取模分表。

  • 新老库数据迁移

    • 迁移必须是在线的,不考虑停机迁移,迁移的过程中还会有数据的写入;

    • 数据应该是完整的,C 端体验是无感知的,迁移之后需要保证新库和旧库的数据是严格一致的;

    • 迁移过程中需要做到可以回滚,一旦迁移过程中出现问题,可以立即回滚到源库,不会对系统可用性造成影响。

  数据迁移步骤如下:双写->迁移历史数据->校验->老库下线。

四、效果&收益

  • 解决了单库容量上限问题;

  • 数据分片后单库表的数据量大大减少,单表数据量由原来的近亿降为百万级别,总体性能大大提高;

  • 降低了因单库、单表数据过大极端情况数据丢失风险,减轻运维压力。

以下是两次大促期间,下单服务接口调用量与接口耗时对比。

改造前:

c4b8f9e5e2bde4aea55e74eefaa439cd.png

改造后:

9dc439c149f30c50aadcbf8957a8ffc0.png

五、总结感悟

任何公司的“分库分表项目”说白了,都不是一个考验点子思路的常见项目,更多的反而是对一个人、一个团队干活的细致程度、上下游部门的沟通协作、工程化的操作实施以及抗压能力的综合考验。

同时业务的不断发展,又促使系统数据架构需要跟着不断升级,ShardingSphere 以其良好的架构设计、高度灵活、可插拔和可扩展的能力简化了数据分片的开发难度,使研发团队只需关注业务本身,进而实现了数据架构的灵活扩展。

附,最终技术方案目录:

2ae871a49e13982704ef60e60d45b0b1.png
作者简介

张强,转转交易中台研发工程师

这篇关于Apache ShardingSphere 在转转亿级交易系统落地实践的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/415609

相关文章

在 Spring Boot 中实现异常处理最佳实践

《在SpringBoot中实现异常处理最佳实践》本文介绍如何在SpringBoot中实现异常处理,涵盖核心概念、实现方法、与先前查询的集成、性能分析、常见问题和最佳实践,感兴趣的朋友一起看看吧... 目录一、Spring Boot 异常处理的背景与核心概念1.1 为什么需要异常处理?1.2 Spring B

Spring Boot 整合 SSE的高级实践(Server-Sent Events)

《SpringBoot整合SSE的高级实践(Server-SentEvents)》SSE(Server-SentEvents)是一种基于HTTP协议的单向通信机制,允许服务器向浏览器持续发送实... 目录1、简述2、Spring Boot 中的SSE实现2.1 添加依赖2.2 实现后端接口2.3 配置超时时

Python使用getopt处理命令行参数示例解析(最佳实践)

《Python使用getopt处理命令行参数示例解析(最佳实践)》getopt模块是Python标准库中一个简单但强大的命令行参数处理工具,它特别适合那些需要快速实现基本命令行参数解析的场景,或者需要... 目录为什么需要处理命令行参数?getopt模块基础实际应用示例与其他参数处理方式的比较常见问http

Java Optional的使用技巧与最佳实践

《JavaOptional的使用技巧与最佳实践》在Java中,Optional是用于优雅处理null的容器类,其核心目标是显式提醒开发者处理空值场景,避免NullPointerExce... 目录一、Optional 的核心用途二、使用技巧与最佳实践三、常见误区与反模式四、替代方案与扩展五、总结在 Java

Spring Boot循环依赖原理、解决方案与最佳实践(全解析)

《SpringBoot循环依赖原理、解决方案与最佳实践(全解析)》循环依赖指两个或多个Bean相互直接或间接引用,形成闭环依赖关系,:本文主要介绍SpringBoot循环依赖原理、解决方案与最... 目录一、循环依赖的本质与危害1.1 什么是循环依赖?1.2 核心危害二、Spring的三级缓存机制2.1 三

深入理解Apache Kafka(分布式流处理平台)

《深入理解ApacheKafka(分布式流处理平台)》ApacheKafka作为现代分布式系统中的核心中间件,为构建高吞吐量、低延迟的数据管道提供了强大支持,本文将深入探讨Kafka的核心概念、架构... 目录引言一、Apache Kafka概述1.1 什么是Kafka?1.2 Kafka的核心概念二、Ka

Python 中的 with open文件操作的最佳实践

《Python中的withopen文件操作的最佳实践》在Python中,withopen()提供了一个简洁而安全的方式来处理文件操作,它不仅能确保文件在操作完成后自动关闭,还能处理文件操作中的异... 目录什么是 with open()?为什么使用 with open()?使用 with open() 进行

Spring Boot 配置文件之类型、加载顺序与最佳实践记录

《SpringBoot配置文件之类型、加载顺序与最佳实践记录》SpringBoot的配置文件是灵活且强大的工具,通过合理的配置管理,可以让应用开发和部署更加高效,无论是简单的属性配置,还是复杂... 目录Spring Boot 配置文件详解一、Spring Boot 配置文件类型1.1 applicatio

tomcat多实例部署的项目实践

《tomcat多实例部署的项目实践》Tomcat多实例是指在一台设备上运行多个Tomcat服务,这些Tomcat相互独立,本文主要介绍了tomcat多实例部署的项目实践,具有一定的参考价值,感兴趣的可... 目录1.创建项目目录,测试文China编程件2js.创建实例的安装目录3.准备实例的配置文件4.编辑实例的

Python 中的异步与同步深度解析(实践记录)

《Python中的异步与同步深度解析(实践记录)》在Python编程世界里,异步和同步的概念是理解程序执行流程和性能优化的关键,这篇文章将带你深入了解它们的差异,以及阻塞和非阻塞的特性,同时通过实际... 目录python中的异步与同步:深度解析与实践异步与同步的定义异步同步阻塞与非阻塞的概念阻塞非阻塞同步