美文网首页
生产消息重发机制

生产消息重发机制

作者: Britney_z | 来源:发表于2021-08-13 16:19 被阅读0次

同步重试,异步或者oneway不再重发消息

例如:如果发送时间是3000毫秒,则mq预计broker的不可用时长为18000L(根据latencyMax数组,notAvailableDuration数组对应关系得到),则broker恢复正常时间为:当前时间+不可用时长,即System.currentTimeMillis() + notAvailableDuration 。

循环一直找到一个可用的broker。虽然broker有定时剔除,但Broker故障转移机制,可以选择更有效的broker。

相关文章

  • 生产消息重发机制

    同步重试,异步或者oneway不再重发消息 例如:如果发送时间是3000毫秒,则mq预计broker的不可用时长为...

  • rabbitMQ--防止消息丢失

    1.在生产端,可以通过comfirm机制,让生产端获悉消息已被MQ接收(接收不成功则重发)。 2.消息被消费者领了...

  • storm 消息重发机制

    Storm为确保消息的安全可靠到达每一个指定的bolt进行业务处理提供了一套可靠的安全机制 Storm的可靠性是指...

  • RocketMQ 8.可靠性消息投递

    方案1:消息落库 消息落库重发是基于RocketMQ的confirm机制,在消息发送失败后自动重发。该方案只能保证...

  • 消息重发

    主要看看 SendMessageProcessor 的consumerSendMsgBack方法,消费者将消息发送...

  • (7)消息的确认和重发机制

    1.消费端的 PrefetchSize 还记得我们在分析消费端的源码的时候,所讲到的 prefetchsize 吗...

  • rabbitmq知识总结

    rabbitmq消费者消费消息没有提供超时机制,需要客户端自己实现,当连接关闭或者channel关闭,才会重发消息...

  • RabbitMQ高级特性

    1、Confirm机制 消息的确认,是指生产者投递消息后,如果Broker收到消息,会给我们生产者一个应答。生产者...

  • Confirm确认消息

    消息确认机制 1.消息的确认,是指生产者投递消息后,如果Broker接受到消息,则会给生产者一个应答。2.生产者进...

  • Kafka学习笔记(二)架构深入

    1. Kafka工作流程及文件存储机制 Kafka中消息是以topic进行分类的,生产者生产消息,消费者消费消息,...

网友评论

      本文标题:生产消息重发机制

      本文链接:https://www.haomeiwen.com/subject/qrxjbltx.html