在项目中,DotnetCore.CAP 可以作为分布式事务、消息队列的解决方案,详见官方文档:https://cap.dotnetcore.xyz/,此处不过多的讲解。本文主要讲解官方文档没有说明,但是在实际项目确实必不可少的要点。
查询cap的源码可以知道:
(1)cap的重试进行器会每60s会执行检查一次,针对失败或者正在进行中的消息,如果重试次数不超过50次、4分钟之前,则请阅的节点就会查询出来进行发布到订阅调度器中,执行任务。因此针对订阅处理的时间超过4分钟没有成功,那么消息就会被每个集群节点查询出来,就会造成数据重复消费。
针对这个问题需要加入幂等性的进行处理
(2)kafka作为消息队列,如果假如新的组则订阅者会从头消费消息,可以在订阅入口通过时间过滤调无用的消息;