使用 sponge + dtm 轻松实现秒杀抢购服务(HTTP),彻底解决库存与订单数据不一致的难题

秒杀场景的挑战

秒杀是电商中常见的抢购商品场景,其技术特点是瞬间请求量巨大,对服务的性能和一致性要求极高。即使服务出现崩溃,也必须确保库存扣减和订单生成保持一致,避免出现超卖或超买的现象。通过使用 dtm(分布式事务管理器),可以轻松解决库存与订单数据不一致的问题。


构建秒杀服务

秒杀服务(http)代码由 sponge 自动生成(选择 ⓷基于 protobuf 创建 web 服务),开发者只需在生成的模板代码文件 (例如 internal/handler/flashSale.go) 中填写秒杀相关的业务逻辑。

下图是生成代码的界面:

在这里插入图片描述

解压代码,切换到项目目录(如 flashSale 目录),执行以下命令:

# 生成代码
make proto# 打开 internal/handler/flashSale.go 文件,按照生成的示例代码添加业务逻辑代码。# 编译并启动服务
make run

更详细的 sponge 创建 web 服务的开发文档请参考:sponge Web 开发文档。

这是添加业务逻辑后的flashSale服务代码。


快速开始

  1. 启动 Redis 服务

  2. 启动 dtm 服务

    • 下载 dtm 可执行文件,修改 dtm 默认配置以使用 Redis 作为存储,并启动 dtm 服务:
      dtm -c conf.yml
      
  3. 配置项目

    • 克隆项目代码flashSale到本地,打开配置文件 configs/flashSale.yml,修改 Redis 和 dtm 的配置项,将默认的 IP 地址(如 192.168.3.37 和 192.168.3.90)替换为实际环境中的 IP 地址(如果所有服务在本地运行,填写127.0.0.1即可)。
  4. 编译并启动服务

    • 可以直接使用以下命令编译并运行服务:
      cd cmd/flashSale
      go run main.go
      
    • 或者,如果已安装 sponge,直接运行以下命令启动服务:
      make run
      
  5. 测试秒杀 API

    • 在浏览器中访问 http://localhost:8080/apis/swagger/index.html,通过 Swagger UI 测试秒杀抢购 API。

    在这里插入图片描述

    API 测试示例:

    1. 设置库存 API

      • 请求示例参数:
        {"productID": 1,"stock": 3
        }
        
    2. 秒杀请求 API

      • 请求示例参数:
        {"productID": 1,"amount": 100,"userID": 1
        }
        
      • 如果库存不足,则返回 409 状态码,表示秒杀失败。
  6. 性能压测api

    在进行性能压测时,为避免终端日志输出影响服务性能,建议将服务以后台模式运行。已安装 sponge 的情况下,可使用以下命令在后台启动服务:

    make run-nohup
    

    使用ab、wrk等压测工具进行压测api。


总结

通过结合 sponge 和 dtm,可以快速搭建一个高性能、高可靠的秒杀服务,彻底解决库存与订单数据不一致的问题。该方案不仅简化了开发流程,还能显著提升服务的并发处理能力和稳定性,是构建电商秒杀系统的理想选择。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.rhkb.cn/news/432706.html

如若内容造成侵权/违法违规/事实不符,请联系长河编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

【重要提示】由于找不到msvcr110.dll 无法继续执行的解决途径全面解析

在使用Windows操作系统时,您可能会遇到这样的问题:某些应用程序在启动时提示“由于找不到 msvcr110.dll,无法继续执行代码。重新安装程序可能会解决此问题。” 这种错误通常会导致应用程序无法正常运行,影响用户体验。本文将全面介…

MySQL 预处理语句:强大的数据库工具

《MySQL 预处理语句:强大的数据库工具》 在 MySQL 数据库的使用中,预处理语句是一个非常有用的功能。它可以提高数据库的性能、安全性和可维护性。那么,什么是预处理语句呢?它又有哪些优点呢?让我们一起来了解一下。 …

docker - 镜像操作(拉取、查看、删除)

文章目录 1、docker search --help(用于显示 Docker 搜索命令的帮助信息)2、docker pull(拉取镜像)3、docker images (查看镜像)3.1、docker images --help(用于显示 Docker 镜像管理相关命令的帮助信息)3.…

【数据结构】排序算法---桶排序

文章目录 1. 定义2. 算法步骤3. 演示3.1 动态演示13.2 动态演示23.3 图片演示13.4 图片演示2 4. 性质5. 算法分析6. 代码实现C语言PythonJavaCGo 结语 1. 定义 桶排序(英文:Bucket sort)是计数排序的升级版,适用于待排序数据值域…

Elasticsearch黑窗口启动乱码问题解决方案

问题描述 elasticsearch启动后有乱码现象 解决方案: 提示:这里填写该问题的具体解决方案: 到 \config 文件下找到 jvm.options 文件 打开后 在文件末尾空白处 添加 -Dfile.encodingGBK 保存后重启即可。

1. Linux系统(CentOS7.9)安装

toc 一、Linux概述介绍 1、Linux系统介绍 Linux, 一类操作系统的统称 部署在服务器上,部署项目、应用 服务器: 硬件设备, 柜式服务器,(华为、浪潮、联想) 提供服务的机器 2、Linux的优势 开源, open source , 开放源代码稳定性最大化发挥硬件资源 …

微服务注册中⼼1

1. 微服务的注册中⼼ 注册中⼼可以说是微服务架构中的”通讯录“ ,它记录了服务和服务地址的映射关系。在分布式架构中, 服务会注册到这⾥,当服务需要调⽤其它服务时,就这⾥找到服务的地址,进⾏调⽤。 1.1 注册中⼼的…

【Redis入门到精通七】详解Redis持久化机制(AOF,RDB)

目录 Redis持久化机制 1.RDB持久化 (1)手动触发RDB持久化 (2)自动触发RDB持久化 (3)Redis文件相关处理 (4)RDB持久化的优缺点 2.AOF持久化 (1)AOF工作…

【隐私计算篇】利用多方安全计算MPC实现VGG16人脸识别隐私推理

1. 背景介绍 本文主要介绍一种利用多方安全计算MPC技术,实现VGG16的人脸识别模型,侧重于模型推理阶段,目前已经公开专利,因此以下内容的分享都是基于公开材料。该分享涉及到最小化多方安全计算(MPC)以及明密文混合计算的思想&…

签署《AI安全国际对话威尼斯共识》 智源持续推动人工智能安全发展

近日,由AI安全国际论坛(Safe AI Forum)和博古睿研究院(Berggruen Institute) 共同举办的第三届国际AI安全对话(International Dialogues on AI Safety)在威尼斯举办。图灵奖得主Yoshua Bengio、姚期智教授&…

UBUNTU20.04安装CH384串口卡驱动

继续上文:统信UOS安装CH384串口卡驱动-CSDN博客 统信UOS系统成功安装CH384串口驱动后,继续在ubuntu20.04下安装驱动,发现一直报错,原因是内核驱动不一致。 解决办法: 1. 下载最新的驱动。CH35XCH384驱动源文件资源-C…

Java语言程序设计基础篇_编程练习题**18.30 (找出单词)

题目:**18.30 (找出单词) 编写一个程序,递归地找出某个目录下的所有文件中某个单词出现的次数。从命令行如下传递参数: java Exercise18_30 dirName word 习题思路 (读取路径方法)和18.28题差不多,把找…

Structure-Aware Transformer for Graph Representation Learning

Structure-Aware Transformer for Graph Representation Learning(ICML22) 摘要 Transformer 架构最近在图表示学习中受到越来越多的关注,因为它通过避免严格的结构归纳偏差而仅通过位置编码对图结构进行编码,自然地克服了图神经…

分享课程:VUE数据可视化教程

在当今这个数据驱动的世界中,数据可视化已经成为了一种至关重要的工具,它帮助我们理解复杂的数据集,发现模式、趋势和异常。数据可视化不仅仅是将数字转换成图表,它是一种将数据转化为洞察力的艺术。 1.什么是数据可视化&#xf…

C语言指针系列1——初识指针

祛魅:其实指针这块儿并不难,有人说难只是因为基础到进阶没有处理好,大家要好好跟着一步一步学习,今天我们先来认识一下指针 指针定义:指针就是内存地址,指针变量是用来存放内存地址的变量,在同一…

Java.动态代理

1.创建一个接口 package Mydynamicproxy1;public interface Star {public abstract String sing(String str);public abstract void dance(String str); }2.创建一个BigStar类,要实现Star这个接口 package Mydynamicproxy1;public class BigStar implements Star{…

webpack4 target:“electron-renderer“ 打包加速配置

背景 昨天写得一篇Electron-vue asar 局部打包优化处理方案——绕开每次npm run build 超级慢的打包问题-CSDN博客文章浏览阅读754次,点赞19次,收藏11次。因为组员对于 Electron 打包过程存在比较迷糊的状态,且自己也没主动探索 Electron-vu…

tcp、udp通信调试工具Socket Tool

tcp、udp通信调试工具Socket Tool ]

线程池的执行流程和配置参数总结

一、线程池的执行流程总结 提交线程任务;如果线程池中存在空闲线程,则分配一个空闲线程给任务,执行线程任务;线程池中不存在空闲线程,则线程池会判断当前线程数是否超过核心线程数(corePoolSize&#xff09…

LeaferJS 动画、状态、过渡、游戏框架

LeaferJS 现阶段依然专注于绘图、交互和图形编辑场景。我们引入游戏场景,只是希望让 LeaferJS 被更多有需要的人看到,以充分发挥它的价值 LeaferJS 为你带来了全新的游戏、动画、状态和过渡功能,助你实现那些年少时的游戏梦想。我们引入了丰富…