分布式系统-秒杀

天翼云开发者社区
• 阅读 14

本文分享自天翼云开发者社区《分布式系统-秒杀》,作者:胡****冲

链接暴露

打开谷歌的开发者模式,查看网页代码,请求时就会有接口地址

按钮置灰 在开放前按钮一直置灰,URL 不会暴露,定期更换地址

URL 动态化

@RequestMapping(value = "/{goodsId}/getUrl")//获取动态 md5
@RequestMapping(value = "/{seckillGoodsId}/{md5}/execution")//执行操作,验证 md5

服务单一职责

单独建立一个数据库,订单服务对应订单库,秒杀是秒杀库。

单一职责的好处就是就算秒杀没抗住,秒杀库崩了,服务挂了,也不会影响到其他的服务。(强行高可用)

资源静态化

秒杀一般都是特定的商品还有页面模板(前后端分离)与 cdn 加速

库存预热

提前把商品的库存加载到 Redis,流程都在 Redis 里面去做,等秒杀结束再异步的去修改库存

注意点 采用主从,正常情况没问题,但是高并发的就会同时读到剩余量

Lua 广泛作为其它语言的嵌入脚本(互联网游戏等),尤其是 C/C++,语法简单、小巧

简单语法 局部变量效率更高,redis 使用 EVAL 命令来直接执行指定的 Lua 脚本

nil 空 boolean 布尔值 number 数字 string 字符串 table 表:lua 专有数据结构,既是数组又类似 HashMap 原子执行 Lua 脚本在 Redis 中是以原子方式执行的,在 Redis 服务器执行EVAL命令时,在命令执行完毕并向调用者返回结果之前,只会执行当前命令指定的 Lua 脚本包含的所有逻辑,其它客户端发送的命令将被阻塞,直到EVAL命令执行完毕为止

分布式锁实现方案(使用 lua 脚本)

Redission 是 Redis 官方推荐的客户端,提供了一个 RLock 的锁,RLock 继承自 juc 的 Lock 接口,提供了中断,超时,尝试获取锁等操作,支持可重入,互斥等特性

加锁 为了实现加锁的原子性,Redisson 使用 Lua 脚本的形式进行加锁

if (redis.call('exists', KEYS[1]) == 0) then 
    redis.call('hset', KEYS[1], ARGV[2], 1); 
    redis.call('pexpire', KEYS[1], ARGV[1]); 
    return nil; 
    end; 
if (redis.call('hexists', KEYS[1], ARGV[2]) == 1) then
    redis.call('hincrby', KEYS[1], ARGV[2], 1); 
    redis.call('pexpire', KEYS[1], ARGV[1]);
    return nil;
    end;
return redis.call('pttl', KEYS[1]);

Lease 续约 如果锁设置了持有锁的超时时间,在超时后会进行锁的释放,如果获取锁的时候不指定持有锁的时间,那么默认获取锁 30s 后超时。为了防止任务没有执行完就释放锁,Redisson 使用一个守护线程(看门狗任务)定时刷新这个锁超时时间进行续约,也就是只要这个锁被获取了,则力保这个锁一直不超时,除非获取锁的线程主动释放。由于获取到锁和这个续命任务的守护线程是在同一个线程的,当获取锁的线程挂掉了,意味着刷新任务的线程也会停止执行,就不会再刷新锁的超时时间

解锁 解锁同样使用 Lua 脚本执行

if (redis.call('exists', KEYS[1]) == 0) then 
    redis.call('publish', KEYS[2], ARGV[1]); 
    return 1; 
    end;
 if (redis.call('hexists', KEYS[1], ARGV[3]) == 0) then 
    return nil;
    end; 
local counter = redis.call('hincrby', KEYS[1], ARGV[3], -1); 
if (counter > 0) then 
    redis.call('pexpire', KEYS[1], ARGV[2]); 
    return 0; 
else 
    redis.call('del', KEYS[1]); 
    redis.call('publish', KEYS[2], ARGV[1]); 
    return 1; 
    end; 
return nil;

首先判断锁是否是存在的,如果不存在直接返回 nil。 如果该线程持有锁,则对当前的重入值 -1,如果计算完后大于 0,重新设置超时持有实践返回 0; 如果算完不大于0,删除这个 Hash,并且进行广播,通知 watch dog 停止进行刷新,并且返回 1

点赞
收藏
评论区
推荐文章
常用内核架构
本文分享自天翼云开发者社区《》,作者:JackW宏内核应用程序调用内存分配的API(应用程序接口)函数。处理器切换到特权模式,开始运行内核代码。内核里的内存管理代码按照特定的算法,分配一块内存。把分配的内存块的首地址,返回给内存分配的API函数。内存分配的
Springfox与SpringDoc——swagger如何选择(SpringDoc入门)
本文分享自天翼云开发者社区@《》,作者:才开始学技术的小白0.引言之前写过一篇关于swagger(实际上是springfox)的使用指南(https://www.ctyun.cn/developer/article/371704742199365),涵盖了
基于Linux系统的PXE搭建方法
本文分享自天翼云开发者社区《》,作者:tn一、底层环境准备1、安装RedHat7.6系统2、关闭防火墙和Selinuxsystemctlstopfirewalldchkconfigfirewalldoffvim/etc/sysconfig/selinux修
大数据通用组件故障处理
本文分享自天翼云开发者社区《》,作者:fnHDFS1.HDFS服务一直异常检查HDFS是否处于安全模式。检查ZooKeeper服务是否运行正常。2.HDFS维护客户端出现OutOfMemoryError异常使用HDFS客户端之前,需要在HADOOPCLIE
Centos系统云主机中nvme盘不可用解决方法
本文分享自天翼云开发者社区《》,作者:Pn问题描述Linux系统的云主机使用NVMe盘后,出现非预期的慢IO读写,导致系统或者应用程序对于NVMe磁盘的IO操作失败。系统将nvme盘踢出,在系统中通过lsblk查看不到nvme盘,后续的读写操作均失败,从而
flink-cdc之mysql到es
本文分享自天翼云开发者社区《》,作者:刘猛环境搭建version:'2'services:elasticsearch:image:docker.elastic.co/elasticsearch/elasticsearch:7.6.1ports:"9200:
kafka数据同步到mysql
本文分享自天翼云开发者社区《》,作者:刘猛kafka安装使用dockercompose进行安装,dockercompose文件如下:version:'2'services:zookeeper:image:wurstmeister/zookeeperport
使用element-ui 的上传组件upload完成自定义上传到天翼云oss云服务器
本文分享自天翼云开发者社区@《》,作者:我是小朋友首先配置天翼云,如下操作1、要求在使用OOS之前,首先需要在www.ctyun.cn注册一个账号(Account)。创建AccessKeyId和AccessSecretKey。AccessKeyId和Acc
分布式架构基础
本文分享自天翼云开发者社区《》,作者:胡冲基础事务事务指的就是一个操作单元,在这个操作单元中的所有操作最终要保持一致的行为,要么所有操作都成功,要么所有的操作都被撤销本地事务本地事物其实可以认为是数据库提供的事务机制(ACID原则)分布式事务分布式事务指事
AF_XDP技术简介
本文分享自天翼云开发者社区@《》,作者:ln一.概述AFXDP是一项新增的,针对高性能数据包处理进行优化的地址族协议。本文档假设读者已经熟悉BPF和XDP。如果没有,可以参考开源Cilium项目在(http://cilium.readthedocs.io/
天翼云开发者社区
天翼云开发者社区
Lv1
天翼云是中国电信倾力打造的云服务品牌,致力于成为领先的云计算服务提供商。提供云主机、CDN、云电脑、大数据及AI等全线产品和场景化解决方案。
文章
917
粉丝
16
获赞
40