消费者:
关于保证消息的可靠性,我们只分析 Producer 和 Consuemr,Pulsar服务器就不分析了。
2.3.2、分析producer:
生产者主要还是利用中间表来保证消息发送的可靠性:
发送消息前,先插入一条发送记录表
接着开启本地事务,开始发送消息
发送完毕,接到broker返回的响应
更新发送记录为已发送
开启定时任务,定时扫描未发送的记录,重新进行发送
consumer:
消费者保证消息的可靠性,只需要利用Pulsar提供的重试策略即可:
消费者:
关于保证消息的可靠性,我们只分析 Producer 和 Consuemr,Pulsar服务器就不分析了。
2.3.2、分析producer:
生产者主要还是利用中间表来保证消息发送的可靠性:
发送消息前,先插入一条发送记录表
接着开启本地事务,开始发送消息
发送完毕,接到broker返回的响应
更新发送记录为已发送
开启定时任务,定时扫描未发送的记录,重新进行发送
consumer:
消费者保证消息的可靠性,只需要利用Pulsar提供的重试策略即可:
内容版权声明:除非注明,否则皆为本站原创文章。