首页/新闻资讯/详情

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

发布时间：2026/11/15 14:03:38

单应用下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/11/16 5:42:05

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

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

3d-vehicle-tracking常见问题解答：新手必知的8个关键知识点
2026/11/16 5:42:05

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/11/13 13:13:54

如何用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/11/16 5:41:21

龙游电工证查询官方回应：电工证全国通用吗？上岗前必须知道

龙游电工证查询官方回应：电工证全国通用吗？上岗前必须知道 你正准备找工作，结果对方一句“必须有电工证”直接把你拦下？这年头， 特种作业证 几乎成了很多行业的门槛， 龙游电工证查询 成了刚需，但你有没有想过，这张证真的全国通用吗？别急，…

工地太忙根本没时间复习考试？福州初级电工证网上查询和办理全攻略
2026/11/16 5:41:21

工地太忙根本没时间复习考试？福州初级电工证网上查询和办理全攻略

工地太忙根本没时间复习考试？福州初级电工证网上查询和办理全攻略 工地太忙根本没时间复习考试？很多电工朋友都在为福州初级电工证的办理发愁，特别是那些刚入行的工人，既要面对高强度的工作节奏，又得抽空准备考试和网上查询相关流程。别急，这篇文章从开…

民权电工证在哪里办理考前押题怎么找？工地太忙根本没时间复习考试
2026/11/16 5:41:21

民权电工证在哪里办理考前押题怎么找？工地太忙根本没时间复习考试

民权电工证在哪里办理考前押题怎么找？工地太忙根本没时间复习考试 工地太忙根本没时间复习考试，这是大多数电工在备考特种作业操作证时的普遍烦恼。特别是像民权县这样的地方，很多人工作在一线，根本没有多余的时间去准备理论和实操考试。别急，这篇文章就…

哪些特种工适合女生通过率揭秘
2026/11/16 5:41:21

哪些特种工适合女生通过率揭秘

哪些特种工适合女生通过率揭秘 之前考的证在外省能不能转过来？这是很多考生最关心的问题，特别是那些在外省工作或曾经在外地报考证书的学员。 通过率揭秘…

司机算特种工吗？含金量和报考全解析
2026/11/16 5:36:21

司机算特种工吗？含金量和报考全解析

司机算特种工吗？含金量和报考全解析 工地太忙根本没时间复习考试，这种焦虑很多特种作业操作证的考生都经历过。特别是像司机这类岗位，不少人会疑惑—— 司机算特种工吗？…

电工证考试口诉怎么准备值不值得考
2026/11/15 0:02:49

电工证考试口诉怎么准备值不值得考

电工证考试口诉怎么准备值不值得考 实操考试心里没底怕挂科，这是大多数准备考电工证的人心里最真实的感受。尤其是面对【电工证考试口诉】环节，很多人不知道该怎么准备，甚至担心自己说不好就被淘汰。其实，只要掌握方法， 值不值得考…

桑植县考电工证千万别踩坑！报名全流程教你避坑
2026/11/16 5:30:20

桑植县考电工证千万别踩坑！报名全流程教你避坑

桑植县考电工证千万别踩坑！报名全流程教你避坑 你是不是也遇到过这种情况：想考个电工证，但不知道从哪儿下手，怕被中介坑，怕花冤枉钱，更怕考了证还不能用？别急，这正是你该看这篇文章的原因。在桑植县考电工证，确实有很多人被坑过，但只要你知道流程、…

黎城电工证查询报名费多少钱 内部消息告诉你怎么避开中介陷阱
2026/11/16 0:00:11

黎城电工证查询报名费多少钱 内部消息告诉你怎么避开中介陷阱

黎城电工证查询报名费多少钱 内部消息告诉你怎么避开中介陷阱 你是不是也和我一样，想考电工证，但不知道去哪报名，怕被中介坑？最近网上有不少人问“黎城电工证查询报名费多少钱”，结果一查，信息五花八门，真假难辨。别担心，今天我就从一线从业者的角度…

青岛崂山区电工证培训通过率揭秘：外省证书怎么转过来？
2026/11/16 0:00:11

青岛崂山区电工证培训通过率揭秘：外省证书怎么转过来？

青岛崂山区电工证培训通过率揭秘：外省证书怎么转过来？ 之前考的证在外省能不能转过来？这个问题困扰着很多在外地打工的电工，尤其是像南阳卧龙区的建筑工人，他们常年在工地作业，手上持有电工证是基本要求，但很多人因为工作流动性大，担心证书不能转到本…

面向复杂光照与角度的宠物面部识别鲁棒性增强策略
2026/11/15 4:46:37

面向复杂光照与角度的宠物面部识别鲁棒性增强策略

在智慧养宠时代，基于视觉的宠物身份识别技术正逐步从实验室走向家庭应用。然而，与配合度高的人类不同，宠物是典型的“非合作生物识别对象”——它们不会主动配合摄像头调整姿态，更无法控制光照环境。实际应用中，我们常…

SSM电子书店源码全解析：结构、原理、部署与排错实战
2026/11/16 3:17:47

SSM电子书店源码全解析：结构、原理、部署与排错实战

/* MD / 富文本中的 .toc（含博客园搬家等嵌套结构）；.toc-box 在侧栏，不受影响 */#content_views .toc,/* 编辑器常在目录前后插入空 p（:empty 仍占 20px），一并去掉避免顶空隙 */#content_views.markdown_views > p:empty:has(+ .toc),#content_views.markdown_views …

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

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

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