java开发微信抢红包挂_「高并发秒杀」微信抢红包实战案例
推荐阅读:
( i' [9 Q6 ?7 K/ p+ B% ~
8 L$ _" R- y- v s1 p. e7 Y( }* M, l6 T+ R
阿里二面凉经:设计模式+缓存+Spring+虚拟机+MySQL+中间件+并发等难题,全部迎刃而解! N5 i' z. e+ z4 J
阿里巴巴字节跳动那些大厂必问的HTTP该怎么学?我建议你看看这篇文章!
2 ~0 f3 B% _6 S4 {
蚂蚁、字节、PDD社招面经Java岗(分布式+线程安全+MySQL+CAS)! [4 N$ v( r/ l4 N6 h$ T8 L前言, v) _+ J, {0 |$ Z0 V
; f- M& e! e- ]" L9 q V
群里有小伙伴咨询微信红包的架构,对于我来说,显然是不知道的,但是写一个相对高并发的抢红包案例还是完全可以的。7 ]# I& H+ F' s% i5 O0 ?
架构流程
: U5 |3 ~' {, s4 E A+ y8 c H?* t5 @3 l x" I) {
架构设计
# b1 s+ E$ c; D2 n) f8 R. E; L) V2 m/ Z) S/ _: [% y1 K6 ^
4 V/ {. m3 e1 f) _0 E( P
老板发红包,此时缓存初始化红包个数,红包金额(单位分),并异步入库。5 O& E- Z B; d, G6 M5 [$ b. y* c# y
抢红包,判断缓存剩余红包金额,剩余金额大于零则抢到红包,否则手慢了,红包派完了
" A8 S+ a$ y- R$ t
拆红包,根据 redPacketId 获取分布式锁,如果获取到锁,红包个数减一,如果剩余红包个数大于零抢红包成功、否则失败。成功则计算红包金额,缓存总红包金额减去抢到的红包金额,异步入库、异步到账。; J0 \$ g( H8 U3 E: \$ {, R
若获取分布式锁失败,使用 Redis的 decr命令对红包个数加一。3 n5 ^2 T1 P* _% h# X0 I' G& K4 ?2 b- D数据库设计
; x! C- @) [9 }1 |. o5 w) q
* P( c% R" R0 f3 p" o( [6 d9 |( ]9 _+ y& |( C) }' f" D% D' [
红包信息表
; D/ y) A6 M* ?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='红包信息表'" N- c h( `; ~+ T' N) ~
$ J p9 |! B; B& D( L( s, O
抢红包记录表O/ i" r( Z7 uCREATE 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='抢红包记录表'代码案例
% K) ?: \2 k- p0 ~: I' _0 X. D% M9 T1 h! \' `! [/ [+ b
老板发了10个红包一共200人民币,100个人同时抢红包,伪代码分别为拆红包和抢红包相关业务逻辑。模拟抢红包伪代码:9 h9 r |! X# x4 t; `5 u0 k1 ?
/** * 抢红包 拆红包 抢到不一定能拆到 * @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 { /** * 抢红包 判断剩余金额 */ 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(); }业务层拆红包:5 M# |" \# E. i! V1 {
@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==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); }演示4 [& r5 w( d& B8 c$ Q/ h) O0 P9 r# `
+ ^! B" L% M P& l$ P4 r' n在 Application中有接口演示说明,你可以在抢红包 Red Packet Controller接口中输入任何参数进行测试,也可以配合数据库稍加修改即可作为生产环境的抢红包功能模块。& c: j$ n% y. N$ i% X
源码
; d: T' d8 J5 r" ] u2 g; |, ^# u1 X O8 G0 V4 V/ F: O
https://gitee.com/52itstyle/spring-boot-seckill1 b/ t3 a9 l# p5 V( I+ n
; h0 y/ @# ?- |2 q( y: [& a9 P
Java吧 收集整理 java8论坛 www.java8.com
java开发微信抢红包挂_「高并发秒杀」微信抢红包实战案例相关推荐
- 疯狂涨知识!「高并发秒杀」微信抢红包实战案例帮你突破瓶颈
推荐阅读: 阿里二面凉经:设计模式+缓存+Spring+虚拟机+MySQL+中间件+并发等难题,全部迎刃而解 阿里巴巴字节跳动那些大厂必问的HTTP该怎么学?我建议你看看这篇文章! 蚂蚁.字节.PDD ...
- 「高并发秒杀」微信抢红包实战案例
推荐阅读: 阿里二面凉经:设计模式+缓存+Spring+虚拟机+MySQL+中间件+并发等难题,全部迎刃而解 阿里巴巴字节跳动那些大厂必问的HTTP该怎么学?我建议你看看这篇文章! 蚂蚁.字节.PDD ...
- 小白勿进!「高并发秒杀」微信抢红包实战案例
推荐阅读: 阿里二面凉经:设计模式+缓存+Spring+虚拟机+MySQL+中间件+并发等难题,全部迎刃而解 阿里巴巴字节跳动那些大厂必问的HTTP该怎么学?我建议你看看这篇文章! 蚂蚁.字节.PDD ...
- 「高并发秒杀」mysql只修改字段名称
高并发架构 消息队列 搜索引擎 缓存 分库分表 读写分离 设计高并发系统 高并发架构部分内容 缓存: Redis高可用: 高并发系统设计: 分布式系统 分布式业务系统,就是把原来用 Java 开发的一 ...
- 「高并发秒杀」java课程设计报告模板
正文 我在做技术面试官的时候,在问完问题后,照例会问一句:你期望的工资是多少?对此,我只会记录下候选人的回答然后上报,没有同意权,更没有批驳权. 判断候选人能否通过面试,主要看候选人能力和岗位的匹配度 ...
- 「高并发秒杀」mysql数据库引擎区别
一.秒杀系统架构设计都有哪些关键点? 二.设计秒杀系统时应该注意的5个架构原则 架构原则:"4要1不要" 1.1.数据要尽里少 1.2. 请求数要尽里少 1.3.路径要尽里短 1. ...
- 「高并发秒杀」linux安装软件有哪几种方式
那么,如何学习Kafka源码?? 我觉得最高效的方式就是去读最核心的源码,先看一张 Kafka结构图 以及 Kafka 源码全景图 梳理一下关于 Kafka 框架,找到学习的重点. 其次,我要说的就是 ...
- 【在线网课】Java高性能高并发秒杀系统方案优化实战
java教程视频讲座简介: Java高性能高并发秒杀系统方案优化实战 Java秒杀系统方案优化 高性能高并发实战 以"秒杀"这一Java高性能高并发的试金石场景为例,带你通过一系列 ...
- java 画笔跟swing组件_「软帝学院」:2019思维最清晰的java学习路线
第一步 首先要做好学习前的准备工作:java语言一般用于大型的服务器程序开发,所有有必要了解如下内容:Unix开发环境Unix系统原理.Unix开发环境.Unix常用命令.熟练掌握Unix常用命令:熟 ...
最新文章
- linux下安装redmine1.2.1全记录
- QSS为Qt程序添加不一样的样式
- 聊聊WebRTC网关服务器2:如何选择PeerConnection方案?
- oracle clob 次数,解决Oracle clob字段数据过大问题
- QT的QDataStream类的使用
- 关于微信红包的架构思考
- 关于real210开发板linux系统可能无法解析域名的问题解决方法
- psychopy 音频时长代码_PsychoPy入门_03_视频和音频的呈现
- c语言如何实现玫瑰花
- 苹果ios15.4RC版发布:新增口罩面容解锁功能
- unity里如何在点击UI时,避免触发游戏内操作。
- java poi读取word中附件_java poi word读取
- 价值连城 图灵奖得主Yann LeCun 杨立昆的采访 给AI从业者的建议
- 【UML建模案例】小型网上书店系统
- php文章重复度检测,有哪些可以检测文章原创度的工具,避免文章重复度过高
- 建筑工地施工现场人员安全管理软件系统
- 高一计算机算法教案,教科版 高一信息技术 必修1 第四单元 4.2 数值计算 教案...
- 超融合服务器系统,超融合服务器|超融合架构|超融合一体机|业务系统一体机
- java开发工程师面试自我介绍_Java程序员面试如何自我介绍HR这一关
- 基于spring+springmvc+mybatis的个人简易记账系统(包含数据库)