首页 > Windows开发 > 详细

RocketMQ学习Api

时间:2018-05-12 23:02:51      阅读:220      评论:0      收藏:0      [点我收藏+]

生成者

DefaultMQProducer

 

发送消息失败,消息重试。

    produce.send(msg,10)

    可以指定重试的次数

 

 

消费者(先订阅服务,在发送消息)

DefaultMQPushConsumer

  setConsumerMessageBatchMaxsize(10);    看情况,不会一次性拉取10条数据。如果生成者先生产数据,有数据积累,可能会部分10条,10条的拉取。

 

 消费数据失败,重试。(可以得到重试的次数 )

    timeout重试(无限次数的重试)

    exception重试(理论性的重试,指定重试策略)

 

消费群组

    当有多个消费者组成一个组之后,当a消费者,消费b数据失败了,然后会将消息交给c消费者。

 

Broker

    多slave配置,主节点挂了,不会主从切换,slave节点主要用来提供消费数据(写入,同步数据是主节点干)

 

RocketMQ学习Api

原文:https://www.cnblogs.com/xiaotao13725566749/p/9030339.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!