rocketMQ(九) rocketMQ 高性能分析之ZeroCopy零拷贝技术
高效原因 CommitLog顺序写, 存储了MessagBody、message key、tag等信息 ConsumeQueue随机读 + 操作系统的PageCache + 零拷贝技术ZeroCopy 2.1 零拷贝技术 例子：将一个File读取并发送出去（Linux有两个 ...
原文：RocketMQ高性能原理(pushConsumer,CommitLog,ZeroCopy)
. Rocketmq消费模型 实时性 常见的数据同步方式有这几种： push：producer发送消息后，broker马上把消息投递给consumer。这种方式好在实时性比较高，但是会增加broker的负载 而且消费端能力不同，如果push推送过快，消费端会出现很多问题。 pull：producer发送消息后，broker什么也不做，等着consumer自己来读取。它的优点在于主动权在消费者端， ...
2019-05-19 19:06 0 1329 推荐指数：
相关推荐
RocketMQ架构原理解析（二）：消息存储（CommitLog）
RocketMQ架构原理解析（一）：整体架构 RocketMQ架构原理解析（二）：消息存储（CommitLog） RocketMQ架构原理解析（三）：消息索引（ConsumeQueue & IndexFile） RocketMQ架构原理解析（四）：消息生产端（Producer） 一、概述 ...
RocketMQ(七)：高性能探秘之MappedFile
RocketMQ作为消息中间件，经常会被用来和其他消息中间件做比较，比对rabbitmq, kafka... 但个人觉得它一直对标的，都是kafka。因为它们面对的场景往往都是超高并发，超高性能要求的场景。 所以，有必要深挖下其实现高性能，高并发的原因。实际上，这是非常大的话题 ...
RocketMQ学习笔记（11）----RocketMQ的PushConsumer和PullConsumer
1. PushConsumer 推，Broker主动向Consumer推消息，它Consumer的一种，应用通常向对象注册一个Listener接口，一旦接收到消息，Consumer对象立刻回调Linstener接口方法。Push方式里,consumer把轮询过程封装了,并注册 ...
RocketMQ学习笔记（11）----RocketMQ的PushConsumer和PullConsumer
1. PushConsumer 推，Broker主动向Consumer推消息，它Consumer的一种，应用通常向对象注册一个Listener接口，一旦接收到消息，Consumer对象立刻回调Linstener接口方法。Push方式里,consumer把轮询过程封装了,并注册 ...
rocketMQ(八) rocketMQ 消息队列Offset和CommitLog
一：消息偏移量Offset 1. 什么是offset message queue是无限长的数组，一条消息进来下标就会涨1，下标就是offset，消息在某个MessageQueue里的位置，通 ...
RocketMQ(八)：高性能探秘之线程池
上一篇文章讲了如何设计和实现高并发高性能的应用，从根本上说明了一些道理。且以rocketmq的mappedFile的实现作为一个突破点，讲解了rocketmq是如何具体实现高性能的。从中我们也知道，mappedFile只是其利用的操作系统的一个特性小点。 今天，我们就来说说，rockmq ...
如何实现高性能的IO及其原理？
程序运行在内存以及IO的体现 首先普及一下常识，如图所示： 1、在整个内存空间中，跑着各种各样的程序，有Java程序、C程序，他们共用一块内存空间。 2 ...