HBase在阿里搜索中的应用实践

李钰，花名绝顶，WOTA全球架构与运维技术峰会分享嘉宾，现任阿里巴巴搜索事业部高级技术专家，HBase开源社区PMC &   committer。开源技术爱好者，主要关注分布式系统设计、大数据基础平台建设等领域。连续3年基于HBase/HDFS设计和开发存储系统应对双十一访问压力，具有丰富的大规模集群生产实战经验。

HBase做为淘宝全网索引构建以及在线机器学习平台的核心存储系统，是阿里搜索基础架构的重要组成部分。本文咱们将介绍HBase在阿里搜索的历史、规模，应用的场景以及在实际应用当中遇到的问题和优化。

HBase在阿里搜索的历史、规模和服务能力

历史：阿里搜索于2010年开始使用HBase，从最先到目前已经有十余个版本。目前使用的版本是在社区版本的基础上通过大量优化而成。社区版本建议不要使用1.1.2版本，有较严重的性能问题， 1.1.3之后的版本体验会好不少。

集群规模：目前，仅在阿里搜索节点数就超过3000个，最大集群超过1500个。阿里集团节点数远远超过这个数量。

服务能力：去年双十一，阿里搜索离线集群的吞吐峰值一秒钟访问超过4000万次，单机一秒钟吞吐峰值达到10万次。还有在CPU使用量超过70%的状况下，单cpu core还可支撑 8000+ QPS。

HBase在阿里搜索的角色和主要应用场景

角色：HBase是阿里搜索的核心存储系统，它和计算引擎紧密结合，主要服务搜索和推荐的业务。

HBase在搜索和推荐的应用流程

如上图，是HBase在搜索和推荐的应用流程。在索引构建流程中会从线上MySQL等数据库中存储的商品和用户产生的全部线上数据经过流式的方式导入到HBaes中，并提供给搜索引擎构建索引。在推荐流程中，机器学习平台Porshe会将模型和特征数据存储在HBase里，并将用户点击数据实时的存入HBase，经过在线training更新模型，提升线上推荐的准确度和效果。

应用场景一：索引构建。淘宝和天猫有各类各样的的线上数据源，这取决于淘宝有很是多不一样的线上店铺和各类用户访问。

索引构建应用场景

如上图，在夜间咱们会将数据从HBase批量导出，供给搜索引擎来构建全量索引。而在白天，线上商品、用户信息等都在不停的变化，这些动态的变化数据也会从线上存储实时的更新到HBase并触发增量索引构建，进而保证搜索结果的实时性。

目前，能够作到端到端的延时控制在秒级，即库存变化，产品上架等信息在服务端更新后，迅速的可在用户终端搜索到。

索引构建应用场景抽象图

如上图，整个索引构建过程能够抽象成一个持续更新的流程。如把全量和增量看作是一个Join，线上有不一样的数据源且实时处于更新状态，整个过程是长期持续的过程。这里，就凸显出HBase和流式计算引擎相结合的特色。

应用场景二：机器学习。这里举一个简单的机器学习示例：用户想买一款三千元的手机，因而在淘宝按照三千元的条件筛选下来，可是没有中意的。以后   ，用户会从头搜索，这时就会利用机器学习模型把三千块钱左右的手机排在搜索结果的靠前位置，也就是用前一个搜索结果来影响后一个搜索结果的排序。

分析线上日志

如上图，分析线上日志，归结为商品和用户两个纬度，导入分布式、持久化消息队列，存放到HBase上。随线上用户的点击行为日志来产生数据更新，对应模型随之更新，进行机器学习训练，这是一个反复迭代的过程。

HBase在阿里搜索应用中遇到的问题和优化

HBase架构分层。在说问题和优化以前，先来看HBase的架构图，大体分为以下几个部分：

HBase的架构图

首先是API，一些应用程序编程接口。RPC，这里把远程过程调用协议分为客户端会发起访问与服务端来处理访问两部分。MTTR故障恢复、Replication数据复制、表处理等，这些都是分布式管理的范畴。中间Core是核心的数据处理流程部分，像写入、查询等，最底层是HDFS（分布式文件系统）。HBase在阿里搜索应用中遇到的问题和优化有不少，下面挑选近期比较重点的RPC的瓶颈和优化、异步与吞吐、GC与毛刺、IO隔离与优化、IO利用这五方面进行展开。

问题与优化一：RPC的瓶颈和优化

RPC Server线程模型

PPC服务端的实际问题是原有RpcServer线程模型效率较低，如上图，能够看到整个过程一般很快，但会由不一样的线程来处理，效率很是低。基于Netty重写以后，能够更高效的复用线程，实现HBase  RpcServer。使得RPC平均响应时间从0.92ms降低到0.25ms，吞吐能力提升接近2倍。

问题与优化二：异步与吞吐

RPC的客户端存在的实际问题是流式计算对于实时性的要求很高、分布式系统没法避免秒级毛刺、同步模式对毛刺敏感，吞吐存在瓶颈。优化手段就是基于netty实现non-blocking  client，基于protobuf的non-blocking   Stub/RpcCallback实现callback回调，当和flink集成后实测吞吐较同步模式提升2倍。

问题与优化三： GC与毛刺

如上图，这部分的实际问题是PCIe-SSD的高IO吞吐能力下，读cache的换入换出速率大幅提升、堆上的cache内存回收不及时，致使频繁的CMS  gc甚至fullGC。优化手段是实现读路径E2E的offheap，使得Full和CMS gc频率下降200%以上、读吞吐提升20%以上。

如上图，是线上的一个结果，QPS以前是17.86M，优化以后是25.31M。

问题与优化四： IO隔离与优化

HBase自己对IO很是敏感，磁盘打满会形成大量毛刺。在计算存储混合部署环境下，MapReduce做业产生的shuffle数据和HBase自身Flush/Compaction这两方面都是大IO来源。

如何规避这些影响呢？利用HDFS的Heterogeneous   Storage功能，对WAL(write-ahead-log)和重要业务表的HFile使用ALL_SSD策略、普通业务表的HFile使用ONE_SSD策略，保证Bulkload支持指定storage  policy。同时，确保MR临时数据目录(mapreduce.cluster.local.dir)只使用SATA盘。

HBase集群IO隔离后的毛刺优化效果

对于HBase自身的IO带来的影响，采用Compaction限流、Flush限流和Per-CF flush三大手段。上图为线上效果，绿线从左到右分别是响应时间、处理时间和等待时间的p999数据，以响应时间为例，99.9%的请求不会超过250ms。

问题与优化五： IO利用

HDFS写3份副本、通用机型有12块HDD盘、SSD的IO能力远超HDD。如上图，实际问题是单WAL没法充分使用磁盘IO。

如上图，为了充分利用IO，咱们能够经过合理映射对region进行分组，来实现多WAL。基于Namespace的WAL分组，支持App间IO隔离。从上线效果来看，全HDD盘下写吞吐提升20%，全SSD盘下写吞吐提升40%。线上写入平均响应延时从0.5ms降低到0.3ms。

开源&将来

为何要拥抱开源？其一，试想若是你们作了优化都不拿出来，认为这是本身强于别人的优点，结果会怎样？若是你们把本身的优点都拿出来分享，获得的会是正向的反馈。其二，   HBase的团队通常都比较小，人员流失会产生很大的损失。如把内容贡献给社区，代码的维护成本能够大大下降。开源一块儿作，比一个公司一我的作要好不少，因此咱们要有贡献精神。

将来，一方面，阿里搜索会进一步把PPC服务端也作异步，把HBase内核用在流式计算、为HBase提供嵌入式的模式。另外一方面，尝试更换HBase内核，用新的DB来替代，达到更高的性能。

以上内容根据绝顶老师在WOTA2017 “大数据系统架构”专场的演讲内容整理。