大家好，接下上篇文章继续吧。10，booleaninitResult=controller.initialize();这才是controller初始化的地方booleanresult=true;result=result&&this.topicConfigManager.load();加载topic配置JSON串如下：{"dataVersion":{"counter":4,"timestatmp":1429155762598},..
分类：
其他好文 时间：
2015-04-17 18:40:12
阅读次数：
509
hi大家好上两章介绍了namesrv的启动和注册过程，有什么不对的地方欢迎大家吐槽,接着开始分析broker吧
分类：
其他好文 时间：
2015-04-16 17:55:11
阅读次数：
558
大家好，很高兴在这里跟大家分享下rocketmq源码实现，如有不对的地方欢迎指正。Namesrv顾名思义就是名称服务，是没有状态可横向扩展的服务。废话不多说了，直接贴代码。。1,入口函数NamesrvStartup.main01.1System.setProperty(RemotingCommand.RemotingVersionKey,Integer.toS..
分类：
其他好文 时间：
2015-04-11 21:02:28
阅读次数：
397
大家好，很高兴在这里跟大家分享下rocketmq源码实现，如有不对的地方欢迎指正。接着上篇文章继续展开namesrv注册过程。
分类：
其他好文 时间：
2015-04-11 21:00:07
阅读次数：
146
本文想介绍一下前段时间在写enode时，顺便实现的一个分布式消息队列equeue。这个消息队列的思想不是我想出来的，而是通过学习阿里的rocketmq后，自己用c#实现了一个轻量级的简单版本。一方面可以通过写这个队列让自己更深入的掌握消息队列的一些常见问题；另一方面也可以用来和enode集成，为en...
分类：
其他好文 时间：
2015-04-01 19:18:31
阅读次数：
244
RocketMQ与Kafka对比（18项差异）
2015-02-28王启军奔跑中的蜗牛
此文是rocketmq作者vintage.wang所写，对于每项对比，后面都增加了我的观点，有不对的地方，请各位指出。
淘宝内部的交易系统使用了淘宝自主研发的Notify消息中间件，使用Mysql作为消息存储媒介，可完全水平扩容，为了进一步降低成本，我们认为存储部分可以...
分类：
其他好文 时间：
2015-03-10 19:23:56
阅读次数：
155
消息中间件rocketmq原理解析：http://download.csdn.net/detail/u010311445/8451015
服务治理中间件dubbo原理解析：http://download.csdn.net/detail/u010311445/8451021...
分类：
其他好文 时间：
2015-02-18 14:11:10
阅读次数：
151
pom.xml 4.0.0 net.datafans net.datafans.exercise.rocketmq 0.0.1-SNAPSHOT com.alibaba.rocketmq rocketmq-c...
分类：
其他好文 时间：
2014-12-10 01:40:13
阅读次数：
272
问题现象RocketMQ3.2.2版本，测试时尝试发送消息时自动创建Topic，设置了队列数量为8：producer.setDefaultTopicQueueNums(8);同时设置broker服务器的配置文件broker.properties：defaultTopicQueueNums=16但实际创建后从控制台及后台打印代码观察到该Topic只创建了4个队列，反..
分类：
其他好文 时间：
2014-11-22 02:09:11
阅读次数：
9396
RocketMQ会在Topics.json保存默认队列信息，在消息生产者发送消息自动创建Topic时，borker服务器会比较生产者设定的QueueNum和默认队列信息的writeQueueNum，取其中较小者作为新生成Topic队列的队列数。borker.properties中设定的default...
分类：
其他好文 时间：
2014-11-21 21:41:09
阅读次数：
229
