1. PushConsumer 　　推，Broker主动向Consumer推消息，它Consumer的一种，应用通常向对象注册一个Listener接口，一旦接收到消息，Consumer对象立刻回调Linstener接口方法。Push方式里,consumer把轮询过程封装了,并注册 ...

基本介绍 rocketmq是阿里巴巴团队使用java语言开发的一款基于发布订阅模型的分布式消息队列中间件，是一款低延迟，高可用，拥有海量消息堆积能力和灵活拓展性的消息队列。 特点 可以实现集群无单点故障问题，节点高可用，水平可扩展； 支持消息存储，写入低延迟，支持实时消息查询 ...

org.apache.rocketmq.namesrv.NamesrvController NameserController,NameServer的核心控制类。 1.1 NamesrvConfig NamesrvConfig,主要指定nameserver的相关配置目录属性 ...

在前面学习ActiveMQ时，看到ActiveMQ可以是队列消息模式，也可以是订阅发布模式。 　　同样，在RocketMQ中，也存在两种消息模式，即是集群消费模式和广播消费模式。 1. 集群消费模式 　　跟AciiveMQ一样，当存在多个消费者时，消息通过一定负载均衡策略，将消息分发到多个 ...

在RocketMQ中提供了三种发送消息的模式： 　　1.NormalProducer（普通） 　　2.OrderProducer（顺序） 　　3.TransactionProducer（事务） 下面来介绍一下producer中的各个API的使用： 　　1. producerGroup ...

在Spring中，我们要实现事务，一般通过@Transactional注解实现。这在引入RocketMQ之前没有问题，但是在引入了RocketMQ之后，如果消息发送之后的业务逻辑处理发生了异常的话，这时候消息已经发送出去了，就会导致业务的问题。 为了解决这一问题，RocketMQ引入 ...

巨大的开销。所以RocketMQ 为了追求高性能，并不保证此特性，要求在业务上进行去重，也就是说消费消 ...

1. Rocketmq消费模型(实时性) 常见的数据同步方式有这几种： 　　push：producer发送消息后，broker马上把消息投递给consumer。这种方式好在实时性比较高，但是会增加broker的负载；而且消费端能力不同，如果push推送过快，消费端会出现很多问题。 　　pull ...