0

0

MongoDB抽奖活动记录怎么存_防重入与并发安全设计

P粉602998670

P粉602998670

发布时间:2026-03-18 10:37:03

|

730人浏览过

|

来源于php中文网

原创

应优先选 upsert:抽奖记录属冷数据,需天然防重,upsert 语义更贴合“存在即忽略”;但必须配合唯一索引(如 {uid, activityId, traceId}),且用 mgo.IsDup() 精准识别重复错误。

mongodb抽奖活动记录怎么存_防重入与并发安全设计

upsert 还是 Insert?别选错场景

抽奖活动记录本质是「写多读少、结构松散、允许延迟」的冷数据,不是用户资料那种强一致性核心数据。所以第一反应不该是“怎么锁住它”,而是“怎么让它天然不重复”。Insert + Find 判断是典型反模式——并发一高,两个请求同时查不到、同时插进去,重复就来了。

  • upsert: true 是更贴近业务语义的选择:你真正要的是“这条中奖记录存在就不管,不存在才落库”,而不是“必须插入一条新文档”
  • 但前提是 filter 字段必须有唯一索引支撑,否则多个 upsert 可能各自创建文档(比如只按 uid 过滤却没建索引)
  • 如果业务要求“绝对不允许覆盖已有记录”(比如中奖时间、IP 不能被后来同 uid 的请求改掉),那 Insert + 唯一索引 + mgo.IsDup() 或对应驱动的重复错误捕获才是正解

唯一索引建在哪?别只盯 uid

红包雨里光靠 uid 去重毫无意义——同一用户可中多次奖。真正需要约束的是“一次抽奖行为”的原子性,比如:{uid, activityId, prizeId, createTime} 组合,或更轻量的 {uid, activityId, traceId}(traceId 由前端/网关生成,保证单次点击唯一)。

  • 索引字段顺序影响查询效率,把高频过滤字段放前面,比如 activityId 通常比 uid 更早确定
  • 别在 createTime 上用精确时间戳做唯一键——毫秒级并发下仍可能冲突;改用带随机后缀的 traceId 更可靠
  • 建索引用 Background: true,避免大集合上锁阻塞线上写入;且务必在服务启动时执行,不是每次插入前调

mgo.IsDup() 捕获失败,还是直接 panic?

Go 用 mgo 驱动时,Insert() 失败不等于数据错了——网络超时、权限不足、连接中断都会返回 err != nil。盲目当成重复处理,会把真实故障掩盖成“已存在”。

医真AI+开放平台
医真AI+开放平台

医真AI+ 医学AI开放平台

下载
  • 必须用 mgo.IsDup(err) 显式判断,这是唯一安全识别唯一索引冲突的方式
  • 其他错误类型该重试就重试(如网络类),该告警就告警(如权限类),不能一概 return nil
  • 如果用的是官方 mongo-go-driver,对应方法是检查 writeexception.WriteError.Labels 是否含 "DuplicateKey"

异步写入下,怎么知道“到底写没写成”?

抽奖系统普遍走「MQ 异步落库」,消费者从 RabbitMQ 拿到消息后写 MongoDB。这时你没法在 HTTP 响应里告诉用户“已中奖并记账成功”,因为写库还没发生。

  • 消息体里必须带完整上下文:traceId、uid、prizeId、客户端时间戳、IP、设备指纹——哪怕写库失败,也能靠这些字段人工对账
  • 不要依赖 MongoDB 写入成功才发“中奖通知”,应该在扣减库存/生成中奖结果那一刻就发通知,写库只是归档;失败了走补偿任务重推
  • 补偿逻辑里,依然要用 upsert 或带唯一索引的 Insert,否则重推两次又变两条记录
MongoDB 并发安全的复杂点不在语法,而在你定义“重复”的那一刻——它取决于业务规则,不是技术默认值。漏掉 traceId、索引建错字段、错误类型不区分,三者任一出问题,防重就形同虚设。

本站声明:本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn

热门AI工具

更多
DeepSeek
DeepSeek

幻方量化公司旗下的开源大模型平台

豆包大模型
豆包大模型

字节跳动自主研发的一系列大型语言模型

WorkBuddy
WorkBuddy

腾讯云推出的AI原生桌面智能体工作台

腾讯元宝
腾讯元宝

腾讯混元平台推出的AI助手

文心一言
文心一言

文心一言是百度开发的AI聊天机器人,通过对话可以生成各种形式的内容。

讯飞写作
讯飞写作

基于讯飞星火大模型的AI写作工具,可以快速生成新闻稿件、品宣文案、工作总结、心得体会等各种文文稿

即梦AI
即梦AI

一站式AI创作平台,免费AI图片和视频生成。

ChatGPT
ChatGPT

最最强大的AI聊天机器人程序,ChatGPT不单是聊天机器人,还能进行撰写邮件、视频脚本、文案、翻译、代码等任务。

相关专题

更多
rabbitmq和kafka有什么区别
rabbitmq和kafka有什么区别

rabbitmq和kafka的区别:1、语言与平台;2、消息传递模型;3、可靠性;4、性能与吞吐量;5、集群与负载均衡;6、消费模型;7、用途与场景;8、社区与生态系统;9、监控与管理;10、其他特性。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

207

2024.02.23

Java 消息队列与异步架构实战
Java 消息队列与异步架构实战

本专题系统讲解 Java 在消息队列与异步系统架构中的核心应用,涵盖消息队列基本原理、Kafka 与 RabbitMQ 的使用场景对比、生产者与消费者模型、消息可靠性与顺序性保障、重复消费与幂等处理,以及在高并发系统中的异步解耦设计。通过实战案例,帮助学习者掌握 使用 Java 构建高吞吐、高可靠异步消息系统的完整思路。

50

2026.01.28

mongodb和mysql的区别
mongodb和mysql的区别

mongodb和mysql的区别:1、数据模型;2、查询语言;3、扩展性和性能;4、可靠性。本专题为大家提供mongodb和mysql的区别的相关的文章、下载、课程内容,供大家免费下载体验。

287

2023.07.18

mongodb启动命令
mongodb启动命令

MongoDB 是一种开源的、基于文档的 NoSQL 数据库管理系统。本专题提供mongodb启动命令的文章,希望可以帮到大家。

267

2023.08.08

MongoDB删除数据的方法
MongoDB删除数据的方法

MongoDB删除数据的方法有删除集合中的文档、删除整个集合、删除数据库和删除指定字段等。本专题为大家提供MongoDB相关的文章、下载、课程内容,供大家免费下载体验。

161

2023.09.19

常用的数据库软件
常用的数据库软件

常用的数据库软件有MySQL、Oracle、SQL Server、PostgreSQL、MongoDB、Redis、Cassandra、Hadoop、Spark和Amazon DynamoDB。更多关于数据库软件的内容详情请看本专题下面的文章。php中文网欢迎大家前来学习。

1010

2023.11.02

mongodb有哪些应用领域
mongodb有哪些应用领域

mongodb 的应用领域涵盖广泛,包括内容管理系统、社交媒体、分析、移动应用、物联网、金融科技、医疗保健和广告技术等领域,因其灵活性、可扩展性和易用性而广受欢迎。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

345

2024.04.02

mongodb和redis哪个读取速度快
mongodb和redis哪个读取速度快

redis 的读取速度比 mongodb 更快。原因包括:1. redis 使用简单的键值存储,而 mongodb 存储 json 格式的数据,需要解析和反序列化。2. redis 使用哈希表快速查找数据,而 mongodb 使用 b-tree 索引。因此,redis 在需要高性能读取操作的应用程序中是一个更好的选择。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

501

2024.04.02

Python WebSocket实时通信与异步服务开发实践
Python WebSocket实时通信与异步服务开发实践

本专题聚焦 Python 在实时通信场景中的开发实践,系统讲解 WebSocket 协议原理、长连接管理、消息推送机制以及异步服务架构设计。内容包括客户端与服务端通信实现、连接稳定性优化、消息队列集成及高并发处理策略。通过完整案例,帮助开发者构建高效稳定的实时通信系统,适用于聊天应用、实时数据推送等场景。

2

2026.03.18

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号