from: http://jm.taobao.org/2016/04/01/kafka-vs-rabbitmq-vs-rocketmq-message-send-performance/ 引言 分布式系统中,我们广泛运用消息中间件进行系统间的数据交换,便于异步解耦。现在开源的消息中间件有很多,前段时 ...
分类:
其他好文 时间:
2016-09-13 23:55:43
阅读次数:
228
RocketMQ是一款开源的消息中间件,采用Java实现,设计思想来自于Kafka(Scala实现),在具体设计时体现了自己的选择和需求,具体差别可以看RocketMQ与Kafka对比。接下来是自己阅读源码的一些探索。RocketMQ的整体架构如下,可以看到各个组件充当的角色,NameServer负责维护一些..
分类:
其他好文 时间:
2016-08-29 21:01:00
阅读次数:
321
RocketMQ是一款开源的消息中间件,采用Java实现,设计思想来自于Kafka(Scala实现),在具体设计时体现了自己的选择和需求,具体差别可以看RocketMQ与Kafka对比。接下来是自己阅读源码的一些探索。RocketMQ的整体架构如下,可以看到各个组件充当的角色,NameServer负责维护一些..
分类:
其他好文 时间:
2016-08-29 13:15:13
阅读次数:
111
BrokerStartup.java MixAll.java 由资源文件生成对象: 首先获取资源文件 获取对象的所有set开头的方法 截取方法,如:setMethod1 则为 method1 通过key获取properties文件value 获取该方法参数类型 调用该方法。 从而完成set 。 ...
分类:
其他好文 时间:
2016-08-06 08:38:46
阅读次数:
1115
1. jps 获取要监控broker jvm 的进程ID jsp 2. nohup 输出监控日志 nohup jstat -gc -t [pid] [interval] -t 会在每一条记录前加时间戳,执行命令间隔interval(毫秒) 3. 想要结束监控时Ctrl+C 4. 查看日志 cat n ...
分类:
其他好文 时间:
2016-08-06 08:35:17
阅读次数:
216
22 a b-s sh mqbroker -c $ROCKETMQ_HOME/conf/2m-2s-async/broker-a.properties &sh mqbroker -c $ROCKETMQ_HOME/conf/2m-2s-async/broker-b-s.properties & 23 ...
分类:
其他好文 时间:
2016-08-06 08:34:41
阅读次数:
166
请不要监控10912端口 case: result: 监控10912端口会导致HAService异常,新起线程,吃掉内存,无限次监控虚拟机将宕机! 时间上是直接因果关系. 监控10911 和 9876 没有问题. MessageStoreConfig.java ...
分类:
其他好文 时间:
2016-08-06 08:34:27
阅读次数:
524
一 、1. 修改store路径2. 修改logs路径3. 修改rmq_bk_gc.log路径4. 修改rmq_srv_gc.log路径二 、1. 获取正确的rocketmq 源码2. 地址:https://github.com/alibaba/RocketMQ三 、1. 修改store路径: ① 修 ...
分类:
其他好文 时间:
2016-08-06 08:30:55
阅读次数:
6537
runbroker.sh -server By default, all client applications run in -client mode, while the directory server and certain server utilities run in -server m ...
分类:
其他好文 时间:
2016-08-06 08:24:14
阅读次数:
2150
1.1. 控制台使用 RocketMQ 提供有控制台及一系列控制台命令,用于管理员对主题,集群,broker 等信息的管理 登录控制台 首先进入RocketMQ 工程,进入/RocketMQ/bin 在该目录下有个mqadmin 脚本 查看帮助 在mqadmin 下可以查看有哪些命令 sh mqad ...
分类:
其他好文 时间:
2016-08-06 08:24:07
阅读次数:
4635