概述其实一直想写一篇rocketMq和kafka在架构设计上的差别，但是一直有个问题没搞明白所以迟迟没动手，今天无意中听人点播了一下似乎明白了这个问题，所以就有了这篇对比。

运行当前最新版本的RockitMQ，必须先安装64bit的JDK1.8或以上版本。bin目录下存放可运行的脚本。在动手开发之前，我们需要了解一下RocketMQ的基本结构。如上图所示，一个正常工作的RocketMQ包括四个部分。正式应用时通常采用集群部署。

阿里中间件团队博客 -- 十分钟入门RocketMQ：

同时同步Replication也比Kafka异步Replication更可靠，数据完全无单点。开源版本的RocketMQ不支持Master宕机，Slave自动切换为Master，阿里云版本的RocketMQ支持自动切换特性。RocketMQ单机写入TPS单

RocketMQ 是阿里出品的一款MQ,现在已经捐给Apache并成为Apache顶级项目,更多介绍请移步在这里向大家介绍一个学习RocketMQ的好文章:RocketMQ实战（一）RocketMQ实战（二）RocketMQ实战（三）RocketMQ实战（

# We suggest the following mirror site for your download:官方建议下载地址。rocketmq的默认配置极其耗内存，要进行修改。<br/>1）修改runserver.sh配置<br/&

mvn -Prelease-all -DskipTests clean install -U进入打包好的文件。消息发送的高性能与低延迟。强大的消息堆积能力与消息处理能力。严格的顺序消息存储。RocketMQ保证消息至少被消费一次，但不承诺消息不会被消费者多

我还记得第一次使用rocketmq的时候，需要去控制台预先创建topic，我当时就想为什么要这么设计，于是我决定撸一波源码，带大家从根源上吃透rocketmq topic的创建机制。其实rocketmq中存在两种不同的topic创建方式，一种是我刚刚说的预

长轮询长轮询通过客户端和服务端的配合，达到主动权在客户端，同时也能保证数据的实时性；长轮询本质上也是轮询，只不过对普通的轮询做了优化处理，服务端在没有数据的时候并不是马上返回数据，会hold住请求，等待服务端有数据，或者一直没有数据超时处理，然后一直循环下

前言上文RocketMQ生产者流程篇中详细介绍了生产者发送消息的流程，本文将重点介绍发送消息的通信模式以及各种不同的消息类型。通信模式RocketMQ提供了三种通讯模式，分别是：同步，异步和单向；可以查看内部类CommunicationMode：。}最简单

近日，阿里云消息队列MQ发布了多项产品新特性，上线消息队列 AMQP 全新子产品，全面兼容 RabbitMQ 开源产品以及 AMQP 标准协议，用户得以在享用开源技术红利的同时，免去部署和运维方面的投入。同时，消息队列 RocketMQ 采用全新的HTTP

RocketMQ消息系统 - pull模式一、消费模式消息系统常见的消费模式分为push模式和pull模式，push模式是服务端主动给客户端推送数据，也是比较常见的模式，pull模式则是客户端主动去服务端拉取数据。④ 负载均衡，服务端统一处理和控制，需要根

如上图所示，整体可以分成4个角色，分别是：Producer，Consumer，Broker以及NameServer；

private final HashMap<String/* Namespace */, HashMap<String/* Key */, String/* Value */>> configTable =

super(properties);return properties;public SendResult send(final Message message, final KeyValue properties) {. return send(mess

环境要求64位系统，Linux/Unix/Mac64位 JDK 1.8+Maven 3.2.xGit如果下载binary包的话，只需要前两条就可以了。The Name Server boot success...Name Server的默认监听端口为987

概览Apache RocketMQ是一款具有低延迟，高性能和可靠性，数十亿容量和灵活可扩展性的分布式消息传递和流媒体平台。它由四部分组成：Name Servers，brokers，producers和consumers。它们中的每一个都可以在没有单点故障的

Consumer Group的概念是什么?Consumer pull过程是怎样的?Consumer 怎么实现单队列并行消费?Consumer 怎么保证一条消息只被Group中的一个服务消费?Consumer消息消费者，负责消费消息，一般是后台系统负责异步消

在早期阶段，我们在ActiveMQ 5.x的基础上构建我们的分布式消息中间件。随着我们的交易业务量增加，来自消息集群的压力与日俱增，亟需解决。根据我们的研究，随着使用中的队列越来越长、虚拟主题越来越多，ActiveMQ的IO模型会到达一个瓶颈。不走运的是，

本文主要介绍RocketMQ中Topic、Tag、GroupName的概念、设计初衷以及使用方法。Topic是生产者在发送消息和消费者在拉取消息的类别。Topic与生产者和消费者之间的关系非常松散。Topic在Google翻译中解释为话题。在应用系统中，一