前面的章节，我们已经把RocketMQ的环境搭建起来了，是一个两主两从的异步集群。接下来，我们就看看怎么去使用RocketMQ，在使用之前，先要在NameServer中创建Topic，我们知道RocketMQ是基于Topic的消息队列，在生产者发送消息的时

RocketMQ有一个对其扩展的开源项目incubator-rocketmq-externals，这个项目中有一个子模块叫rocketmq-console，这个便是管理控制台项目了，先将incubator-rocketmq-externals拉到本地，因为

brokerRole : broker角色 ASYNC_MASTER/ SYNC_MASTER/ SLAVE. flushDiskType ：刷盘策略, 默认为 ASYNC_FLUSH, 另外是SYNC_FLUSH. storePathRootDir :

近期在研究各种消息队列方案，为了有一个直观的使用体验，我把Kafka，RocketMQ，RabbitMQ各自部署了一遍，并使用了最基本的生产与消费消息功能。在部署过程中也遇到一些问题，特此记录。本文只适用于没有使用过消息队列，还停留在安装部署阶段的新手用户

//Create a message instance, specifying topic, tag and message body.Message msg = new Message("TopicTest11" /* Topic *

日常思维中，顺序大部分情况会和时间关联起来，即时间的先后表示事件的顺序关系。比如事件A发生在下午3点一刻，而事件B发生在下午4点，那么我们认为事件A发生在事件B之前，他们的顺序关系为先A后B。上面的例子之所以成立是因为他们有相同的参考系，即他们的时间是对应

本篇文章会尽力全面的介绍RocketMQ和Kafka各个关键点的比较，希望大家读完能有所收获。RocketMQ前身叫做MetaQ, 在MeataQ发布3.0版本的时候改名为RocketMQ，其本质上的设计思路和Kafka类似，但是和Kafka不同的是其使用

前言在分布式系统中,我们广泛运用消息中间件进行系统间的数据交换,便于异步解耦。现在开源的消息中间件有很多,前段时间产品 RocketMQ 也顺利开源,得到大家的关注。概念MQ简介MQ,Message queue,消息队列，就是指保存消息的一个容器。MQ特

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

　　　　　　<property name="namesrvAddr" value="127.0.0.1:9876" />

在消息队列中，当消费者去消费消息的时候，无论是通过 pull 的方式还是 push 的方式，都可能会出现大批量的消息突刺。如果此时要处理所有消息，很可能会导致系统负载过高，影响稳定性。但其实可能后面几秒之内都没有消息投递，若直接把多余的消息丢掉则没有充分利

本文将对rocktmq-spring-boot的设计实现做一个简单的介绍，读者可以通过本文了解将RocketMQ Client端集成为spring-boot-starter框架的开发细节，然后通过一个简单的示例来一步一步的讲解如何使用这个spring-bo

private final Map<String, DiscardSummary> discardMap = new HashMap<String, DiscardSummary>();

protected long maxFileSize = 10 * 1024 * 1024;

ProducerGroup用来表示一个发送消息应用，一个 Producer Group 下包含多个 Producer 实例，可以是多台机器，也可以是一台机器的多个进程，或者一个进程的多个 Producer 对象。一个 Producer Group 可以发送

在互联网架构中，MQ是一种非常常见的上下游“逻辑解耦+物理解耦”的消息通信服务。使用MQ之后，消息发送上游只需要依赖MQ，逻辑上和物理上都不用依赖其他服务。MQ的不足系统更加复杂，多了一个MQ组件消息传递路径更长，延时会增加消息可能会被重复消费上游无法知道

对MQ的理解一直不深,上周看了<Java消息服务>,还是觉得不够深入,找个成熟的产品来学习吧,RabbitMQ是erLang写的,Kafka是Scala写的,非Java写的看起来还需要补充很多知识,ActiveMQ虽然是Java,但是各方面略显

本文主要通过对Kafka源码的分析来简述其Reactor的多线程网络通信模型和总体框架结构，同时简要介绍Kafka网络通信层的设计与具体实现。， SocketServer ：其是一个NIO的服务，它同时启动一个Acceptor接收线程和多个Processo

本文整理自滴滴出行消息队列负责人 江海挺 在Apache RocketMQ开发者沙龙北京站的分享。在消息队列技术选型方面的思考；为什么选择 RocketMQ 作为出行业务的消息队列解决方案；如何构建自己的消息队列服务；在 RocketMQ 上的扩展改造实践

借用一句话“消息队列的本质在于消息的发送、存储和接收”。那么，对于一款消息队列来说，如何做到消息的高效发送与接收是重点和关键。NameServer：在MQ集群中做的是做命名服务，更新和路由发现 broker服务；Broker-Master：broker 消