数据库并发抢红包_微信高并发抢红包秒杀实战案例
前言
群里有小伙伴咨询微信红包的架构,对于我来说,显然是不知道的,但是写一个相对高并发的抢红包案例还是完全可以的。
架构设计
业务流程老板发红包,此时缓存初始化红包个数,红包金额(单位分),并异步入库。
抢红包,判断缓存剩余红包金额,剩余金额大于零则抢到红包,否则手慢了,红包派完了
拆红包,根据 redPacketId 获取分布式锁,如果获取到锁,红包个数减一,如果剩余红包个数大于零抢红包成功、否则失败。成功则计算红包金额,缓存总红包金额减去抢到的红包金额,异步入库、异步到账。
数据库设计红包信息表
CREATE TABLE `red_racket` (
`id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT '自增主键',
`red_packet_id` bigint(20) NOT NULL COMMENT '红包唯一ID',
`total_amount` int(11) NOT NULL COMMENT '红包金额单位分',
`total_packet` int(11) NOT NULL COMMENT '红包个数',
`type` int(11) NOT NULL COMMENT '红包类型',
`create_time` datetime DEFAULT NULL COMMENT '创建时间',
`version` int(11) NOT NULL COMMENT '版本号',
PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8 CHECKSUM=1 DELAY_KEY_WRITE=1 ROW_FORMAT=DYNAMIC COMMENT='红包信息表'抢红包记录表
CREATE TABLE `red_packet_record` (
`id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT '自增主键',
`amount` int(11) NOT NULL COMMENT '抢到红包的金额',
`red_packet_id` bigint(20) NOT NULL COMMENT '红包ID',
`uid` int(11) NOT NULL COMMENT '抢到红包用户的用户标识',
`create_time` datetime DEFAULT NULL COMMENT '创建时间',
PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=10 DEFAULT CHARSET=utf8 CHECKSUM=1 DELAY_KEY_WRITE=1 ROW_FORMAT=DYNAMIC COMMENT='抢红包记录表'
代码案例
老板发了10个红包一共200人民币,100个人同时抢红包,伪代码分别为拆红包和抢红包相关业务逻辑。
模拟抢红包伪代码:
/**
* 抢红包 拆红包 抢到不一定能拆到
* @param redPacketId
* @return
*/
@ApiOperation(value="抢红包二",nickname="爪哇笔记")
@PostMapping("/startTwo")
public Result startTwo(long redPacketId){
int skillNum = 100;
final CountDownLatch latch = new CountDownLatch(skillNum);//N个抢红包
/**
* 初始化红包数据,抢红包拦截
*/
redisUtil.cacheValue(redPacketId+"-num",10);
/**
* 初始化红包金额,单位为分
*/
redisUtil.cacheValue(redPacketId+"-money",20000);
/**
* 模拟100个用户抢10个红包
*/
for(int i=1;i<=skillNum;i++){
int userId = i;
Runnable task = () -> {
/**
* 抢红包 判断剩余金额
*/
Integer money = (Integer) redisUtil.getValue(redPacketId+"-money");
if(money>0){
/**
* 虽然能抢到 但是不一定能拆到
* 类似于微信的 点击红包显示抢的按钮
*/
Result result = redPacketService.startTwoSeckil(redPacketId,userId);
if(result.get("code").toString().equals("500")){
LOGGER.info("用户{}手慢了,红包派完了",userId);
}else{
Double amount = DoubleUtil.divide(Double.parseDouble(result.get("msg").toString()), (double) 100);
LOGGER.info("用户{}抢红包成功,金额:{}", userId,amount);
}
}else{
/**
* 直接显示手慢了,红包派完了
*/
//LOGGER.info("用户{}手慢了,红包派完了",userId);
}
latch.countDown();
};
executor.execute(task);
}
try {
latch.await();
Integer restMoney = Integer.parseInt(redisUtil.getValue(redPacketId+"-money").toString());
LOGGER.info("剩余金额:{}",restMoney);
} catch (InterruptedException e) {
e.printStackTrace();
}
return Result.ok();
}
业务层拆红包:
@Override
@Transactional
public Result startTwoSeckil(long redPacketId, int userId) {
Integer money = 0;
boolean res=false;
try {
/**
* 获取锁 保证红包数量和计算红包金额的原子性操作
*/
res = RedissLockUtil.tryLock(redPacketId+"", TimeUnit.SECONDS, 3, 10);
if(res){
long restPeople = redisUtil.decr(redPacketId+"-num",1);
if(restPeople>=0){
/**
* 如果是最后一人
*/
if(restPeople==0){
money = Integer.parseInt(redisUtil.getValue(redPacketId+"-money").toString());
}else{
Integer restMoney = Integer.parseInt(redisUtil.getValue(redPacketId+"-money").toString());
Random random = new Random();
//随机范围:[1,剩余人均金额的两倍]
money = random.nextInt((int) (restMoney / (restPeople+1) * 2 - 1)) + 1;
}
redisUtil.decr(redPacketId+"-money",money);
/**
* 异步入库
*/
RedPacketRecord record = new RedPacketRecord();
record.setMoney(money);
record.setRedPacketId(redPacketId);
record.setUid(userId);
record.setCreateTime(new Timestamp(System.currentTimeMillis()));
saveRecord(record);
/**
* 异步入账
*/
}else{
return Result.error("手慢了,红包派完了");
}
}else{
/**
* 获取锁失败相当于抢红包失败
*/
return Result.error("手慢了,红包派完了");
}
} catch (Exception e) {
e.printStackTrace();
}finally {
if(res){//释放锁
RedissLockUtil.unlock(redPacketId+"");
}
}
return Result.ok(money);
}
演示
在 Application中有接口演示说明,你可以在抢红包 Red Packet Controller接口中输入任何参数进行测试,也可以配合数据库稍加修改即可作为生产环境的抢红包功能模块。
小结
以上方案并没有实现持久化和分布式,生产环境可根据实际业务需求选择使用。
源码
数据库并发抢红包_微信高并发抢红包秒杀实战案例相关推荐
- 《Java并发编程入门与高并发面试》or 《Java并发编程与高并发解决方案》笔记
<Java并发编程入门与高并发面试>or <Java并发编程与高并发解决方案>笔记 参考文章: (1)<Java并发编程入门与高并发面试>or <Java并发 ...
- java开发微信抢红包挂_「高并发秒杀」微信抢红包实战案例
推荐阅读: ( i' [9 Q6 ?7 K/ p+ B% ~ 8 L$ _" R- y- v s1 p. e7 Y( }* M, l6 T+ R 阿里二面凉经:设计模式+缓存+Spring ...
- mongodb线程池_常用高并发网络线程模型设计及MongoDB线程模型优化实践
服务端通常需要支持高并发业务访问,如何设计优秀的服务端网络IO工作线程/进程模型对业务的高并发访问需求起着至关重要的核心作用. 本文总结了了不同场景下的多种网络IO线程/进程模型,并给出了各种模型的优 ...
- oracle单表高并发,见过这么高并发( logons current)的数据库么?
见过这么高并发( logons current)的数据库么? SQL> select * from v$version; BANNER ----------------------------- ...
- div固定大小文字溢出自动缩小_【高并发】高并发环境下如何防止Tomcat内存溢出?看完我懂了!!
写在前面 随着系统并发量越来越高,Tomcat所占用的内存就会越来越大,如果对Tomcat的内存管理不当,则可能会引发Tomcat内存溢出的问题,那么,如何防止Tomcat内存溢出呢?我们今天就来一起 ...
- oom 如何避免 高并发_【高并发】高并发环境下如何防止Tomcat内存溢出?看完我懂了!!...
[高并发]高并发环境下如何防止Tomcat内存溢出?看完我懂了!! 发布时间:2020-04-19 00:47, 浏览次数:126 , 标签: Tomcat 写在前面 随着系统并发量越来越高,Tomc ...
- 数据库大数据量、高并发、高可用解决方案!
数据库性能瓶颈 对于一些互联网项目来说,企业为节省成本,一般会考虑将所有的数据都存储在一个数据库中,这个时候我们只需要考虑数据库优化.SQL优化.数据缓存.限流,消息队列.服务器性能等问题. 阿里巴巴 ...
- mysql 高并发扣除库存_【并发】mysql处理高并发,防止库存超卖
先来就库存超卖的问题作描述:一般电子商务网站都会遇到如团购.秒杀.特价之类的活动,而这样的活动有一个共同的特点就是访问量激增.上千甚至上万人抢购 一个商品.然而,作为活动商品,库存肯定是很有限的,如何 ...
- 电商项目的并发量一般是多少_【高并发】高并发秒杀系统架构解密,不是所有的秒杀都是秒杀!...
写在前面 很多小伙伴反馈说,高并发专题学了那么久,但是,在真正做项目时,仍然不知道如何下手处理高并发业务场景!甚至很多小伙伴仍然停留在只是简单的提供接口(CRUD)阶段,不知道学习的并发知识如何运用到 ...
最新文章
- ‘聪明的搜索算法’ A*算法
- grouping Function
- 出产报表数据库呈现了运动事项的回滚段毁坏(二)
- IO流——字节流的使用
- mysql三大范式 答案_数据库逻辑设计之三大范式通俗理解,一看就懂,书上说的太晦涩...
- System学习笔记003---Windows把内存变成快速虚拟硬盘
- 安装用户脚本的福音:Tampermonkey(油猴)
- [转]VC 键盘虚拟码
- 面试相关——计算机网络基础
- 几行代码实现鼠标自动点击电脑屏幕指定位置,防止电脑或远程桌面休眠
- java 如何执行dig 命令_如何在cmd下直接执行Dig命令
- 网络爬虫相关软件以及论文检索与推荐网站调研
- 杭州电子科技大学 计算机专硕复试分数线,2020杭州电子科技大学考研复试分数线已公布...
- 决战行测5000题-数量关系精华版
- 解决el-table 树形结构expand 操作后 stripe 显示失效问题
- 微信公众号 和 微信小程序 用户数据互通 通过微信开放平台的UnionID机制
- 数据结构——二叉树的实现
- 虚拟机安装---模板机准备9(测试安装好的模板机)
- 熊谱翔:变化的RT-Thread 不变的初心
- eclipse luna java 版本_eclipse luna使用jdk1.8初始化
热门文章
- github电脑壁纸_GitHub - githubtaotao/bing-wallpaper: Bing每日壁纸,自动获取Bing的精美图片设置为壁纸,并且支持随机切换历史壁纸,查看壁纸故事...
- 1到100的偶数之和是多少_求1到100之间所有偶数之和
- ANC主动降噪,FFT方案与FxLMS方案比较
- The first interview for xiecheng
- python 根据坐标点计算方位角函数
- liunx 中文乱码 和 html转图片中文乱码问题处理方式以及linux中文字体包
- iOS App 唤醒另一个App
- 合宙Air724 Luat 开发接入ThingsCloud 物联网云平台
- Code For Better 谷歌开发者之声——使用谷歌浏览器 Chrome 更好地调试
- 【API调用】人脸检测+人脸属性(旷视 / 百度)