0
  • 聊天消息
  • 系统消息
  • 评论与回复
登录后你可以
  • 下载海量资料
  • 学习在线课程
  • 观看技术视频
  • 写文章/发帖/加入社区
会员中心
创作中心

完善资料让更多小伙伴认识你,还能领取20积分哦,立即完善>

3天内不再提示

Redis抢红包项目

数据分析与开发 ? 来源:数据分析与开发 ? 作者:数据分析与开发 ? 2020-09-24 15:09 ? 次阅读
加入交流群
微信小助手二维码

扫码添加小助手

加入工程师交流群

业务流程分析

功能拆解


新建红包

在 DB、Redis 分别新增一条记录

抢红包(并发)

「使用技术」

Redis 中数据类型的 String 特性的原子递减(DECR key)和减少指定值(DECRBY key decrement)

「业务」

请求 Redis ,当剩余红包个数大于 0,红包个数原子递减,随机获取红包

计算金额,当最后一个红包时,最后一个红包金额=总金额-总已抢红包金额

更新数据库

「查询红包记录」

查询 DB 即可

数据库设计

红包流水表

CREATE TABLE `red_packet_info` ( `id` int(11) NOT NULL AUTO_INCREMENT, `red_packet_id` bigint(11) NOT NULL DEFAULT 0 COMMENT '红包id,采? timestamp+5位随机数', `total_amount` int(11) NOT NULL DEFAULT 0 COMMENT '红包总?额,单位分', `total_packet` int(11) NOT NULL DEFAULT 0 COMMENT '红包总个数', `remaining_amount` int(11) NOT NULL DEFAULT 0 COMMENT '剩余红包?额,单位 分', `remaining_packet` int(11) NOT NULL DEFAULT 0 COMMENT '剩余红包个数', `uid` int(20) NOT NULL DEFAULT 0 COMMENT '新建红包?户的?户标识', `create_time` timestamp COMMENT '创建时间', `update_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新时间', PRIMARY KEY (`id`) ) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8mb4 COMMENT='红包信息 表,新建?个红包插??条记录';

红包记录表

CREATE TABLE `red_packet_record` ( `id` int(11) NOT NULL AUTO_INCREMENT, `amount` int(11) NOT NULL DEFAULT '0' COMMENT '抢到红包的?额', `nick_name` varchar(32) NOT NULL DEFAULT '0' COMMENT '抢到红包的?户的?户 名', `img_url` varchar(255) NOT NULL DEFAULT '0' COMMENT '抢到红包的?户的头像', `uid` int(20) NOT NULL DEFAULT '0' COMMENT '抢到红包?户的?户标识', `red_packet_id` bigint(11) NOT NULL DEFAULT '0' COMMENT '红包id,采? timestamp+5位随机数', `create_time` timestamp COMMENT '创建时间', `update_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新时间', PRIMARY KEY (`id`) ) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8mb4 COMMENT='抢红包记 录表,抢?个红包插??条记录';

发红包 API

发红包接口开发

新增一条红包记录

往 mysql 里面添加一条红包记录

往 redis 里面添加一条红包数量记录

往redis里面添加一条红包金额记录

?

往db中就单纯存入一条记录,Service层和Mapper层,就简单的一条sql语句,主要是提供思路,下面会附案例源码,不要慌

?

抢红包 API

抢红包功能属于原子减操作

当大小小于 0 时原子减失败

当红包个数为0时,后面进来的用户全部抢红包失败,并不会进入拆红包环节

抢红包功能设计

将红包ID的请求放入请求队列中,如果发现超过红包的个数,直接返回

注意事项

抢到红包不一定能拆成功

抢红包算法拆解

img

通过上图算法得出,靠前面的人,手气最佳几率小,手气最佳,往往在后面

发 100 元,共 10 个红包,那么平均值是 10 元一个,那么发出来的红包金额在 0.01~20 元之间波动

当前面 4 个红包总共被领了 30 元时,剩下 70 元,总共 6 个红包,那么这 6 个红包的金额在 0.01~23.3 元之间波动

抢红包接口开发

「测试」

「发红包」

模拟高并发抢红包(Jmeter压测工具)

因为我发了 10 个红包,金额是 20000,使用压测工具,模拟50个请求,只允许前10个请求能抢到红包,并且金额等于20000。

布隆过滤器

介绍

布隆过滤器是1970年由布隆提出的。它实际上是一个很长的二进制向量和一系列随机映射函数。布隆过滤器可以用于检索一个元素是否在一个集合中。它的优点是空间效率和查询时间都远远超过一般的算法,缺点是有一定的误识别率和删除困难。

优点

相比于其他的数据结构,布隆过滤器在空间和时间方面都有巨大的优势。布隆过滤器存储空间和插入/查询时间都是常数。另外三列函数相互之间没有关系,方便由硬件并行实现。布隆过滤器不需要存储元素本身,在某些对保密要求非常严格的场合有优势。

缺点

但是布隆过滤器的缺点和有点一样明显。误算率是其中之一。随着存入的元素数量增加,误算率随之增加。但是如果元素数量太少,则使用散列表足矣。

布隆过滤器有什么用

黑客流量攻击:故意访问不存在的数据,导致查程序不断访问DB的数据

黑客安全阻截:当黑客访问不存在的缓存时迅速返回避免缓存及DB挂掉

网页爬虫对 URL 的去重,避免爬取相同的URL地址

反垃圾邮件,从数十亿个垃圾邮件列表中判断某邮件是否垃圾邮件(同理,垃圾短信)

缓存击穿,将已存在的缓存放到布隆中,当黑客访问不存在的缓存时迅速返回避免缓存及 DB 挂掉

布隆过滤器实现会员转盘抽奖

需求

一个抽奖程序,只针对会员用户有效

通过google布隆过滤器存储会员数据

程序启动时将数据放入内存中

google自动创建布隆过滤器

用户ID进来之后判断是否是会员

代码实现

引入依赖

com.google.guava guava 29.0-jre

数据库会员表

CREATE TABLE `sys_user` ( `id` int(11) unsigned NOT NULL AUTO_INCREMENT, `user_name` varchar(11) CHARACTER SET utf8mb4 DEFAULT NULL COMMENT '?户名', `image` varchar(11) CHARACTER SET utf8mb4 DEFAULT NULL COMMENT '?户头像', PRIMARY KEY (`id`) ) ENGINE=InnoDB AUTO_INCREMENT=11 DEFAULT CHARSET=utf8;

初始化布隆过滤器

dao 层和 dao 映射文件,就单纯的一个 sql 查询,看核心方法,下面会附源码滴,不要慌好嘛

控制层

测试

缺点

内存级别产部

重启即失效

本地内存无法用在分布式场景

不支持大数据量存储

Redis布隆过滤器

优点

可扩展性 Bloom 过滤器

不存在重启即失效或定时任务维护的成本

缺点

需要网络IO,性能比基于内存的过滤器低

布隆过滤器安装

「下载」

github:https://github.com/RedisBloom/RedisBloom

链接:https://pan.baidu.com/s/16DlKLm8WGFzGkoPpy8y4Aw密码:25w1

「编译」

make

「将 Rebloom 加载到 Redis 中」

先把 Redis 给停掉!!!在 redis.conf 里面添加一行命令->加载模块

loadmodule/usr/soft/RedisBloom-2.2.4/redisbloom.so

「测试布隆过滤器」

SpringBoot 整合 Redis 布隆过滤器

编写两个lua脚本

添加数据到指定名称的布隆过滤器

从指定名称的布隆过滤器获取key是否存在的脚本

localbloomName=KEYS[1] localvalue=KEYS[2] --bloomFilter localresult_1=redis.call('BF.ADD',bloomName,value) returnresult_1

localbloomName=KEYS[1] localvalue=KEYS[2] --bloomFilter localresult_1=redis.call('BF.EXISTS',bloomName,value) returnresult_1

在 RedisService.java 中添加 2 个方法

验证

秒杀

秒杀业务流程图

数据落地存储方案

通过分布式redis减库存

DB存最终订单信息数据

API性能调优

性能瓶颈在高并发秒杀

技术难题在于超卖问题

实现步骤

提前将秒杀数据缓存到 redis

setskuId_start_10_1554045087--秒杀标识 setskuId_access_112000--允许抢购数 setskuId_count_10--抢购计数 setskuId_booked_10--真实秒杀数

秒杀开始前,skuId_start为0,代表活动未开始

当skuId_start改为1时,活动开始,开始秒杀叭

当接受下单数达到sku_count*1.2后,继续拦截所有请求,商品剩余数量为0(为啥接受抢购数为1万2呢,看业务流程图,涉及到“校验订单信息”,一般设置的值要比总数多一点,多多少自己定)

利用 Redis 缓存加速增库存数

"skuId_booked":10000//从0开始累加,秒杀的个数只能加到1万

将用户订单数据写入 MQ(异步方式)。

另外一台服务器监听 mq,将订单信息写入到 DB。

好了,以上就是完整的开发步骤,下面我们开始编写代码

代码实战

网关浏览拦截层

1、先判断秒杀是否已经开始

2、利用 Redis 缓存 incr 拦截流量

用 incr 方法原子加

通过原子加帕努单当前 skuId_access 是否达到最大值

订单信息校验层

1、校验当前用户是否已经买过这个商品

需要存储用户的uid

存数据库效率太低

存Redis value方式数据太大

存布隆过滤器性能高且数据量小(推荐)

2、校验通过直接返回抢购成功

开发lua脚本实现库存扣除

1、库存扣除成功,获取当前最新库存

2、如果库存大于0,即马上进行库存扣除,并且访问抢购成功给用户

3、考虑原子性问题

保证原子性的方式,采用 lua 脚本

采用lua脚本方式保证原子性带来缺点,性能有所下降

不保证原子性缺点,放入请求量可能大于预期

当前扣除库存场景必须保证原子性,否则会导致超卖

4、返回抢购结果

抢购成功

库存没了,抢购失败

控制层

Service 层

布隆过滤器

初始化redis缓存

setskuId_start_10_1554045087--秒杀标识 setskuId_access_112000--允许抢购数 setskuId_count_10--抢购计数 setskuId_booked_10--真实秒杀数

秒杀验证

jmeter 配置

压测秒杀验证原子性

项目下载

链接:https://pan.baidu.com/s/1hZUPRAljkqO05fYluqJBhQ密码:1iwr

尾声

演示的时候,我使用的 Redis 单机的,吞吐量不是很大,感兴趣的,可以自己搭建个 Redis 主从复制+哨兵+集群,然后再测试。

最近比较忙,没时间完善微信抢红包秒杀的原子性。下面那个完整案例抢库存的,亲自使用 Jmeter 压测几次,是原子性的,可以拿来借鉴,感兴趣的同学,可以借鉴下面抢库存的代码,把微信抢红包的功能在完善下,我就不修改啦。

原文标题:Redis 秒杀实战

文章出处:【微信公众号:数据分析与开发】欢迎添加关注!文章转载请注明出处。

声明:本文内容及配图由入驻作者撰写或者入驻合作网站授权转载。文章观点仅代表作者本人,不代表电子发烧友网立场。文章及其配图仅供工程师学习之用,如有内容侵权或者其他违规问题,请联系本站处理。 举报投诉
  • C语言
    +关注

    关注

    180

    文章

    7633

    浏览量

    142506
  • Redis
    +关注

    关注

    0

    文章

    387

    浏览量

    11548

原文标题:Redis 秒杀实战

文章出处:【微信号:DBDevs,微信公众号:数据分析与开发】欢迎添加关注!文章转载请注明出处。

收藏 人收藏
加入交流群
微信小助手二维码

扫码添加小助手

加入工程师交流群

    评论

    相关推荐
    热点推荐

    Redis集群部署配置详解

    Redis集群是一种分布式Redis解决方案,通过数据分片和主从复制实现高可用性和横向扩展。集群将整个数据集分割成16384个哈希槽(hash slots),每个节点负责一部分槽位。
    的头像 发表于 07-17 11:04 ?286次阅读

    Redis集群部署与性能优化实战

    Redis作为高性能的内存数据库,在现代互联网架构中扮演着关键角色。作为运维工程师,掌握Redis的部署、配置和优化技能至关重要。本文将从实战角度出发,详细介绍Redis集群的搭建、性能优化以及监控运维的核心技术。
    的头像 发表于 07-08 17:56 ?308次阅读

    【经验分享】在Omni3576上编译Redis-8.0.2源码,并安装及性能测试

    本文首先介绍Redis是什么,然后介绍如何在Omni3576上编译Redis-8.0.2源码,以及从源码编译、安装Redis,最后介绍如何在Omni3576上运行Redis性能测试,并
    的头像 发表于 06-05 08:05 ?461次阅读
    【经验分享】在Omni3576上编译<b class='flag-5'>Redis</b>-8.0.2源码,并安装及性能测试

    【幸狐Omni3576边缘计算套件试用体验】Redis最新8.0.2版本源码安装及性能测试

    本文首先介绍Redis是什么,然后介绍如何在Omni3576上编译Redis-8.0.2源码,以及从源码编译、安装Redis,最后介绍如何在Omni3576上运行Redis性能测试,并
    发表于 06-03 01:28

    Redis 再次开源!

    “ ?Redis 现已采用 AGPLv3 开源许可证。? ” Redis CEO 的 Blog 以下是 Redis CEO Rowan Trollope 的 Blog: 像 AWS 和 GCP 这样
    的头像 发表于 05-06 18:26 ?453次阅读

    redis三种集群方案详解

    Redis中提供的集群方案总共有三种(一般一个redis节点不超过10G内存)。
    的头像 发表于 03-31 10:46 ?866次阅读
    <b class='flag-5'>redis</b>三种集群方案详解

    Redis实战笔记

    在目前的技术选型中,Redis 俨然已经成为了系统高性能缓存方案的事实标准,因此现在?Redis 也成为了后端开发的基本技能树之一。 ? 基于上述情况,今天给大家分享一份?杰哥?亲笔撰写的内部
    的头像 发表于 02-09 09:12 ?449次阅读
    <b class='flag-5'>Redis</b>实战笔记

    华为云 Flexus X 加速 Redis 案例实践与详解

    Redis 加速镜像,更是为开发者提供了极大的便利。本文将详细介绍如何利用华为云 Flexus X 实例自带的 Redis 镜像,快速部署并配置 Redis,以及通过实际案例展示其便捷性和高效性。 一、华为云 Flexus
    的头像 发表于 01-23 17:52 ?386次阅读
    华为云 Flexus X 加速 <b class='flag-5'>Redis</b> 案例实践与详解

    Redis Cluster之故障转移

    1. Redis Cluster 简介 Redis Cluster 是 Redis 官方提供的 Redis 集群功能。 为什么要实现 Redis
    的头像 发表于 01-20 09:21 ?962次阅读
    <b class='flag-5'>Redis</b> Cluster之故障转移

    云服务器 Flexus X 实例,Docker 集成搭建 Redis 集群

    Redis 集群是一种分布式的 Redis 解决方案,能够在多个节点之间分片存储数据,实现水平扩展和高可用性。与传统的主从架构不同,Redis 集群支持数据自动分片、主节点故障自动切换,并可以在多台
    的头像 发表于 01-13 13:37 ?429次阅读
    云服务器 Flexus X 实例,Docker 集成搭建 <b class='flag-5'>Redis</b> 集群

    华为云Flexus X实例,Redis性能加速评测及对比

    随着云计算技术的飞速发展,Redis 作为一种高性能的内存数据库,在各种应用场景中发挥着越来越重要的作用。为了满足不同用户对 Redis 性能的高要求,华为云推出了 Flexus X 实例,并提供了
    的头像 发表于 12-29 15:47 ?592次阅读
    华为云Flexus X实例,<b class='flag-5'>Redis</b>性能加速评测及对比

    华为云 Flexus X 轻松实现 Redis 一主多从高效部署

    前言 ????????华为云 Flexus?X 是一款专为高性能计算设计的云服务器实例,其搭载的 X-Turbo 加速技术和智能应用调优算法,能够大幅提升 Redis 的处理能力和响应速度。此外
    的头像 发表于 12-27 13:45 ?529次阅读
    华为云 Flexus X 轻松实现 <b class='flag-5'>Redis</b> 一主多从高效部署

    Redis使用重要的两个机制:Reids持久化和主从复制

    今天这篇文章,我们一起了解 Redis 使用中非常重要的两个机制:Reids 持久化和主从复制。 我们都知道Redis是一个内存数据库,在学习主从同步之前,我们首先要想到 Redis 是如何做数据
    的头像 发表于 12-18 10:33 ?463次阅读
    <b class='flag-5'>Redis</b>使用重要的两个机制:Reids持久化和主从复制

    Redis缓存与Memcached的比较

    Redis和Memcached都是广泛使用的内存数据存储系统,它们主要用于提高应用程序的性能,通过减少对数据库的直接访问来加速数据检索。以下是对Redis和Memcached的比较,涵盖了它们的一些
    的头像 发表于 12-18 09:33 ?691次阅读

    恒讯科技分析:云数据库rds和redis区别是什么如何选择?

    云数据库RDS(Relational Database Service)和Redis是两种不同类型的数据库服务,它们有各自的特点和适用场景: 1、数据模型:RDS是一种关系型数据库服务,通常用于存储
    的头像 发表于 08-19 15:31 ?909次阅读