电商系统设计到开发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。

相关文章

Java实现字节字符转bcd编码

Java实现字节字符转bcd编码

《Java实现字节字符转bcd编码》BCD是一种将十进制数字编码为二进制的表示方式,常用于数字显示和存储,本文将介绍如何在Java中实现字节字符转BCD码的过程,需要的小伙伴可以了解下... 目录前言BCD码是什么Java实现字节转bcd编码方法补充总结前言BCD码（Binary-Coded Decima
阅读更多...
SpringBoot 多环境开发实战(从配置、管理与控制)

SpringBoot 多环境开发实战(从配置、管理与控制)

《SpringBoot多环境开发实战(从配置、管理与控制)》本文详解SpringBoot多环境配置,涵盖单文件YAML、多文件模式、MavenProfile分组及激活策略,通过优先级控制灵活切换环境... 目录一、多环境开发基础（单文件 YAML 版）（一）配置原理与优势（二）实操示例二、多环境开发多文件版
阅读更多...
使用docker搭建嵌入式Linux开发环境

使用docker搭建嵌入式Linux开发环境

《使用docker搭建嵌入式Linux开发环境》本文主要介绍了使用docker搭建嵌入式Linux开发环境,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面... 目录1、前言2、安装docker3、编写容器管理脚本4、创建容器1、前言在日常开发全志、rk等不同
阅读更多...
JWT + 拦截器实现无状态登录系统

JWT + 拦截器实现无状态登录系统

《JWT+拦截器实现无状态登录系统》JWT（JSONWebToken）提供了一种无状态的解决方案：用户登录后,服务器返回一个Token,后续请求携带该Token即可完成身份验证,无需服务器存储会话... 目录✅ 引言 一、JWT 是什么？ 二、技术选型 三、项目结构 四、核心代码实现4.1 添加依赖（pom
阅读更多...
基于Python实现自动化邮件发送系统的完整指南

基于Python实现自动化邮件发送系统的完整指南

《基于Python实现自动化邮件发送系统的完整指南》在现代软件开发和自动化流程中,邮件通知是一个常见且实用的功能,无论是用于发送报告、告警信息还是用户提醒,通过Python实现自动化的邮件发送功能都能... 目录一、前言：二、项目概述三、配置文件 `.env` 解析四、代码结构解析1. 导入模块2. 加载环
阅读更多...
Python实战之SEO优化自动化工具开发指南

Python实战之SEO优化自动化工具开发指南

《Python实战之SEO优化自动化工具开发指南》在数字化营销时代,搜索引擎优化（SEO）已成为网站获取流量的重要手段,本文将带您使用Python开发一套完整的SEO自动化工具,需要的可以了解下... 目录前言项目概述技术栈选择核心模块实现1. 关键词研究模块2. 网站技术seo检测模块3. 内容优化分析模
阅读更多...
linux系统上安装JDK8全过程

linux系统上安装JDK8全过程

《linux系统上安装JDK8全过程》文章介绍安装JDK的必要性及Linux下JDK8的安装步骤,包括卸载旧版本、下载解压、配置环境变量等,强调开发需JDK,运行可选JRE,现JDK已集成JRE... 目录为什么要安装jdk？1.查看linux系统是否有自带的jdk：2.下载jdk压缩包2.解压3.配置环境
阅读更多...
基于Java开发一个极简版敏感词检测工具

基于Java开发一个极简版敏感词检测工具

《基于Java开发一个极简版敏感词检测工具》这篇文章主要为大家详细介绍了如何基于Java开发一个极简版敏感词检测工具,文中的示例代码简洁易懂,感兴趣的小伙伴可以跟随小编一起学习一下... 目录你是否还在为敏感词检测头疼一、极简版Java敏感词检测工具的3大核心优势1.1 优势1：DFA算法驱动，效率提升10
阅读更多...
Java 中编码与解码的具体实现方法

Java 中编码与解码的具体实现方法

《Java中编码与解码的具体实现方法》在Java中,字符编码与解码是处理数据的重要组成部分,正确的编码和解码可以确保字符数据在存储、传输、读取时不会出现乱码,本文将详细介绍Java中字符编码与解码的... 目录Java 中编码与解码的实现详解1. 什么是字符编码与解码？1.1 字符编码（Encoding）1
阅读更多...
Python开发简易网络服务器的示例详解(新手入门)

Python开发简易网络服务器的示例详解(新手入门)

《Python开发简易网络服务器的示例详解(新手入门)》网络服务器是互联网基础设施的核心组件,它本质上是一个持续运行的程序,负责监听特定端口,本文将使用Python开发一个简单的网络服务器,感兴趣的小... 目录网络服务器基础概念python内置服务器模块1. HTTP服务器模块2. Socket服务器模块
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2