标签：订阅 CAP 06 cap 查询 DotnetCore 节点 消息

描述

在项目中，DotnetCore.CAP 可以作为分布式事务、消息队列的解决方案，详见官方文档：https://cap.dotnetcore.xyz/，此处不过多的讲解。本文主要讲解官方文档没有说明，但是在实际项目确实必不可少的要点。

消息会被集群中的每个节点都消费的问题？

查询cap的源码可以知道：

(1)cap的重试进行器会每60s会执行检查一次，针对失败或者正在进行中的消息，如果重试次数不超过50次、4分钟之前，则请阅的节点就会查询出来进行发布到订阅调度器中，执行任务。因此针对订阅处理的时间超过4分钟没有成功，那么消息就会被每个集群节点查询出来，就会造成数据重复消费。

针对这个问题需要加入幂等性的进行处理

 （2）kafka作为消息队列，如果假如新的组则订阅者会从头消费消息，可以在订阅入口通过时间过滤调无用的消息；

标签：订阅,CAP,06,cap,查询,DotnetCore,节点,消息
来源： https://www.cnblogs.com/hjwcore/p/16632811.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。