首页/新闻资讯/详情

单应用下RabbitMQ如何保证线程安全，及多应用下抢数据问题

发布时间：2026/9/21 19:53:01

单应用下RabbitMQ如何保证线程安全，及多应用下抢数据问题 消费RabbitMQ时的注意事项，如何禁止大量的消息涌到Consumerï¼Œä¿è¯çº¿ç¨‹å®‰å ¨ï¼šæŒ‰ç §å®˜ç½‘æä¾›çš„è®¢é˜ åž‹å†™æ³•ï¼ˆ Retrieving Messages By Subscription (push API) ） 我发现，RabbitMQæœåŠ¡å™¨ä¼šåœ¨çŸ­æ—¶é—´å† å‘é€å¤§é‡çš„æ¶ˆæ¯ç»™Consumerï¼Œç„¶åŽï¼Œå¦‚æžœä½ æ²¡æœ‰æ¥å¾—åŠAck的话，那么服务端会积压大量的UnAcked消息，而Consumerå¦‚æžœæ¥ä¸æ€¥å¤„ç†ä¹Ÿä¼šå¤„äºŽå‡æ­»ï¼ˆä¹Ÿå¯èƒ½å¼•èµ·ç¨‹åºå´©æºƒï¼‰ã€‚ä» æœ‰ä¸¤ä¸ªChannel，结果积压了大量的UnAcked消息。这明显是与我们的目的不一致，我们不能保证Consumer一 定会及时快速的处理消息。所以这种方式带来的后果就是Consmer崩溃后，UnAcked消息又ReQueue，这肯定会消耗MQ的宝贵资源。我试图在官网上找到一种方法，让每条消息明确的Ack后再接受下一条。但是没有。好在在 gitbooks.io/rabbitmq-quick/ 这儿找到了，通过设置Channel的QOS即可var channel Connect.CreateModel();channel.BasicQos(0,1,false); //RabbitMQ客户端接受消息最大数量设置后的结果：在开启4个Consumerçš„æƒ å†µä¸‹ï¼Œæ¯æ¡æ¶ˆæ¯å¤„ç†è¦è€—æ—¶2秒。然后问题解决了。Unacked的消息只有4个。让每条消息明确的AckåŽå†æŽ¥å—ä¸‹ä¸€æ¡ï¼Œé€šè¿‡è¿™ç§æ–¹å¼ä¸ä» å¯ä»¥è§£å†³ç§¯åŽ‹å¤§é‡æ¶ˆæ¯çš„é—®é¢˜ï¼Œè¿˜å¯ä»¥é˜²æ­¢å¤šæ¡æ¶ˆæ¯åŒæ—¶æ¶Œå ¥è€Œå¯¼è‡´çš„å¤šçº¿ç¨‹ä¸å®‰å ¨é—®é¢˜ã€‚å¤šåº”ç”¨ï¼šå½“ç„¶åœ¨å•åº”ç”¨ä¸‹ä¸Šé¢çš„æ–¹æ¡ˆå·²ç»å¯ä»¥è§£å†³å¤§éƒ¨åˆ†é—®é¢˜ï¼Œä½†æ˜¯åœ¨å¤šåº”ç”¨ä¸‹ä¼¼ä¹Žä¸å¤ªç†æƒ³ã€‚åˆšå¼€å§‹æ˜¯å•åº”ç”¨æœåŠ¡ï¼Œä½†æ˜¯åŽæ¥ç”¨æˆ·é‡å¹¶å‘é‡æé«˜äº†ï¼Œæ¸æ¸åœ°å•åº”ç”¨æœåŠ¡æ‰›ä¸ä½äº†ï¼Œå°±é€šè¿‡Nginxè´Ÿè½½å‡è¡¡åˆ†æ‹ åˆ°å¦å¤–ä¸€å°æœåŠ¡æœºï¼Œæ­¤æ—¶å°±æ˜¯åŒåº”ç”¨äº†ã€‚è¿™æ ·ä¸€æ¥æœ‰ä¸¤ä¸ªåº”ç”¨åŒæ—¶ç›‘å¬åŒä¸€ä¸ªæ¶ˆæ¯é˜Ÿåˆ—ï¼Œæœ‰ä¸¤ä¸ªæ¶ˆè´¹è€ ã€‚æ¶ˆæ¯é˜Ÿåˆ—çš„å¤„ç†æœºåˆ¶ï¼šä¸€ä¸ªæ¶ˆæ¯é˜Ÿåˆ—é‡Œé¢çš„ä¸€æ¡æ¶ˆæ¯åªä¼šä» ä¸”å‘é€åˆ°ä¸€ä¸ªæ¶ˆè´¹è€ é‡Œé¢ï¼Œç­‰å¾ è¯¥æ¶ˆè´¹è€ Ackï¼Œä¸€æ¡æ¶ˆæ¯å°±å®Œæˆå®ƒçš„ä½¿å‘½äº†ã€‚æœ¬ä»¥ä¸ºè¿™æ ·å­å¤šåº”ç”¨ä¸‹ä¹Ÿä¸ä¼šå‡ºçŽ°ä»€ä¹ˆé—®é¢˜ï¼Œä½†æ˜¯é—®é¢˜å´å‡ºåœ¨åˆ«çš„åœ°æ–¹äº†ã€‚ï¼ˆæ³¨ï¼šåº”ç”¨A与应用B同库）当第一条消息分发到 应用A，第二条消息分发到 应用Bï¼Œä»–ä»¬å‡ ä¹Žæ˜¯åŒæ—¶è¿›è¡Œï¼Œæ¶ˆæ¯A在应用A处理事务，消息B在应用Bå¤„ç†äº‹åŠ¡ï¼Œä»–ä»¬éƒ½éœ€è¦èŽ·å–æ•°æ®åº“ä¸­çš„æŸæ¡æ•°æ®å¹¶ä¸”æ›´æ–°å ¶çŠ¶æ€ï¼Œç”±äºŽA没处理完数据状态未改，Bå› æ­¤ä¹ŸèŽ·å¾—äº†ç›¸åŒçš„ä¸€æ¡æ•°æ®ï¼Œå¯¼è‡´A，B抢了同一条数据做处理了。由于应用A，应用Béƒ½æ˜¯ç‹¬ç«‹çš„æœåŠ¡ï¼Œæ‰€ä»¥å•åº”ç”¨ä¸‹çš„åœ¨ä»£ç é‡Œé¢åŠ åŒæ­¥é”è¿™äº›å¯¹ä»–ä»¬æ¯«æ— ä½œç”¨ã€‚A，B同库，试着利用数据库本身的读写锁机制，进一步优化在insert之前在做一次判断，如果更新成功则insert，否则表明该数据已经被更新了，放弃insertã€‚åŠ äº†è¿™ç§åˆ¤æ–­æ–¹å¼ç¡®å®žå‡å°‘äº†å¾ˆå¤šæŠ¢æ•°æ®é—®é¢˜ï¼Œä½†å¹¶ä¸èƒ½å®Œå ¨è§£å†³è¿™ä¸ªé—®é¢˜ï¼Œæ¯•ç«Ÿæ•°æ®åº“é”åªæ˜¯åœ¨è¯»å†™çš„æ—¶å€™å¯¹ä¸€æ¡æ•°æ®çš„åŠ é”ï¼Œæ“ä½œå®Œäº†é‡Šæ”¾ï¼Œä½†ç”±äºŽåŒæ­¥æ€§å¤ªé«˜ï¼Œå¹¶ä¸èƒ½è§£å†³çŽ°åœ¨çš„é—®é¢˜ã€‚æœ€åŽè€ƒè™‘åˆ°ä¸¤ä¸ªåº”ç”¨éƒ½æ˜¯å®Œå ¨ä¸€æ ·çš„ï¼Œæ‰€ä»¥å°±å¹²æŽ‰ä¸€ä¸ªåº”ç”¨çš„æ¶ˆæ¯æ¶ˆè´¹è€ ï¼Œåªä¿ç•™ä¸€ä¸ªæ¶ˆè´¹è€ ï¼Œè¿™æ ·å°±å¯ä»¥å›žå½’åˆ°å•åº”ç”¨çš„æƒ æ™¯äº†ã€‚æ€»ç»“ï¼šè¿™ä¹Ÿæ˜¯ä¸ºä»€ä¹ˆåœ¨åˆ†å¸ƒå¼ï¼Œå¾®æœåŠ¡ä¸‹åˆ†å¸ƒå¼äº‹åŠ¡çš„å¿ è¦æ€§å’Œé‡è¦æ€§ï¼Œç›®å‰åˆ†å¸ƒå¼äº‹åŠ¡ä¸»è¦é€šè¿‡ MQ事件表、业务补偿、TCCã€å¯¹è´¦ç­‰æ–¹å¼å®žçŽ°ï¼Œä½†éƒ½ä¸å¥½åšï¼Œæ‰€ä»¥å°½é‡é¿å ã€‚åœ¨ä½¿ç”¨åˆ†å¸ƒå¼ï¼Œå¾®æœåŠ¡å¸¦æ¥çš„æ–¹ä¾¿åŒæ—¶ï¼Œä¹Ÿå¾—ä¸ºäº‹åŠ¡çš„å››ä¸ªç‰¹æ€§ï¼ˆåŽŸå­æ€§ï¼Œä¸€è‡´æ€§ï¼Œéš”ç¦»æ€§ï¼ŒæŒä¹ æ€§ï¼‰ä»˜å‡ºä»£ä»·ã€‚å ³æ³¨å ¬ä¼—å·ï¼Œåˆ†äº«å¹²è´§ï¼Œè®¨è®ºæŠ€æœ¯作者molashaonian
延伸阅读

更多相关文章

建站公司告诉你，网站建设包括哪些方面（全流程深度解析）
2026/9/21 19:53:01

建站公司告诉你，网站建设包括哪些方面（全流程深度解析）

在这个数字化浪潮汹涌澎湃的时代，几乎每一个稍微有点规模的企业，或者每一个想在互联网上留下点印记的创作者，都会面临同一个问题：我要做个网站。听起来似乎很简单，毕竟现在随便找个模板拖拽一下，好像半天就能上线一个。但是，真当你着手去准备的时候，你会发现水深得很，…

3d-vehicle-tracking常见问题解答：新手必知的8个关键知识点
2026/9/19 23:20:20

3d-vehicle-tracking常见问题解答：新手必知的8个关键知识点

3d-vehicle-tracking常见问题解答：新手必知的8个关键知识点 【免费下载链接】3d-vehicle-tracking Official implementation of Joint Monocular 3D Vehicle Detection and Tracking (ICCV 2019) 项目地址: https://gitcode.com/gh_mirrors/3d/3d-vehicle-trackin…

如何用Growler构建高性能异步Web应用：从入门到精通
2026/9/19 16:02:56

如何用Growler构建高性能异步Web应用：从入门到精通

如何用Growler构建高性能异步Web应用：从入门到精通 【免费下载链接】Growler A micro web-framework using asyncio coroutines and chained middleware. 项目地址: https://gitcode.com/gh_mirrors/gr/Growler Growler是一个基于Python asyncio的轻量级异步…

疯狂猜图 帽子进阶用法
2026/9/21 19:49:25

疯狂猜图 帽子进阶用法

面试官拷问疯狂猜图帽子逻辑，手写实现避坑指南 面试被问原理答不上来？别慌。昨天陪一个哥们模拟面试，聊到前端状态管理和组件通信，他卡壳了。面试官顺嘴提了一句：“像《疯狂猜图》里那个帽子切换逻辑，你如果不用…

参考文献格式生成器避坑：5个致命错误与最佳实践
2026/9/21 19:49:25

参考文献格式生成器避坑：5个致命错误与最佳实践

参考文献格式生成器避坑：5个致命错误与最佳实践 报错一堆看不懂，StackTrace 长得像天书，参考文献格式生成器明明配好了却输出乱码？别慌，这往往是配置细节或依赖版本冲突导致的。作为在一线踩过无数坑的开发者，我见过太多团队因为忽略…

老太BBW搡BBBB搡BBBB完整示例
2026/9/21 19:49:25

老太BBW搡BBBB搡BBBB完整示例

3步吃透HTTP协议：保姆级教程带你告别官方文档焦虑 官方文档太长抓不住重点？RFC 2616那几千行英文谁看得完？别慌，这篇 保姆级教程 专治各种“文档焦虑症”。 这里有一个必须澄清的事实：…

双曲螺线面试避坑指南：拒绝Stack Trace崩溃
2026/9/21 19:44:25

双曲螺线面试避坑指南：拒绝Stack Trace崩溃

双曲螺线面试避坑指南：拒绝Stack Trace崩溃 刚跑完双曲螺线算法，满屏红色报错？StackTrace 长得像天书，完全不知道从哪查起。别慌，这是典型的参数初始化或浮点精度陷阱。这份避坑指南专治各种“算得出来画不出来”的玄学问题，帮你…

GAMP 5 基于风险的计算机化系统验证：软件分类与审计追踪实践
2026/9/21 3:28:31

GAMP 5 基于风险的计算机化系统验证：软件分类与审计追踪实践

简介：《A Risk-Based Approach to Compliant GxP Computerized Systems》即业内熟知的GAMP 5指南，面向制药企业质量与IT合规人员、验证工程师及计算机化系统管理者，用于解决GxP法规环境下系统合规性难以科学落地的问题。文档以风险管理为主线…

安全托管MSSP实战：从静态防御到人机协同的攻防运营与应急响应
2026/9/21 3:33:19

安全托管MSSP实战：从静态防御到人机协同的攻防运营与应急响应

简介：这份PPT围绕互联网业务安全托管服务展开，面向企业安全负责人、IT运维人员及关注MSSP/MSS选型的读者，重点回应传统安全过度依赖人工、碎片化静态防御难以对抗产业化攻击等痛点。资源共1个pptx文件，包体约30.63MB，以…

OpenResearch：构建可复现的开放式研究工作流
2026/9/21 0:02:23

OpenResearch：构建可复现的开放式研究工作流

第一次看到“OpenResearch”这个名字，我脑子里冒出的不是某个具体软件，而更像一种研究方式的宣言：开放、可复现、可验证。这三件事放在一起，其实比大多数人想象中难得多。过去几年我一直在折腾自己的研究工作流，从纯纸…

USB Type-C PCB布局分区设计：电源、高速信号与PD协议全攻略
2026/9/20 4:54:47

USB Type-C PCB布局分区设计：电源、高速信号与PD协议全攻略

做硬件这行，Type-C接口算是典型的“看着简单，做起来全坑”的东西。光引脚就24个，高低速信号、电源、控制线全部塞在一个小小的连接器里，如果PCB布局不做规划，打样回来基本就是“插上没反应”、“高速掉线”、“静电一打…

系统编程学习原型如何补齐稳定性边界
2026/9/21 18:32:12

系统编程学习原型如何补齐稳定性边界

系统编程学习原型如何补齐稳定性边界预算有限时&#xff0c;我先优化明显多余的复制&#xff0c;而不是猜测性地换容器。用借用传递只读数据通常就能减少分配&#xff1a; fn parse(line: &str) -> Result<Item, Error> { /* ... */ }用基准确认热点确实在分配&am…

雨花区哪家财务公司代理记账比较好？
2026/9/21 10:29:02

雨花区哪家财务公司代理记账比较好？

在雨花区&#xff0c;企业处理财税事务常常面临诸多挑战&#xff0c;选择一家靠谱的财务公司至关重要。湖南巨勤财务管理咨询有限公司就是本地正规实体财税服务机构&#xff0c;深耕本地工商财税行业多年&#xff0c;熟悉当地工商局、税务局最新政策与申报流程。主营公司注册、…

还想了解更多？直接咨询顾问

免费诊断 + 免费方案 + 透明报价。

全国咨询热线400-8866-253
免费获取方案
☎咨询二维码 ☎ ↑