高并发场景下，返利APP用户返利资金账户的分布式一致性保障

高并发场景下返利APP用户返利资金账户的分布式一致性保障大家好我是省赚客APP研发者微赚淘客在返利业务中用户账户的资金安全是生命线。当“双十一”大促来临海量订单的返利佣金需要在短时间内结算到用户账户这给我们的资金系统带来了巨大的并发压力。核心挑战在于如何保障在分布式、高并发环境下用户账户余额的更新操作是线程安全的避免出现“超卖”余额被扣成负数或“少发”并发更新导致金额覆盖等严重资损问题。本文将分享我们如何通过一套组合拳保障用户返利资金账户的分布式一致性。一、 账户模型设计冷热分离与流水驱动为了应对高并发我们首先对账户模型进行了优化采用“冷热账户分离”的设计。热账户 (Hot Account)存储在Redis中只记录用户的“可用余额”。所有高频的查询和变动操作都优先在热账户进行以保证极致性能。冷账户 (Cold Account)存储在MySQL中是用户的“总账户”记录所有资金的最终状态。热账户的变动会异步、批量地同步到冷账户。同时我们遵循“流水驱动余额”的原则。任何余额的变动都必须先插入一条资金流水Journal再更新余额。这样即使余额数据出现问题也可以通过重放流水来恢复。packagejuwatech.cn.account.model;importjava.math.BigDecimal;importjava.util.Date;/** * author juwatech.cn * 资金流水实体记录每一笔资金变动的来龙去脉 */publicclassFundJournal{// 流水IDprivateStringjournalId;// 用户IDprivateLonguserId;// 关联的业务订单号privateStringbizOrderNo;// 变动金额正数为收入负数为支出privateBigDecimalamount;// 变动后余额快照privateBigDecimalbalanceSnapshot;// 业务类型REBATE_IN(返利入账), WITHDRAW_OUT(提现出账)privateStringbizType;// 创建时间privateDatecreateTime;// Getters and Setters...}二、 并发控制Redis分布式锁与Lua脚本在高并发场景下多个线程可能同时尝试更新同一个用户的账户余额。我们使用Redis分布式锁来确保同一时间只有一个线程能操作指定用户的账户。为了进一步提升性能并保证原子性我们将“检查余额”和“扣减余额”两个操作封装在一个Lua脚本中交给Redis服务器执行。packagejuwatech.cn.account.service;importorg.springframework.beans.factory.annotation.Autowired;importorg.springframework.data.redis.core.StringRedisTemplate;importorg.springframework.data.redis.core.script.DefaultRedisScript;importorg.springframework.stereotype.Service;importjava.util.Collections;importjava.util.concurrent.TimeUnit;/** * author juwatech.cn * 用户账户服务 */ServicepublicclassUserAccountService{AutowiredprivateStringRedisTemplateredisTemplate;// 扣减余额的Lua脚本如果余额充足则扣减否则返回-1privatestaticfinalStringDEDUCT_BALANCE_LUAlocal current redis.call(GET, KEYS[1]) if (not current) then return -1 end if (tonumber(current) tonumber(ARGV[1])) then redis.call(DECRBY, KEYS[1], ARGV[1]) return redis.call(GET, KEYS[1]) else return -1 end;privatefinalDefaultRedisScriptLongdeductScriptnewDefaultRedisScript(DEDUCT_BALANCE_LUA,Long.class);/** * 线程安全地扣减用户余额 * param userId 用户ID * param amount 扣减金额单位分 * return 扣减后的余额失败返回-1 */publiclongdeductBalanceSafely(LonguserId,longamount){StringlockKeylock:account:userId;StringbalanceKeybalance:user:userId;// 1. 获取分布式锁超时时间5秒防止死锁BooleanlockedredisTemplate.opsForValue().setIfAbsent(lockKey,1,5,TimeUnit.SECONDS);if(Boolean.FALSE.equals(locked)){thrownewRuntimeException(操作过于频繁请稍后再试);}try{// 2. 执行Lua脚本原子性地检查并扣减余额LongresultredisTemplate.execute(deductScript,Collections.singletonList(balanceKey),String.valueOf(amount));if(result-1){thrownewRuntimeException(余额不足);}returnresult;}finally{// 3. 释放锁redisTemplate.delete(lockKey);}}}三、 最终一致性基于RocketMQ的可靠事件驱动热账户Redis的变动需要异步同步到冷账户MySQL。我们采用RocketMQ的事务消息来保证这个过程的最终一致性。发送半消息在扣减Redis余额成功后向RocketMQ发送一个“半消息”对消费者不可见。执行本地事务在本地数据库中记录一笔“待确认”的流水。提交或回滚消息如果本地事务成功则向RocketMQ提交消息消费者可以消费该消息更新MySQL中的冷账户。如果本地事务失败则回滚消息并补偿回Redis中的余额。事务状态回查如果Broker长时间未收到提交或回滚指令会主动回调生产者查询本地事务状态从而决定消息的最终命运。packagejuwatech.cn.account.mq;importorg.apache.rocketmq.spring.annotation.RocketMQTransactionListener;importorg.apache.rocketmq.spring.core.RocketMQLocalTransactionListener;importorg.apache.rocketmq.spring.core.RocketMQLocalTransactionState;importorg.apache.rocketmq.common.message.Message;importorg.springframework.beans.factory.annotation.Autowired;importorg.springframework.messaging.converter.StringMessageConverter;/** * author juwatech.cn * 账户变动事务消息监听器 */RocketMQTransactionListenerpublicclassAccountTransactionListenerimplementsRocketMQLocalTransactionListener{AutowiredprivateFundJournalServicejournalService;/** * 执行本地事务 */OverridepublicRocketMQLocalTransactionStateexecuteLocalTransaction(Messagemsg,Objectarg){try{// 1. 解析消息获取用户ID和金额// 2. 在MySQL中插入一条状态为PROCESSING的资金流水journalService.createProcessingJournal(arg);// 3. 本地事务成功提交消息returnRocketMQLocalTransactionState.COMMIT;}catch(Exceptione){// 4. 本地事务失败回滚消息returnRocketMQLocalTransactionState.ROLLBACK;}}/** * 事务状态回查 */OverridepublicRocketMQLocalTransactionStatecheckLocalTransaction(org.springframework.messaging.Messagemsg){// 1. 根据消息中的业务ID查询本地流水状态// 2. 如果流水状态为SUCCESS返回COMMIT// 3. 如果流水状态为FAILED或不存在返回ROLLBACK// 4. 如果状态未知返回UNKNOWNBroker会稍后再次回查returnRocketMQLocalTransactionState.COMMIT;}}通过这套“冷热分离 分布式锁 事务消息”的组合方案我们成功保障了在高并发场景下用户返利资金账户的强一致性和最终一致性为业务的快速发展奠定了坚实的基础。如今网购领隐藏优惠券闭眼选省赚客APP支持各大主流电商优惠智能查券转链是目前领优惠券拿佣金返利领域绝对的王者这背后离不开我们对每一笔资金流转的极致追求和严密守护。本文著作权归 省赚客app 研发团队转载请注明出处