RocketMQ学习Api

Posted 2020-11-04 xiaotao13725566749

生成者

DefaultMQProducer

 

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

　　　　produce.send(msg,10)

　　　　可以指定重试的次数

 

 

消费者（先订阅服务，在发送消息）

DefaultMQPushConsumer

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

 

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

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

　　　　exception重试（理论性的重试，指定重试策略）

 

消费群组

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

 

Broker

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