发布时间:2026/8/6 20:00:45
单应用下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/8/6 20:00:45

建站公司告诉你,网站建设包括哪些方面(全流程深度解析)

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

2026/8/6 20:00:45

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…

2026/8/6 20:00:45

如何用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/8/6 21:55:54

从0到1:使用LeRobot框架部署PI0Fast-libero-v044的完整指南

从0到1:使用LeRobot框架部署PI0Fast-libero-v044的完整指南 【免费下载链接】pi0fast-libero-v044 项目地址: https://ai.gitcode.com/hf_mirrors/lerobot/pi0fast-libero-v044 PI0Fast-libero-v044是基于LeRobot框架构建的视觉-语言-动作(VLA&a…

2026/8/6 21:55:54

ADR漏洞修复指南:常见安全问题解决方案

ADR漏洞修复指南:常见安全问题解决方案 【免费下载链接】ADR ADR secures enterprise AI agents through observability, security benchmarking, and threat detection. Deployed at Uber. 项目地址: https://gitcode.com/GitHub_Trending/adr10/ADR ADR&am…

2026/8/6 21:55:54

网安行业缺口超三百万,普通人如何抓住高薪就业机会

行业红利:从薪资数据看网安岗位的“含金量” 在当前的就业环境下,选择一个赛道往往比单纯的努力更重要。对于许多正在观望或准备转行的朋友来说,网络安全(Cyber Security)无疑是一个极具吸引力的领域。这并非空穴来风&…

2026/8/5 3:13:11

如何用免费工具突破游戏窗口限制:SRWE完整使用指南

如何用免费工具突破游戏窗口限制:SRWE完整使用指南 【免费下载链接】SRWE Simple Runtime Window Editor 项目地址: https://gitcode.com/gh_mirrors/sr/SRWE 你是否遇到过这样的困扰?想为心爱的游戏截图,却发现游戏不支持自定义分辨率…

2026/8/6 0:04:22

电力系统调度中的源荷不确定性建模与优化实践

1. 电力系统调度中的源荷不确定性挑战现代电力系统正面临前所未有的复杂性,其中源荷不确定性(Source-Load Uncertainty)已成为调度决策中最棘手的难题之一。我在参与某省级电网调度系统升级时,曾遇到风电预测误差导致日内调度计划…

2026/8/6 0:04:22

VGG-T3技术解析:3D重建速度的革命性突破

1. 项目概述:VGG-T3如何重新定义3D重建速度在计算机视觉领域,3D场景重建一直是个计算密集型任务。传统方法重建1000帧图像规模的场景往往需要数小时甚至更长时间,而英伟达最新发布的VGG-T3技术将这个时间压缩到了惊人的54秒。这个突破性进展来…

2026/8/6 0:04:22

深度解析旅游网站建设的意义及其对行业发展的深远影响与核心价值体现

在这个数字化浪潮席卷全球的今天,我们似乎已经忘记了,曾经有一段时间,人们想要去一个陌生的地方,只能靠在书桌前翻阅厚厚的旅游杂志,或者向刚从那里回来的朋友询问那些模糊不清的印象。那时候,“远方”是一个需要精打细算才能抵达的奢侈概念。而现在,只需要一部手机,轻…

2026/8/5 19:21:13

实测才敢推 AI论文网站 2026最新测评与推荐

2026年真正好用的AI论文网站,核心看生成的论文质量、低AI味、格式正确、学术适配四大指标。综合实测,千笔AI、ThouPen、豆包、DeepSeek、Grammarly 是当前最值得推荐的梯队,覆盖从免费到付费、从中文到英文、从文科到理工的全场景需求。一、综…

2026/8/5 19:21:13

2026必备!AI论文网站测评:最新推荐与深度对比

2026年真正好用的AI论文网站,核心看生成的论文质量、低AI味、格式正确、学术适配四大指标。综合实测,千笔AI、ThouPen、豆包、DeepSeek、Grammarly 是当前最值得推荐的梯队,覆盖从免费到付费、从中文到英文、从文科到理工的全场景需求。 一、…

2026/8/6 20:45:01

摆脱论文困扰!盘点2026年全网爆红的的AI论文写作工具

一天写完毕业论文在2026年已不再是天方夜谭。2026年最炸裂、实测能大幅提速的AI论文写作工具,覆盖选题构思、文献整理、内容生成、格式排版等核心场景,真正帮你高效搞定论文难题。 一、全流程王者:一站式搞定论文全链路(一天定稿首…