Namesrv名称服务，是没有状态可集群横向扩展。 一：Namesrv功能： 二：Namesrv启动流程： 三： RouteInfoManager 路由信息RouteInfoManager类的管理 四：Namesrv与broker间的心跳： ...
分类：
其他好文 时间：
2016-11-11 19:33:58
阅读次数：
334
Remoting2. 通信层底层传输协议 RocketMq服务器与客户端通过传递RemotingCommand来交互，通过NettyDecoder，对RemotingCommand进行协议的编码与解码 协议格式 <length> <header length> <header data> <body ...
分类：
其他好文 时间：
2016-11-11 19:27:40
阅读次数：
426
备注：1.如果您此前未接触过RocketMQ，请先阅读附录部分，以便了解RocketMQ的整体架构和相关术语2.文中的MQServer与Broker表示同一概念 分布式消息系统作为实现分布式系统可扩展、可伸缩性的关键组件，需要具有高吞吐量、高可用等特点。而谈到消息系统的设计，就回避不了两个问题： R ...
分类：
其他好文 时间：
2016-11-11 11:44:10
阅读次数：
161
java-jarxxx.jarparams的形式用了这么多年，都没在意原来java的执行命令可以多元的。这两天刚好在看rocketmq，顺便看了下它的shell脚本，然后才发现原来我这么多年的java-jar有多么的无知。先来一段命令：java-Djava.ext.dirs=$ROCKETMQ_HOME/lib-cp$ROCKETMQ_HOME/lib/rocketm..
分类：
编程语言 时间：
2016-11-01 21:49:48
阅读次数：
263
转载请注明出处：http://www.cnblogs.com/xiaodf/ 本示例展示了一个RocketMQ producer的简单实现，通过解析文本文件获取输入数据，将数据经过Avro序列化后发送到RocketMQ。 程序通过stdin.xml配置文件获取主要参数值，stdin.xml文件内容如 ...
分类：
其他好文 时间：
2016-10-26 14:13:45
阅读次数：
282
一、启动RocketMQ[root@master~]#cat/etc/hosts#Donotremovethefollowingline,orvariousprograms#thatrequirenetworkfunctionalitywillfail.127.0.0.1localhost.localdomainlocalhost::1localhost6.localdomain6localhost6192.168.1.106node1192.168.1.103master192.168.1.110n..
分类：
编程语言 时间：
2016-10-22 18:33:55
阅读次数：
542
RocketMQ3.2.6安装部署及调用
1、RocketMQ部署架构
所有IP都是127.0.0.1，其中NameServer一个，Broker一个，Producer一个，Consumer一个 ...
分类：
其他好文 时间：
2016-10-10 11:31:07
阅读次数：
148
备注：1.如果您此前未接触过RocketMQ，请先阅读附录部分，以便了解RocketMQ的整体架构和相关术语2.文中的MQServer与Broker表示同一概念 分布式消息系统作为实现分布式系统可扩展、可伸缩性的关键组件，需要具有高吞吐量、高可用等特点。而谈到消息系统的设计，就回避不了两个问题： 消... ...
分类：
其他好文 时间：
2016-09-27 19:27:36
阅读次数：
694
一、消息队列概述消息队列中间件是分布式系统中重要的组件，主要解决应用解耦，异步消息，流量削锋等问题，实现高性能，高可用，可伸缩和最终一致性架构。目前使用较多的消息队列有ActiveMQ，RabbitMQ，ZeroMQ，Kafka，MetaMQ，RocketMQ 二、消息队列应用场景以下介绍消息队列在 ...
分类：
其他好文 时间：
2016-09-27 17:44:56
阅读次数：
156
