一个基于Spring Boot的高并发秒杀抢购解决方案，用于个人学习。欢迎提供意见和建议

• 服务注册和发现中心：Eureka
• API网关：Zuul
• 缓存：Redis
• 消息队列：Kafka
• 数据库：MySQL

use sec_kill;

DROP TABLE IF EXISTS tb_user; CREATE TABLE tb_user( id int(32) not null AUTO_INCREMENT comment 'ID', user_name varchar (50) not null comment '用户名', phone varchar (20) not null comment '手机号码', create_time datetime not null default now() NOT NULL comment "创建时间", primary key (id) ) ENGINE=InnoDB default charset='utf8';

DROP TABLE IF EXISTS tb_product; CREATE TABLE tb_product ( id int(32) not null AUTO_INCREMENT COMMENT 'ID', product_name varchar(50) not null COMMENT '产品名称', price decimal(16,3) not null COMMENT '价格', stock int(64) not null COMMENT '库存', create_time datetime not null default CURRENT_TIMESTAMP COMMENT '创建时间', version_id int(128) default '0' COMMENT '版本id', primary key (id) ) ENGINE=InnoDB DEFAULT CHARSET='utf8';

DROP TABLE IF EXISTS tb_record; CREATE TABLE tb_record( id int(64) not null AUTO_INCREMENT comment 'ID', user_id int(32) not null comment '用户ID', product_id int(32) not null comment '产品ID', state tinyint(3) not null comment '秒杀状态: 1秒杀成功,0秒杀失败,-1重复秒杀,-2系统异常', create_time datetime not null default now() comment '创建时间', primary key (id), key key_product_id(product_id), key key_user_id_product_id (user_id,product_id) )ENGINE=InnoDB default charset='utf8';

• 缓存查询

  预加载商品库存到Redis缓存，提高查询速率

• 双写一致性

  利用canal对数据库进行binlog监听，更新redis

• 锁机制

  提供3种加锁方案

  • MySQL乐观锁
  • Redis分布式锁
  • ZooKeeper分布式锁

• 异步通信

  在一个事务内：商品库存扣减成功后，利用Kafka发送实现交易记录； 消费端通过Kafka实现异步消费；

• 限流

  利用guava-ratelimit提供的令牌桶算法，在API网关层做限流

• 测试工具

  Jmeter-5.0

  

• 部署

  MySQL: docker单点部署

  Redis: docker单点部署

  Zookeeper: docker单点部署

  Kafka: docker单点部署

  Canal-server: docker单点部署

  eureka: 本地启动

  zuul: 本地启动，令牌发放速率200个/s

  canal-redis: 本地启动

  app: 本地启动

• 测试结果

  开启限流情况下，99%以上请求被拦截在API网关层，平均响应实际在200ms以内。