使用rocketmq的大体消息发送过程如下: 在前面已经分析过MQ的broker接收生产者客户端发过来的消息的过程,此文主要讲述订阅者获取消息的过程,或者说broker是怎样将消息传递给消费者客户端的,即上面时序图中拉取消息(pull message)动作。。 1. 如何找到入口(MQ-broker... ...
分类:
其他好文 时间:
2017-02-23 00:01:40
阅读次数:
422
今天来和大家探讨一下RocketMQ在消息存储方面所作出的努力.
分类:
其他好文 时间:
2017-02-19 22:03:27
阅读次数:
938
benchmark 分析 组成部分 三个java类,都含有main方法,可选的传递一些参数,诸如测试线程数量,消息体积大小。三个类分别用于测试普通生产者,事务生产者,消费者。生产者 默认64个测试线程 1280byte消息大小。 测试指标 普通生产者 这段时间内 每秒发送成功了多少条 采样时间断内 ...
分类:
其他好文 时间:
2017-02-02 20:49:52
阅读次数:
360
metrics 一些关于metrics的文档,demo以及源码学习笔记.metrics主要用于度量。 起因 在研究了rocketmq的benchmark之后,又研究了kafka的benchmark。研究到kafka的benchmark时发现其用到了metrics。然后思索了下,其实这个也可以用在我们 ...
分类:
其他好文 时间:
2017-02-02 16:35:02
阅读次数:
331
前言 最近用了几个月的时间,一直在对EQueue做性能优化。到现在总算告一段落了,现在把一些优化的结果分享给大家。EQueue是一个分布式的消息队列,设计思路基本和阿里的RocketMQ一致,只是是用纯C 写的,这点大家应该都知道了。 EQueue开源地址:https://github.com/ta ...
分类:
其他好文 时间:
2017-01-29 21:23:53
阅读次数:
298
Kafka作为时下最流行的开源消息系统,被广泛地应用在数据缓冲、异步通信、汇集日志、系统解耦等方面。相比较于RocketMQ等其他常见消息系统,Kafka在保障了大部分功能特性的同时,还提供了超一流的读写性能。 针对Kafka性能方面进行简单分析,相关数据请参考:https://segmentfau ...
分类:
其他好文 时间:
2017-01-24 23:59:05
阅读次数:
1300
RocketMQ 是alibaba开源的消息队列。 本文使用的是开源版本v3.18 系统: centos6.x最小化安装 需要用到的软件包: jdk-7u67-linux-x64.tar.gz alibaba-rocketmq-3.1.8.tar.gz 开始安装 配置环境变量 在/etc/profi ...
分类:
其他好文 时间:
2017-01-14 18:34:49
阅读次数:
140
[root@rocketmq-master2zyc]#tar-tfzyc.tarzyc/zyc/example/zyc/example/zyczyc/access_2016-08-13[root@rocketmq-master2zyc]#tar--deletezyc/access_2016-08-13-vfzyc.tar[root@rocketmq-master2zyc]#tar-tfzyc.tarzyc/zyc/example/zyc/example/zyc
分类:
其他好文 时间:
2017-01-09 16:57:34
阅读次数:
273
1. 下载安装包,解压 2. cmd 3. 启动 mqnameserv 4. 启动 mqbroker ...
分类:
其他好文 时间:
2017-01-08 22:43:14
阅读次数:
243
前言Netty作为目前世界上最流行的NIO框架之一,在功能、性能、健壮性方面首屈一指,而且在很多项目中得到验证,比如消息中间件RocketMQ、分布式通信框架Dubbox。Netty内部实现复杂,但是提供给外界的API却十分简单,轻松的让我们的网络处理代码和业务逻辑处理代码分离开,从而..
分类:
Web程序 时间:
2017-01-07 21:23:25
阅读次数:
248