Pulsar の 保证消息的顺序性、幂等性和可靠性 (3)

在这里插入图片描述

消费者:

在这里插入图片描述

关于保证消息的可靠性,我们只分析 Producer 和 Consuemr,Pulsar服务器就不分析了。

2.3.2、分析

producer:

生产者主要还是利用中间表来保证消息发送的可靠性:

发送消息前,先插入一条发送记录表

接着开启本地事务,开始发送消息

发送完毕,接到broker返回的响应

更新发送记录为已发送

开启定时任务,定时扫描未发送的记录,重新进行发送

consumer:

消费者保证消息的可靠性,只需要利用Pulsar提供的重试策略即可:

内容版权声明:除非注明,否则皆为本站原创文章。

转载注明出处:https://www.heiqu.com/zzjggg.html