RocketMQ之NameServer学习笔记
org.apache.rocketmq.namesrv.NamesrvController NameserController,NameServer的核心控制类。 1.1 NamesrvConfig NamesrvConfig,主要指定nameserver的相关配置目录属性 ...
原文：RocketMQ 笔记-转
Astrotrain概述 Astrotrain是基于阿里巴巴开源项目RocketMQ进行封装的分布式消息中间件系统，提供集群环境下的消息生产和消费功能。 RocketMQ介绍 RocketMQ的物理部署结构 Name Server 是一个几乎无状态节点，可集群部署，节点之间无任何信息同步。所有的主题和broker节点信息都由Name Server进行维护。 Broker 是主要的功能单元，处理主题 ...
2015-03-26 15:39 3 7447 推荐指数：
相关推荐
RocketMQ笔记---延时级别
RocketMQ 支持定时消息，但是不支持任意时间精度，仅支持特定的 level，例如定时 5s， 10s， 1m 等。其中，level=0 级表示不延时，level=1 表示 1 级延时，level=2 表示 2 级延时，以此类推。如何配置：在服务器端（rocketmq-broker端）的属性 ...
RocketMQ学习笔记（14）----RocketMQ的去重策略
巨大的开销。所以RocketMQ 为了追求高性能，并不保证此特性，要求在业务上进行去重，也就是说消费消 ...
RocketMQ学习笔记（15）----RocketMQ的消息模式
在前面学习ActiveMQ时，看到ActiveMQ可以是队列消息模式，也可以是订阅发布模式。 同样，在RocketMQ中，也存在两种消息模式，即是集群消费模式和广播消费模式。 1. 集群消费模式 跟AciiveMQ一样，当存在多个消费者时，消息通过一定负载均衡策略，将消息分发到多个 ...
RocketMQ学习笔记（8）----RocketMQ的Producer API简介
在RocketMQ中提供了三种发送消息的模式： 1.NormalProducer（普通） 2.OrderProducer（顺序） 3.TransactionProducer（事务） 下面来介绍一下producer中的各个API的使用： 1. producerGroup ...
RocketMQ学习笔记（11）----RocketMQ的PushConsumer和PullConsumer
1. PushConsumer 推，Broker主动向Consumer推消息，它Consumer的一种，应用通常向对象注册一个Listener接口，一旦接收到消息，Consumer对象立 ...
【rocketmq学习笔记】rocketmq入门学习
基本介绍 rocketmq是阿里巴巴团队使用java语言开发的一款基于发布订阅模型的分布式消息队列中间件，是一款低延迟，高可用，拥有海量消息堆积能力和灵活拓展性的消息队列。 特点 可以实现集群无单点故障问题，节点高可用，水平可扩展； 支持消息存储，写入低延迟，支持实时消息查询 ...
RocketMQ学习笔记（11）----RocketMQ的PushConsumer和PullConsumer
1. PushConsumer 推，Broker主动向Consumer推消息，它Consumer的一种，应用通常向对象注册一个Listener接口，一旦接收到消息，Consumer对象立刻回调L ...