RocketMQ学习Api
2021-04-11 04:25
阅读：375
标签：slave 部分 bsp 重试 size 群组 api 指定 cer 发送消息失败，消息重试。 produce.send(msg,10) 可以指定重试的次数 setConsumerMessageBatchMaxsize(10); 看情况，不会一次性拉取10条数据。如果生成者先生产数据，有数据积累，可能会部分10条，10条的拉取。 消费数据失败，重试。(可以得到重试的次数 ) timeout重试(无限次数的重试) exception重试（理论性的重试，指定重试策略） 消费群组 当有多个消费者组成一个组之后，当a消费者，消费b数据失败了，然后会将消息交给c消费者。 多slave配置，主节点挂了，不会主从切换，slave节点主要用来提供消费数据（写入，同步数据是主节点干） RocketMQ学习Api 标签：slave 部分 bsp 重试 size 群组 api 指定 cer 原文地址：https://www.cnblogs.com/xiaotao13725566749/p/9030339.html生成者
DefaultMQProducer
消费者（先订阅服务，在发送消息）
DefaultMQPushConsumer
Broker
上一篇：百度地图api使用
下一篇：Windows编译Opencv
评论
亲，登录后才可以留言！