1. Rocketmq消费模型(实时性) 常见的数据同步方式有这几种： 　　push：producer发送消息后，broker马上把消息投递给consumer。这种方式好在实时性比较高，但是会增加broker的负载；而且消费端能力不同，如果push推送过快，消费端会出现很多问题。 　　pull ...

　　RocketMQ作为消息中间件，经常会被用来和其他消息中间件做比较，比对rabbitmq, kafka... 但个人觉得它一直对标的，都是kafka。因为它们面对的场景往往都是超高并发，超高性能要求的场景。 　　所以，有必要深挖下其实现高性能，高并发的原因。实际上，这是非常大的话题 ...

一、零拷贝原理：Consumer 消费消息过程，使用了零拷贝，零拷贝包含以下两种方式： 1、使用 mmap + write 方式 （RocketMQ选择的方式：因为有小块数据传输的需求，效果会比 sendfile 更好） 优点：即使频繁调用，使用小块文件传输，效率也很高； 缺点：不能很好 ...

　　上一篇文章讲了如何设计和实现高并发高性能的应用，从根本上说明了一些道理。且以rocketmq的mappedFile的实现作为一个突破点，讲解了rocketmq是如何具体实现高性能的。从中我们也知道，mappedFile只是其利用的操作系统的一个特性小点。 　　今天，我们就来说说，rockmq ...

原创文章，转载请注明出处：http://jameswxx.iteye.com/blog/2093785 一 机器部署 1.1 机器组成 1台nameserver 1台b ...

应用场景 主要作用解耦、滑峰填谷 异构系统的整合，这个问题比较容易理解，在原阿里SOA ESB比较火的年代，很多 ...

前言 阿里消息团队一直致力于RocketMQ的性能优化，双十一前进行了低延时（毛刺）优化，保障了双十一万亿消息的流转如丝般顺滑，在2016年双十一中，MetaQ以接近万亿的消息总量支撑着全集团数千个应用，在系统解耦、削峰填谷、数据库同步、位点回滚消费等多种业务场景中，MetaQ都有精彩 ...

1.需求背景 在1台生产者、1台broker、1台namesrv 、1台消费者的架构中，测试字节为1024B，客户端线程数：256、128、64、32，MQ队列大小为16、32、64、128，进行roketmq的生产与消费的性能测试，找出最大tps。 RocketMQ作为一款纯java、分布式 ...