电商系统设计到开发01 第一版设计到编码

2024-03-18 04:20
文章标签 设计 系统 开发 编码 01 电商 第一版

本文主要是介绍电商系统设计到开发01 第一版设计到编码，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

一、背景

为了学习和研究一个系统是如何演进并发展的，这里采取电商系统是因为电商系统不需要过多的解释业务背景，另外业务也会设计的相对简单，大家可以将关注点放在技术本身上。重点是研究宏观上的技术方案，以及方案对应的测试数据。

业务背景：假定用户下单后系统自动从用户余额中扣钱

二、下单流程图

2.1 业务说明

我只设计简单也，同时也简化模块功能，这里商品与订单放在一个系统，用户中心与账户放在同一个系统，所以只有2个系统，系统间的通信方式用OpenFeign + Consul

2.2 流程说明

  1. 用户点击下单
  2. 向数据库查询库存
  3. 库存足够就扣减库存，并创建订单（事务）
  4. 向用户中心发起支付请求
  5. user-center查询用户余额
  6. 若余额充足，则进行转账动作
  7. 转账成功后返回给goods-center
  8. goods-center 更新订单状态为交易成功

三、数据库表设计

CREATE DATABASE user_center_db;
CREATE DATABASE goods_center_db;CREATE TABLE user_center_db.user_info_tab (`id`  BIGINT(20) NOT NULL,`nick_name` VARCHAR(20) NOT NULL,`age` int(11) NOT NULL,`balance` DECIMAL(20,5)  NOT NULL COMMENT '余额',`create_time` datetime DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',`update_time` datetime DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新时间',PRIMARY KEY (`id`) USING BTREE
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT '用户信息表';CREATE TABLE user_center_db.account_flow_tab (`id`  BIGINT(20) NOT NULL,`order_id` BIGINT(20) NOT NULL COMMENT '订单ID',`src_account_id` BIGINT(20) NOT NULL COMMENT '转出账户' ,`target_account_id` BIGINT(20) NOT NULL COMMENT '转入账户' ,`transfer_amount` DECIMAL(20,5)  NOT NULL COMMENT '转账金额',`src_before_balance` DECIMAL(20,5)  NOT NULL COMMENT '转出账户转前余额',`src_after_balance` DECIMAL(20,5)  NOT NULL COMMENT '转出账户转后余额',`target_before_balance` DECIMAL(20,5)  NOT NULL COMMENT '转入账户转前余额',`target_after_balance` DECIMAL(20,5)  NOT NULL COMMENT '转入账户转后余额',`transfer_time` datetime NOT NULL COMMENT '转账时间',`create_time` datetime DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',`update_time` datetime DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新时间',PRIMARY KEY (`id`) USING BTREE,KEY `idx_order_id` (`order_id`),KEY `idx_src_account_id` (`src_account_id`),KEY `idx_target_account_id` (`target_account_id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT '账户流水表';CREATE TABLE goods_center_db.goods_info_tab (`id`  BIGINT(20) NOT NULL,`goods_name` VARCHAR(30) NOT NULL COMMENT '商品名称',`seller_id`  BIGINT(20) NOT NULL COMMENT '卖家ID',`stock` int(11) NOT NULL COMMENT '库存',`sold` int(11) NOT NULL COMMENT '已售数量',`price` DECIMAL(20,5) NOT NULL COMMENT '单价',`create_time` datetime DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',`update_time` datetime DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新时间',PRIMARY KEY (`id`) USING BTREE,KEY `idx_seller_id` (`seller_id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT '商品表';CREATE TABLE goods_center_db.order_info_tab (`id`  BIGINT(20) NOT NULL,`goods_id`  BIGINT(20) NOT NULL COMMENT '商品ID',`goods_name` VARCHAR(32) NOT NULL COMMENT '商品名称',`trade_number` int(11) NOT NULL COMMENT '交易数量',`seller_id`  BIGINT(20) NOT NULL COMMENT '卖家ID',`buyer_id`  BIGINT(20) NOT NULL COMMENT '买家ID',`order_amount` DECIMAL(20,5) NOT NULL COMMENT '订单金额=单价*数量',`order_status` TINYINT(4) NOT NULL COMMENT '订单状态: 1 创建中, 2 支付中, 3 支付成功, 11 已取消, 11 支付失败',`order_msg` VARCHAR(64) NOT NULL COMMENT '订单信息，描述订单失败或取消原因',`create_time` datetime DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',`update_time` datetime DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新时间',PRIMARY KEY (`id`) USING BTREE,KEY `idx_goods_id` (`goods_id`),KEY `idx_seller_id` (`seller_id`),KEY `idx_buyer_id` (`buyer_id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT '订单表';

四、代码编写

按照上述流程图我们开始编写自己的代码

4.1 代码的gitee地址

风萧萧兮/concurrency-entry-task

4.2 核心代码精选

 a 提交订单的主流程
    @Overridepublic OrderInfo submitOrder(SubmitOrderReq req) {//库存足够就扣减库存，并创建订单（事务）OrderInfo orderInfo = orderBizService.reduceStockAndCreateOrder(req);//向用户中心发起支付请求PayForOrderReq payForOrderReq = buildPayForOrderReq(orderInfo);PayForOrderResp resp = accountFacade.payForOrder(payForOrderReq);if (!resp.getIsSuccess()) {// 支付失败orderBizService.rollbackStockAndUpdateOrder(orderInfo);} else {// 支付成功orderInfo.setOrderStatus(OrderStatusEnum.PAID.getCode());orderInfoMapper.updateOrderStatusByPrimaryKey(orderInfo.getId(), orderInfo.getOrderStatus());}return orderInfo;}
 b 减少库存并创建订单（事务）
    // 减少库存并创建订单@Transactional(rollbackFor = {Exception.class})public OrderInfo reduceStockAndCreateOrder(SubmitOrderReq req) {//向数据库查询库存,并加锁GoodsInfo goodsInfo = goodsInfoMapper.selectByPrimaryKey(req.getGoodsId(), true);// 检查库存if (goodsInfo.getStock() < req.getTradeNumber()) {throw new RuntimeException("stock not enough");}// 扣减库存goodsInfoMapper.reduceStock(req.getGoodsId(), req.getTradeNumber());// 创建订单OrderInfo orderInfo = buildOrderInfo(req, goodsInfo);orderInfoMapper.insert(orderInfo);return orderInfo;}
c 支付失败回滚库存
    // 回滚库存并且更新订单@Transactional(rollbackFor = {Exception.class})public void rollbackStockAndUpdateOrder(OrderInfo orderInfo) {// 回滚库存goodsInfoMapper.rollbackStock(orderInfo.getGoodsId(), orderInfo.getTradeNumber());// 创建订单orderInfo.setOrderStatus(OrderStatusEnum.PAYMENT_FAILED.getCode());orderInfoMapper.updateOrderStatusByPrimaryKey(orderInfo.getId(), orderInfo.getOrderStatus());}
d 支付代码（幂等和事务）
 @Override@Transactional(rollbackFor = {Exception.class})public PayForOrderResp payForOrder(PayForOrderReq req) {PayForOrderResp resp = new PayForOrderResp();// 幂等处理，查询是否已经有流水了AccountFlow flow = accountFlowMapper.selectByOrderId(req.getOrderId());if (flow != null) {resp.setIsSuccess(true);return resp;}UserInfo srcAccount = userInfoMapper.selectByPrimaryKey(req.getSrcAccountId(), true);// 余额不足if (srcAccount.getBalance().compareTo(req.getTransferAmount()) < 0) {resp.setIsSuccess(false);resp.setMsg("amount not enough");return resp;}UserInfo targetAccount = userInfoMapper.selectByPrimaryKey(req.getTargetAccountId(), true);BigDecimal srcBeforeBalance = srcAccount.getBalance();BigDecimal targetBeforeBalance = targetAccount.getBalance();//若余额充足，则进行转账动作srcAccount.setBalance(srcAccount.getBalance().subtract(req.getTransferAmount()));targetAccount.setBalance(targetAccount.getBalance().add(req.getTransferAmount()));userInfoMapper.updateByPrimaryKey(srcAccount);userInfoMapper.updateByPrimaryKey(targetAccount);BigDecimal srcAfterBalance = srcAccount.getBalance();BigDecimal targetAfterBalance = targetAccount.getBalance();flow = genAccountFlow(req, srcBeforeBalance, targetBeforeBalance, srcAfterBalance, targetAfterBalance);accountFlowMapper.insert(flow);resp.setIsSuccess(true);return resp;}

五、主流程测试

5.1 造数(代码写在单元测试目录下)

a 初始化用户
    private void intUser() {List<UserInfo> list = new ArrayList<>();int batchSize = 200;for (int i = 1; i <= 1000; i++) {UserInfo userInfo = new UserInfo();userInfo.setId(SnowFlakeUtils.nextId());userInfo.setNickName("机器人~" + i);userInfo.setAge(10);userInfo.setBalance(new BigDecimal(10000));list.add(userInfo);if (i % batchSize == 0) {userInfoMapper.batchInsert(list);list = new ArrayList<>();}}}
b 初始化商品
sellerId 从前面生成好的用户数据中，选一个作为商品的卖家
	private void intGoods() {List<GoodsInfo> list = new ArrayList<>();int batchSize = 200;for (int i = 1; i <= 1000; i++) {GoodsInfo goodsInfo = new GoodsInfo();goodsInfo.setId(SnowFlakeUtils.nextId());goodsInfo.setGoodsName("虚拟商品~" + i);goodsInfo.setSellerId(8436039040700628992L);goodsInfo.setStock(100_0000);goodsInfo.setSold(0);goodsInfo.setPrice(new BigDecimal(1));list.add(goodsInfo);if (i % batchSize == 0) {goodsInfoMapper.batchInsert(list);list = new ArrayList<>();}}}

5.2 执行

所有的数据都正确，主流程测试成功（说明：因为代码刚刚开始也是有少量bug的，我进行了多次调试，金额是经过多次转账的，所以看到的金额可能有点奇怪，最后的操作我验证过是正确的）

下篇文章，我将进行压力测试，看看在这种架构下系统的支持的并发请求数是多少，并分析原因！！！

这篇关于电商系统设计到开发01 第一版设计到编码的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/821158。

相关文章

使用Python开发一个简单的本地图片服务器

使用Python开发一个简单的本地图片服务器

《使用Python开发一个简单的本地图片服务器》本文介绍了如何结合wxPython构建的图形用户界面GUI和Python内建的Web服务器功能,在本地网络中搭建一个私人的,即开即用的网页相册,文中的示... 目录项目目标核心技术栈代码深度解析完整代码工作流程主要功能与优势潜在改进与思考运行结果总结你是否曾经
阅读更多...
Python FastAPI+Celery+RabbitMQ实现分布式图片水印处理系统

Python FastAPI+Celery+RabbitMQ实现分布式图片水印处理系统

《PythonFastAPI+Celery+RabbitMQ实现分布式图片水印处理系统》这篇文章主要为大家详细介绍了PythonFastAPI如何结合Celery以及RabbitMQ实现简单的分布式... 实现思路FastAPI 服务器Celery 任务队列RabbitMQ 作为消息代理定时任务处理完整
阅读更多...
Linux系统中卸载与安装JDK的详细教程

Linux系统中卸载与安装JDK的详细教程

《Linux系统中卸载与安装JDK的详细教程》本文详细介绍了如何在Linux系统中通过Xshell和Xftp工具连接与传输文件,然后进行JDK的安装与卸载,安装步骤包括连接Linux、传输JDK安装包... 目录1、卸载1.1 linux删除自带的JDK1.2 Linux上卸载自己安装的JDK2、安装2.1
阅读更多...
Python使用自带的base64库进行base64编码和解码

Python使用自带的base64库进行base64编码和解码

《Python使用自带的base64库进行base64编码和解码》在Python中,处理数据的编码和解码是数据传输和存储中非常普遍的需求,其中,Base64是一种常用的编码方案,本文我将详细介绍如何使... 目录引言使用python的base64库进行编码和解码编码函数解码函数Base64编码的应用场景注意
阅读更多...
Spring Boot + MyBatis Plus 高效开发实战从入门到进阶优化(推荐)

Spring Boot + MyBatis Plus 高效开发实战从入门到进阶优化(推荐)

《SpringBoot+MyBatisPlus高效开发实战从入门到进阶优化(推荐)》本文将详细介绍SpringBoot+MyBatisPlus的完整开发流程,并深入剖析分页查询、批量操作、动... 目录Spring Boot + MyBATis Plus 高效开发实战：从入门到进阶优化1. MyBatis
阅读更多...
Python基于wxPython和FFmpeg开发一个视频标签工具

Python基于wxPython和FFmpeg开发一个视频标签工具

《Python基于wxPython和FFmpeg开发一个视频标签工具》在当今数字媒体时代,视频内容的管理和标记变得越来越重要,无论是研究人员需要对实验视频进行时间点标记,还是个人用户希望对家庭视频进行... 目录引言1. 应用概述2. 技术栈分析2.1 核心库和模块2.2 wxpython作为GUI选择的优
阅读更多...
利用Python开发Markdown表格结构转换为Excel工具

利用Python开发Markdown表格结构转换为Excel工具

《利用Python开发Markdown表格结构转换为Excel工具》在数据管理和文档编写过程中,我们经常使用Markdown来记录表格数据,但它没有Excel使用方便,所以本文将使用Python编写一... 目录1.完整代码2. 项目概述3. 代码解析3.1 依赖库3.2 GUI 设计3.3 解析 Mark
阅读更多...
利用Go语言开发文件操作工具轻松处理所有文件

利用Go语言开发文件操作工具轻松处理所有文件

《利用Go语言开发文件操作工具轻松处理所有文件》在后端开发中,文件操作是一个非常常见但又容易出错的场景,本文小编要向大家介绍一个强大的Go语言文件操作工具库,它能帮你轻松处理各种文件操作场景... 目录为什么需要这个工具？核心功能详解1. 文件/目录存javascript在性检查2. 批量创建目录3. 文件
阅读更多...
Linux系统之主机网络配置方式

Linux系统之主机网络配置方式

《Linux系统之主机网络配置方式》：本文主要介绍Linux系统之主机网络配置方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录一、查看主机的网络参数1、查看主机名2、查看IP地址3、查看网关4、查看DNS二、配置网卡1、修改网卡配置文件2、nmcli工具【通用
阅读更多...
Linux系统之dns域名解析全过程

Linux系统之dns域名解析全过程

《Linux系统之dns域名解析全过程》：本文主要介绍Linux系统之dns域名解析全过程,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录一、dns域名解析介绍1、DNS核心概念1.1 区域 zone1.2 记录 record二、DNS服务的配置1、正向解析的配置
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2