goodsKill

Introduction: 🐯基于 SpringCloud 2021.x +Dubbo 3.x 构建的模拟秒杀微服务项目，集成了 Elasticsearch🔍、Gateway、Mybatis-Plus、Sharding-JDBC 等常用开源组件

More: Author ReportBugs

Tags:

= 前言

image:https://img.shields.io/badge/license-MIT-blue.svg[License,link=LICENSE] image:https://github.com/techa03/goodsKill/actions/workflows/maven.yml/badge.svg?branch=master[Java CI with Maven,link=https://github.com/techa03/goodsKill/actions/workflows/maven.yml] image:https://codecov.io/gh/techa03/goodsKill/branch/master/graph/badge.svg[codecov,link=https://codecov.io/gh/techa03/goodsKill] image:https://github.com/techa03/goodsKill/actions/workflows/codeql.yml/badge.svg?branch=main[CodeQL,link=https://github.com/techa03/goodsKill/actions/workflows/codeql.yml]

项目命名为 goodsKill 一方面有商品秒杀的意思(好像有点 chinglish 的味道)，另外也可理解为 good skill，本项目就是希望搭建一套完整的项目框架，把一些好的技术和开发技巧整合进来（偏向于后端技术），方便学习和查阅。

本项目为模拟秒杀项目，提供统一秒杀模拟请求接口，技术上整体采用 SpringMVC + Mybatis 持久层框架，采用 Dubbo3.x{empty}footnote:[由于 SpringCloudAlibaba 官方暂未支持 Dubbo 3.x，本项目采用 dubbo-spring-boot-starter 集成]+Feign 完成服务间接口调用，服务注册发现以及配置中心使用 Nacos，支持数据库分库分表、分布式事务，使用状态机完成数据状态间的转换（基于 Spring Statemachine 实现）。

集成了 Spring AI 服务，可以通过 AI 机器人完成模拟秒杀动作。

== 💎 分支介绍

main分支基于最新 Spring Cloud 2023.x + Spring Boot 3.x + JDK21 体系构建，目前仅保留核心的模拟秒杀 API 接口，如需使用 Spring Boot 2.7.x + JDK11 版本可以切换到 tag https://github.com/techa03/goodsKill/tree/v2.7.4[v2.7.4]（支持登录注册以及简单的后台管理功能）。

本项目功能目前比较简陋且有很多不完善的地方，真实的秒杀场景远比本项目中的实现方式复杂，本项目省略了真实场景中的部分技术实现细节，目前仅作学习参考之用，如果觉得本项目对你有帮助的请多多 star 支持一下👍~~~~。

附：码云项目链接 https://gitee.com/techa/goodsKill,clone 速度慢的用码云仓库拉吧，不定期同步到码云~

== ✨ 技术选型

|=== |使用的工具或框架 |名称 |官网

== 📝 项目模块介绍

goodsKill |--goodskill-admin ||SpringBoot Admin 监控服务端，支持 Spring Cloud 微服务发现 |--goodskill-ai ||AI 机器人聊天服务 |--goodskill-gateway ||微服务 API 网关，统一服务鉴权，支持动态路由加载 |--goodskill-order-provider ||订单服务提供者 |--goodskill-seckill-provider ||秒杀服务提供者 |--goodskill-spring-boot-starter ||项目配置自动装配 |--goodskill-common ||公共服务(目前包含 minio 上传下载功能) |--goodskill-web ||提供秒杀模拟接口访问 |--goodskill-job ||elastic-job 定时任务 |--goodskill-seata ||集成 nacos+dubbo+shardingjdbc+seata 的分布式事务解决方案示例 |--goodskill-auth ||auth 登录以及授权模块 | |--auth-service ||基于 Sa-Token 框架的用户登录授权服务 |--oauth2-auth-server ||oauth2.0 登录授权服务端，自定义的登录授权服务

|--oauth2-resource-server               ||oauth2.0 资源服务端，自定义的登录授权服务

== 🔥🔥 秒杀方案

目前实现了几种秒杀方案，通过SeckillMockController提供测试接口

聚合网关 Openapi 文档地址: http://localhost/doc.html#/home（需要开启网关服务）

Spring Boot Admin 应用监控地址: http://www.goodskill.com:19031, 登录用户名密码：user/123456

场景一：Sychronized 同步锁实现
场景二：Redisson 分布式锁实现
场景三：ActiveMQ 实现(已废弃)
场景四：Kafka 消息队列实现
场景五：数据库原子性更新
场景六：实时等待秒杀处理结果(已废弃)
场景七：ZooKeeper 分布式锁
场景八：使用 Redis 进行秒杀商品减库存操作，秒杀结束后异步发送 MQ，使用 MongoDB 完成数据落地
场景九：Spring Cloud Stream 实现
场景十：Sentinel 限流+数据库原子性更新（需搭配 sentinel 控制台配置资源名limit的流控规则）

.可在 web 控台查看秒杀结果，打印信息类似：

[source,text]

2021-04-14 21:58:59.857 INFO [goodskill-web,df43cc8f59291c48,df43cc8f59291c48] 15808 --- [ main] o.s.w.controller.SeckillMockController : 秒杀场景二(redis 分布式锁实现)开始时间：Wed Apr 14 21:58:59 CST 2021,秒杀 id：1000 2021-04-14 21:59:00.094 INFO [goodskill-web,144aa7910cca9520,2821cb8d62c5a908] 15808 --- [AClOSzbugzYng-1] o.s.w.s.c.SeckillMockResponseListener : 秒杀活动结束，秒杀场景二(redis 分布式锁实现)时间：Wed Apr 14 21:59:00 CST 2021,秒杀 id：1000 2021-04-14 21:59:00.101 INFO [goodskill-web,144aa7910cca9520,2821cb8d62c5a908] 15808 --- [AClOSzbugzYng-1] o.s.w.s.c.SeckillMockResponseListener : 最终成功交易笔数统计中。。。 2021-04-14 21:59:01.616 INFO [goodskill-web,144aa7910cca9520,2821cb8d62c5a908] 15808 --- [AClOSzbugzYng-1] o.s.w.s.c.SeckillMockResponseListener : 最终成功交易笔数统计中。。。 2021-04-14 21:59:03.129 INFO [goodskill-web,144aa7910cca9520,2821cb8d62c5a908] 15808 --- [AClOSzbugzYng-1] o.s.w.s.c.SeckillMockResponseListener : 最终成功交易笔数：10

2021-04-14 21:59:03.130 INFO [goodskill-web,144aa7910cca9520,2821cb8d62c5a908] 15808 --- [AClOSzbugzYng-1] o.s.w.s.c.SeckillMockResponseListener : 历史任务耗时统计：StopWatch '': running time = 36159894800 ns

ns % Task name

4492195700 012% 秒杀场景四(kafka 消息队列实现) 3164155900 009% 秒杀场景八(秒杀商品存放 redis 减库存，异步发送秒杀成功 MQ，mongoDb 数据落地) 6219218300 017% 秒杀场景十(Sentinel 限流+数据库原子性更新) 9189080600 025% 秒杀场景七(zookeeper 分布式锁) 3135926500 009% 秒杀场景五(数据库原子性更新 update set num = num -1) 3342791800 009% 秒杀场景九(基于 springcloud stream rabbitmq) 3343433700 009% 秒杀场景一(sychronized 同步锁实现)

3273092300 009% 秒杀场景二(redis 分布式锁实现)

====

== 🧰 开发环境版本说明

JDK: OpenJDK21
Sharding-JDBC: 5.5.0
SpringCloud: 2023.x.x
SpringBoot: 3.3.x
SpringCloudAlibaba: 2023.x.x
Apache Dubbo: 3.3.x
使用的 Docker 镜像 + |=== |镜像 |版本 |端口 |用户名密码

|Nacos |2.3.2-slim |8848 |nacos:nacos（控制台） |Redis |latest |6379 |密码:123456 |Kafka |3.1.1 |9092 |无 |KafkaManager |latest |9001:9000 |无 |Mongo |6.0.7 |27017 |无 |MySQL |8.0.29 |3306 |root:Password123 |Zookeeper |3.6.2 |2181 |无 |Elasticsearch |7.17.3 |9200 9300 |无 |Kibana |7.17.3 |5601 |无 |RabbitMQ |latest |5672 15672 |无 |MinIO |latest |9000 |root:password |Seata |2.0.0 |7091 8091|seata:seata（控制台） |===

== 🎯 快速开始

项目根目录goodsKill中执行 +

mvn clean install 或

跳过单元测试

mvn clean install -DskipTests

默认端口启动 nacos、redis、mysql、rabbitmq、kafka、zookeeper、elasticsearch、seataServer，或者使用 docker-compose{empty}footnote:[需要安装 docker-desktop https://www.docker.com/products/docker-desktop/]命令： + [source,bash]

docker-compose -f goodskill-simple.yml up -d

进入goodskill-web/src/main/sql目录，找到seckill.sql文件，在本地 mysql 数据库中建立seckill仓库并执行完成数据初始化操作 +

:warning-caption: ⚠️️

[WARNING] docker-compose 启动 MySQL 镜像时会自动执行初始化脚本，如已执行过上一步本步骤可跳过

配置 host [source,text] +

127.0.0.1 kafka 127.0.0.1 nacos 127.0.0.1 redis 127.0.0.1 mysql 127.0.0.1 zookeeper 127.0.0.1 mongo 127.0.0.1 elasticsearch 127.0.0.1 rabbitmq 127.0.0.1 logstash

如果网关服务部署在远程机器，此处改为相应的远程机器 ip

127.0.0.1 www.goodskill.com

在 Nacos 配置中心中添加 DataId 为goodskill-common-connection.yml（中间件公共配置）、goodskill-common.yml（服务公共配置）的公共配置，Group 为DEFAULT_GROUP，具体内容可参考项目根目录中的goodskill-common-connection.yml、goodskill-common.yml文件
main 方法运行OrderApplication类(订单服务)
main 方法运行SeckillApplication类(秒杀管理服务提供者)
main 方法运行SampleWebApplication类(模拟秒杀 web 服务)
发送一个秒杀模拟请求：秒杀活动 id 1000，商品数量 10，执行 20 次购买操作，使用 sychronized 同步锁执行，例如： + 可直接使用以下命令发送模拟秒杀请求，每个秒杀活动 seckillId 对应唯一的一个商品 id，每次执行接口时会有一个库存初始化动作，接口执行完成后可重复调用

.使用 sychronized 同步锁执行

[source,bash] curl -X POST "http://www.goodskill.com:8080/sychronized" \ -H "accept: /" -H "Content-Type: application/json" -d \

"{ \"requestCount\": 20, \"seckillCount\": 10, \"seckillId\": 1000}"

.使用 Redisson 分布式锁执行

[source,bash] curl -X POST "http://www.goodskill.com:8080/redisson" \ -H "accept: /" -H "Content-Type: application/json" -d \

"{ \"requestCount\": 20, \"seckillCount\": 10, \"seckillId\": 1000}"

.使用 Redisson 分布式锁执行，支持动态配置后台线程池核心线程数以及最大线程数

[source,bash] curl --location --request POST 'http://www.goodskill.com:8080/limit' \ --header 'User-Agent: apifox/1.0.0 (https://www.apifox.cn)' \ --header 'Content-Type: application/json' \ --data-raw '{ "maxPoolSize": 10, "seckillId": 1000, "corePoolSize": 2, "seckillCount": 100, "requestCount": 120

}'

+ 请求默认异步执行，可在控制台查看执行日志，如果最终成功交易笔数等于商品数量 10 则表示没有出现超卖或者少卖问题

== 🤖️ 使用 AI 机器人聊天服务基于 Spring AI Alibaba 构建的简易秒杀机器人服务，可以通过机器人服务完成服务调用，目前仅支持开启秒杀活动，以及输出活动耗时情况

进入goodskill-ai模块，替换配置spring.ai.dashscope.api-key，可通过阿里云百炼平台获取
main 方法运行AiBotApplication类，访问聊天页面 http://127.0.0.1:18077
以下是一个对话示例 [source,text] +

我: 帮我执行秒杀

AI: 当然可以帮助您执行秒杀活动啦！为了顺利进行，请告诉我以下几个信息：1.秒杀活动的 ID 是多少？2. 这次秒杀的商品数量是多少？3.您打算这次请求的次数是多少？有了这些信息，我就能帮您开始了！😊

我: 秒杀活动 id 1001，请求次数 20，商品数量 10 个

AI: 秒杀活动已成功开启！我们现在等待 10 秒钟，然后我会为您获取任务的耗时统计信息。秒杀活动已成功启动，并在 10 秒后获得了任务耗时统计信息：总耗时：6.673773375 秒具体耗时分布如下：- 秒杀活动 id:1001，秒杀场景五(数据库原子性更新 update setnum = num -1)耗时 3.528280125 秒，占比 53%-秒杀活动 id:1001，秒杀场景五(数据库原子性更新 updateset num = num-1)耗时 3.14549325 秒，占比 47%希望这些信息对您有帮助！如果还有其他问题或需要进一步的帮助，请随时告诉我哦！😊

== 🕹️️ 启动其他可选项目步骤在快速开始部分基础上增加以下步骤即可启动一个完整项目

进入goodskill-gateway模块，通过GatewayBootApplication类 main 方法启动服务网关，统一通过网关访问各个服务

http://www.goodskill.com/api/order/** 对应访问goodskill-order服务
http://www.goodskill.com/api/seata/** 对应访问goodskill-seata服务
http://www.goodskill.com/api/seckill/** 对应访问goodskill-seckill服务
http://www.goodskill.com/api/auth/** 对应访问goodskill-auth服务
http://www.goodskill.com/api/web/** 对应访问goodskill-web服务

已集成Sentinel限流组件，支持nacos配置中心方式推送限流规则，使用时需启动Sentinel控制台，并以18088端口启动，docker 环境暂不支持。
Seata 分布式事务测试方法见 https://github.com/techa03/goodsKill/tree/master/goodskill-seata/README.md[Seata 分布式事务测试示例运行说明]
main 方法运行GoodskillAdminApplication类(微服务健康状态指标监控)

== ❓常见问题 [qanda] docker es 镜像启动失败::

出现此问题一般为 linux 环境，运行以下命令即可 sysctl -w vm.max_map_count=262144 ，或者修改/etc/sysctl.conf 文件，追加以下配置： +

[source,text]

grep vm.max_map_count /etc/sysctl.conf

vm.max_map_count=262144

如何使用本项目自定义的 OAuth2.0 授权服务器进行登录授权？::

待完善。。

项目集成的各个框架之间目前的兼容性如何？::

本项目目前依赖的各个主流框架的版本比较新，尚未经过完整测试{empty}footnote:[附 https://start.aliyun.com/bootstrap.html[SpringCloudAlibaba]兼容版本说明]。

服务启动控制台报 ERROR 日志 no available service found in cluster 'default', please make sure registry config correct and keep your seata server running 如何解决？::

启动seata-server服务即可（docker-compose.yml 文件中已提供），可参照 Seata 官网添加 nacos 相关配置。如未使用分布式事务，可忽略该错误，不影响服务正常运行

docker-compose 无法拉取镜像::

hub.docker 被墙，国内可使用阿里云镜像加速器，具体操作见 https://cr.console.aliyun.com/cn-hangzhou/instances/mirrors[阿里云镜像加速器]

使用 JDK17 以上启动项目失败::

启动时添加以下 jvm 参数，例如： +

[source,text]

--add-opens java.base/java.lang=ALL-UNNAMED --add-opens java.base/java.util=ALL-UNNAMED --add-opens java.base/java.util.concurrent=ALL-UNNAMED --add-opens java.base/java.math=ALL-UNNAMED