RocketMQ_笔记

RocketMQ-Filer

duchaochen阅读(505)评论(0)赞(0)

一、搭建RocketMQ集群   我搭建的是2-master no slave模式,所以在${rocketmq}/conf/2m-noslave/下的 brokder-*.properties 中添加filter...

RocketMQ-事务消费

duchaochen阅读(503)评论(0)赞(0)

理论部分在https://www.jianshu.com/p/453c6e7ff81c中的 “三、事务消息”。下面从代码层面看一下rockemq的事务消息 一、事务消费端。   从代码中看到跟其他模式的消费端没有什么两样。 package ...

RocketMQ-顺序消费

duchaochen阅读(503)评论(0)赞(0)

  看了https://www.jianshu.com/p/453c6e7ff81c这篇博客,得出顺序消费的结论。“要实现严格的顺序消息,简单且可行的办法就是:保证生产者 - MQServer - 消费者是一对一的关系”。 我们下面通过几个...

RocketMQ-消费重试机制

duchaochen阅读(503)评论(0)赞(0)

介绍:   RocketMQ的消息重试及时分为两种,一种是Producer端重试,一种是Consume端重试。   1、Producer端重试 :     1.1消息发没发成功,默认情况下是3次重试。   2、Consumer端重试:   ...

RocketMQ-广播模式消费

duchaochen阅读(502)评论(0)赞(0)

Rocketmq 消费者默认是集群的方式消费的,消费者还可以用广播的模式进行消费。广播模式消费就是所有订阅同一个主题的消费者都会收到消息。代码实现上其实很简单,就是在消费端添加 consumer.setMessageModel(Messag...

RocketMQ-quickstart(批量消费问题)

duchaochen阅读(504)评论(0)赞(0)

基本概念:   Producer:消息生产者,负责生产消息,一般由业务系统负责生产消息。   Consumer:消息消费者,负责消费消息,一般是后台系统负责异步消费。   Push Consumer:Consumer的一种,应用通常向Con...

RocketMQ环境搭建(双master模式)

duchaochen阅读(503)评论(0)赞(0)

介绍:   多Master模式,一个集群无Slave,全是Master,例如2个Master或者3个Master。   优点:配置简单,单个Master宕机或重启维护对应用无影响,在磁盘配置为RAID10时,即使机器宕机不可恢复情况下,由于...

确认

duchaochen阅读(502)评论(0)赞(0)

Consumer Acknowledgements and Publisher Confirms 消费者到RabbitMQ的投递处理确认在AMQP 0-9-1中被称之为“acknowledgements”;而RabbitMQ给生产者的确认是...