pagecache 里面不可避免会有锁的问题，在并发的读写操作情况下，会出现缺页中断 降低，内存加锁，污染页的回写。 第二种，DirectByteBuffer(堆外内存)+PageCache 的两层架构方式，这样子可以实 现读写消息分离，写入消息时候写到的是 DirectByteBuffer——堆外内存中,读消息走的是 PageCache(对于,DirectByteBuffer 是两步刷盘，一步是刷到 消息追加是否会超过 500 ms。 在这个图中我们看到在设置了 transientStorePoolEnable 为 true 的情况下，虽然 一天只有一条超过 500ms 的消息，但也值得警惕了，由于对系统内核参数掌握程度不够， 这种情况，估计只能走集群扩容的路子了。但如果一天消息量巨大而且出现频率不高的情况， 由于有重试机制，倒不会带来太大的问题。如果出现太多的错误，建议集群扩容。 本文接下来想重点探讨一下

Middleware Group 阿里消息中间件演变历史 2016 2007 2010 2011 2012 2015 Notify 五彩石项目 交易核心消息流转 Napoli ActiveMQ内核 B2B大规模使用 MetaQ v1.0 顺序消息 海量堆积能力 Aliware MQ v1.0 Notify v3.0 MetaQ v3.0 RocketMQ开源 Apache RocketMQ watermark low reclaim kswapd wakeup allocate extra free_kbytes 1.4万亿 低延迟分布式存储系统 – PageCache的毛刺内核源码分析 Entity Inode i_mapping i_data address_space radix_tree_root nrpages writeback_index inode(host) try_to_unmap_one remove_from_page_cache add_to_page_cache_locked 自旋锁- treelock 1.4万亿 低延迟分布式存储系统 – PageCache的毛刺内核源码分析 lMemory access latency issues: ØMemory lock ØWake_up_page ØWait_on_page_locked() ØWait_on_page_writebacfk()

Middleware Group 阿里消息中间件演变历史 2016 2007 2010 2011 2012 2015 Notify 五彩石项目 交易核心消息流转 Napoli ActiveMQ内核 B2B大规模使用 MetaQ v1.0 顺序消息 海量堆积能力 Aliware MQ v1.0 Notify v3.0 MetaQ v3.0 RocketMQ开源 Apache RocketMQ watermark low reclaim kswapd wakeup allocate extra free_kbytes 1.4万亿 低延迟分布式存储系统 – PageCache的毛刺内核源码分析 Entity Inode i_mapping i_data address_space radix_tree_root nrpages writeback_index inode(host) try_to_unmap_one remove_from_page_cache add_to_page_cache_locked 自旋锁- treelock 1.4万亿 低延迟分布式存储系统 – PageCache的毛刺内核源码分析 lMemory access latency issues: ØMemory lock ØWake_up_page ØWait_on_page_locked() ØWait_on_page_writebacfk()

.............................................................................. 48 第五章 Remoting 通信层： .................................................................................................. .......................................................................................... 54 五：通信层的整体交互 .............................................................................................. commitOffsetValue //TODO 这个值跟 pullRequest.getNextOffset 区别 8. 构建 sysFlag pull 接口用到的 flag 9. 调底层通信层向 broker 发送拉消息请求 如果 master 压力过大，会建议去 slave 拉取消息 如果是到 broker 拉取消息清楚实时提交标记位，因为 slave 不允许实时提交消费进 度，可以定时提交

RocketMQ支持按照时间来回溯消息，精度毫秒，例如从一天之前的某时某分某秒开始重新消费消 原文链接：Apache RocketMQ 介绍 。 其他消息中间件 RabbitMQ是AMQP规范的参考实现，AMQP是一个线路层协议，面面俱到，很系统，也稍显复杂。 前RabbitMQ已经成为OpenStack Iaas平台首选的消息服务，其背后的支持力度不言而喻。 ActiveMQ最初主要的开发者在LogicBlaze，现

A l i b a b a M i d d l e w a r e G r o u p 01 Architecture and Features …… 合抱之木生于毫末；九层之台起于累土；千里之行始于足下…… © 2 0 1 7 A l i b a b a M i d d l e w a r e G r o u p © 2 0 1 7 A l i b a b

客户端实例名称，客户端创建的多个 Producer、 Consumer 实际是共用一个内部实例（这个实例包含 网络连接、线程资源等） clientCallbackExecutorThreads 4 通信层异步回调线程数 pollNameServerInteval 30000 轮询 Name Server 间隔时间，单位毫秒 项目开源主页：https://github.com/alibaba/RocketMQ