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

相关文章

不懂推荐算法也能设计推荐系统

不懂推荐算法也能设计推荐系统

本文以商业化应用推荐为例，告诉我们不懂推荐算法的产品，也能从产品侧出发， 设计出一款不错的推荐系统。 相信很多新手产品，看到算法二字，多是懵圈的。 什么排序算法、最短路径等都是相对传统的算法（注：传统是指科班出身的产品都会接触过）。但对于推荐算法，多数产品对着网上搜到的资源，都会无从下手。特别当某些推荐算法 和 “AI”扯上关系后，更是加大了理解的难度。 但，不了解推荐算法，就无法做推荐系
阅读更多...
这15个Vue指令，让你的项目开发爽到爆

这15个Vue指令，让你的项目开发爽到爆

1. V-Hotkey 仓库地址: github.com/Dafrok/v-ho… Demo: 戳这里 https://dafrok.github.io/v-hotkey 安装: npm install --save v-hotkey 这个指令可以给组件绑定一个或多个快捷键。你想要通过按下 Escape 键后隐藏某个组件，按住 Control 和回车键再显示它吗？小菜一碟： <template
阅读更多...
基于人工智能的图像分类系统

基于人工智能的图像分类系统

目录 引言项目背景环境准备 硬件要求软件安装与配置系统设计 系统架构关键技术代码示例 数据预处理模型训练模型预测应用场景结论 1. 引言 图像分类是计算机视觉中的一个重要任务，目标是自动识别图像中的对象类别。通过卷积神经网络（CNN）等深度学习技术，我们可以构建高效的图像分类系统，广泛应用于自动驾驶、医疗影像诊断、监控分析等领域。本文将介绍如何构建一个基于人工智能的图像分类系统，包括环境
阅读更多...
水位雨量在线监测系统概述及应用介绍

水位雨量在线监测系统概述及应用介绍

在当今社会，随着科技的飞速发展，各种智能监测系统已成为保障公共安全、促进资源管理和环境保护的重要工具。其中，水位雨量在线监测系统作为自然灾害预警、水资源管理及水利工程运行的关键技术，其重要性不言而喻。 一、水位雨量在线监测系统的基本原理 水位雨量在线监测系统主要由数据采集单元、数据传输网络、数据处理中心及用户终端四大部分构成，形成了一个完整的闭环系统。 数据采集单元：这是系统的“眼睛”，
阅读更多...
Hadoop企业开发案例调优场景

Hadoop企业开发案例调优场景

需求 （1）需求：从1G数据中，统计每个单词出现次数。服务器3台，每台配置4G内存，4核CPU，4线程。 （2）需求分析： 1G / 128m = 8个MapTask；1个ReduceTask；1个mrAppMaster 平均每个节点运行10个 / 3台 ≈ 3个任务（4    3    3） HDFS参数调优 （1）修改：hadoop-env.sh export HDFS_NAMENOD
阅读更多...
嵌入式QT开发：构建高效智能的嵌入式系统

嵌入式QT开发：构建高效智能的嵌入式系统

摘要： 本文深入探讨了嵌入式 QT 相关的各个方面。从 QT 框架的基础架构和核心概念出发，详细阐述了其在嵌入式环境中的优势与特点。文中分析了嵌入式 QT 的开发环境搭建过程，包括交叉编译工具链的配置等关键步骤。进一步探讨了嵌入式 QT 的界面设计与开发，涵盖了从基本控件的使用到复杂界面布局的构建。同时也深入研究了信号与槽机制在嵌入式系统中的应用，以及嵌入式 QT 与硬件设备的交互，包括输入输出设
阅读更多...
OpenHarmony鸿蒙开发（ Beta5.0）无感配网详解

OpenHarmony鸿蒙开发（ Beta5.0）无感配网详解

1、简介 无感配网是指在设备联网过程中无需输入热点相关账号信息，即可快速实现设备配网，是一种兼顾高效性、可靠性和安全性的配网方式。 2、配网原理 2.1 通信原理 手机和智能设备之间的信息传递，利用特有的NAN协议实现。利用手机和智能设备之间的WiFi 感知订阅、发布能力，实现了数字管家应用和设备之间的发现。在完成设备间的认证和响应后，即可发送相关配网数据。同时还支持与常规Sof
阅读更多...
JAVA智听未来一站式有声阅读平台听书系统小程序源码

JAVA智听未来一站式有声阅读平台听书系统小程序源码

智听未来，一站式有声阅读平台听书系统 🌟&nbsp;开篇：遇见未来，从“智听”开始 在这个快节奏的时代，你是否渴望在忙碌的间隙，找到一片属于自己的宁静角落？是否梦想着能随时随地，沉浸在知识的海洋，或是故事的奇幻世界里？今天，就让我带你一起探索“智听未来”——这一站式有声阅读平台听书系统，它正悄悄改变着我们的阅读方式，让未来触手可及！ 📚&nbsp;第一站：海量资源，应有尽有 走进“智听
阅读更多...
活用c4d官方开发文档查询代码

活用c4d官方开发文档查询代码

当你问AI助手比如豆包，如何用python禁止掉xpresso标签时候，它会提示到 这时候要用到两个东西。https://developers.maxon.net/论坛搜索和开发文档 比如这里我就在官方找到正确的id描述 然后我就把参数标签换过来
阅读更多...
hdu 2602 and poj 3624(01背包)

hdu 2602 and poj 3624(01背包)

01背包的模板题。 hdu2602代码： #include<stdio.h>#include<string.h>const int MaxN = 1001;int max(int a, int b){return a > b ? a : b;}int w[MaxN];int v[MaxN];int dp[MaxN];int main(){int T;int N, V;s
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2