# SecKill-System

**Repository Path**: senrian/SecKill-System

## Basic Information

- **Project Name**: SecKill-System
- **Description**: 一个秒杀抢购项目：分别提供MySQL乐观锁，Redis分布锁和ZooKeeper分布锁共3种方案
- **Primary Language**: Unknown
- **License**: Not specified
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 0
- **Created**: 2020-02-29
- **Last Updated**: 2020-12-19

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

# SecKill-System

一个基于Spring Boot的高并发秒杀抢购解决方案，用于个人学习。欢迎提供意见和建议
 
 
### 项目结构
   - 服务注册和发现中心：**Eureka**
   - API网关：**Zuul**
   - 缓存：**Redis**
   - 消息队列：**Kafka**
   - 数据库：**MySQL**

 
# SQL

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
  
  ![test_config](https://github.com/JiangJiangjungle/SecKill-System/blob/master/data_figure/test_config.png)

- #### 部署

  MySQL: docker单点部署
  
  Redis: docker单点部署
  
  Zookeeper: docker单点部署
  
  Kafka: docker单点部署
  
  Canal-server: docker单点部署
  
  eureka: 本地启动
  
  zuul: 本地启动，令牌发放速率200个/s
  
  canal-redis: 本地启动
  
  app: 本地启动
  
- #### 测试结果

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