所以最终我们的数据中心存储架构采用的是 HBase+Elasticsearch 作为核心架构。
也就是说，基于 HBase 把数据以 kv 的格式分布式的存储在多台服务器上，写入的时候是 kv 格式，读取的时候也是 kv 格式，key 就是数据的主键 id，value 就是一行完整的数据。
同时会为各个查询接口的查询条件，把要查询的字段值写入 ES 里建立查询索引，让查询接口可以基于 ES 中的索引先搜索数据主键 id，然后根据数据主键 id 去 HBase 里查询完整的一行数据。
一个是 Hbase 和 ES 之间的一致性问题如何保证，也就是说，万一写入 Hbase 成功了，结果写入 ES 失败了，此时应该怎么办？
这个时候其实应该设计一个补偿机制，也就是说，写入 Hbase 成功，而写入 ES 失败的时候，需要发一个补偿消息到 MQ 里去，然后下次再重试做一个写入，实现最终一致性的效果。