疯狂涨知识！「高并发秒杀」微信抢红包实战案例帮你突破瓶颈

前言

群里有小伙伴咨询微信红包的架构，对于我来说，显然是不知道的，但是写一个相对高并发的抢红包案例还是完全可以的。

架构流程

架构设计

老板发红包，此时缓存初始化红包个数，红包金额(单位分)，并异步入库。
抢红包，判断缓存剩余红包金额，剩余金额大于零则抢到红包，否则手慢了，红包派完了
拆红包，根据 redPacketId 获取分布式锁，如果获取到锁，红包个数减一，如果剩余红包个数大于零抢红包成功、否则失败。成功则计算红包金额，缓存总红包金额减去抢到的红包金额，异步入库、异步到账。
若获取分布式锁失败，使用 Redis的 decr命令对红包个数加一。

数据库设计

红包信息表

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@Transactionalpublic 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==1){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{/*** 获取锁失败相当于抢红包失败，红包个数加一*/redisUtil.incr(redPacketId+"-num",1);}} catch (Exception e) {e.printStackTrace();}finally {if(res){//释放锁RedissLockUtil.unlock(redPacketId+"");}}return Result.ok(money);}

演示

在 Application中有接口演示说明，你可以在抢红包 Red Packet Controller接口中输入任何参数进行测试，也可以配合数据库稍加修改即可作为生产环境的抢红包功能模块。

源码

最后

如果觉得本文对你有帮助的话，不妨给我点个赞，关注一下吧！

资料免费领取方式：点击这里

esult.ok(money);

## **演示**在 `Application`中有接口演示说明，你可以在抢红包 `Red Packet Controller`接口中输入任何参数进行测试，也可以配合数据库稍加修改即可作为生产环境的抢红包功能模块。## **源码**### 最后**如果觉得本文对你有帮助的话，不妨给我点个赞，关注一下吧！****[资料免费领取方式：点击这里](https://docs.qq.com/doc/DSmxTbFJ1cmN1R2dB)**[外链图片转存中...(img-qm6jDdfJ-1623502396052)]![](https://img-blog.csdnimg.cn/img_convert/6e6463247e74e06477dd5eb773261f4b.png)

疯狂涨知识！「高并发秒杀」微信抢红包实战案例帮你突破瓶颈相关推荐

java开发微信抢红包挂_「高并发秒杀」微信抢红包实战案例
推荐阅读: ( i' [9 Q6 ?7 K/ p+ B% ~ 8 L$ _" R- y- v s1 p. e7 Y( }* M, l6 T+ R 阿里二面凉经:设计模式+缓存+Spring ...
「高并发秒杀」微信抢红包实战案例
推荐阅读: 阿里二面凉经:设计模式+缓存+Spring+虚拟机+MySQL+中间件+并发等难题,全部迎刃而解阿里巴巴字节跳动那些大厂必问的HTTP该怎么学?我建议你看看这篇文章! 蚂蚁.字节.PDD ...
小白勿进！「高并发秒杀」微信抢红包实战案例
推荐阅读: 阿里二面凉经:设计模式+缓存+Spring+虚拟机+MySQL+中间件+并发等难题,全部迎刃而解阿里巴巴字节跳动那些大厂必问的HTTP该怎么学?我建议你看看这篇文章! 蚂蚁.字节.PDD ...
「高并发秒杀」mysql只修改字段名称
高并发架构消息队列搜索引擎缓存分库分表读写分离设计高并发系统高并发架构部分内容缓存: Redis高可用: 高并发系统设计: 分布式系统分布式业务系统,就是把原来用 Java 开发的一 ...
「高并发秒杀」mysql数据库引擎区别
一.秒杀系统架构设计都有哪些关键点? 二.设计秒杀系统时应该注意的5个架构原则架构原则:"4要1不要" 1.1.数据要尽里少 1.2. 请求数要尽里少 1.3.路径要尽里短 1. ...
「高并发秒杀」java课程设计报告模板
正文我在做技术面试官的时候,在问完问题后,照例会问一句:你期望的工资是多少?对此,我只会记录下候选人的回答然后上报,没有同意权,更没有批驳权. 判断候选人能否通过面试,主要看候选人能力和岗位的匹配度 ...
「高并发秒杀」linux安装软件有哪几种方式
那么,如何学习Kafka源码?? 我觉得最高效的方式就是去读最核心的源码,先看一张 Kafka结构图以及 Kafka 源码全景图梳理一下关于 Kafka 框架,找到学习的重点. 其次,我要说的就是 ...
【在线网课】Java高性能高并发秒杀系统方案优化实战
java教程视频讲座简介: Java高性能高并发秒杀系统方案优化实战 Java秒杀系统方案优化高性能高并发实战以"秒杀"这一Java高性能高并发的试金石场景为例,带你通过一系列 ...
阿里、百度、美团都在用的‘’高并发秒杀系统‘’；抢红包、秒杀活动、微博热搜、12306抢票等高并发场景
"秒杀活动"."抢红包"."微博热搜"."12306抢票"."共享单车拉新"等都是高并发的典型业务场 ...

疯狂涨知识！「高并发秒杀」微信抢红包实战案例帮你突破瓶颈

推荐阅读：

前言

架构流程

架构设计

数据库设计

代码案例

演示

源码

最后

疯狂涨知识！「高并发秒杀」微信抢红包实战案例帮你突破瓶颈相关推荐

最新文章

热门文章