Netflix最近推出了Hollow，一款Java库和工具包，旨在有效缓存不属于“大数据”的数据集。这些数据集可能是电子商务和搜索引擎的元数据，或者是Netflix电影和电视节目的元数据。处理这种数据集的传统方法包括数据存储或串行化，但这可能会有可靠性和延迟问题。Hollow的入门指南中总结了核心概念和命名方法：
Hollow管理由单个生产者构建的数据集，并向一个或多个消费者传送以用于只读访问。数据集会随着时间而改变。改变的数据集的时间线可以分为离散的数据状态，每个状态都是那个特定时间点数据的完整快照。
生产者和消费者通过在数据状态之间转换的状态引擎来处理数据集。生产者使用写状态引擎，而消费者使用读状态引擎。
Hollow取代了Netflix原先的内存数据集框架Zeno。数据集现在用紧凑的、固定长度的、强类型的数据编码表示。这种编码最小化了数据集占用的空间，并将编码记录“打包在JVM堆上合并的可重用内存条中，以避免影响繁忙的服务器上的GC行为。”
入门
要开始使用Hollow示例，请参考以下POJO：
public class Movie {
long id;
String title;
int releaseYear;
public Movie(long id,String title,int releaseYear) {
this.id = id;
this.title = title;
this.releaseYear = releaseYear;
}
}
上述POJO上简单的数据集可以这样填充：
List<Movie> movies = Arrays.asList(
new Movie(1,"The Matrix",1999),
new Movie(2,"Beasts of No Nation",2015),
new Movie(3,"Goodfellas",1990),
new Movie(4,"Inception",2010)
);
Hollow将这样的movies列表转换为新的编码形式，如下所示：
![]()
有关编码的更多详细信息，请参阅Hollow网站的高级主题章节。
生产者
生产者的第一个示例发布了数据集（本例中的电影）的初始数据状态，并通知消费者在哪里找到该数据集。对数据集的后续更改会系统地发布并传送给消费者。
生产者使用HollowWriteStateEngine作为数据集的句柄：
HollowWriteStateEngine writeEngine = new HollowWriteStateEngine();
HollowObjectMapper填充HollowWriteStateEngine：
HollowObjectMapper objectMapper = new HollowObjectMapper(writeEngine);
for(Movie movie : movies) {
objectMapper.addObject(movie);
}
HollowObjectMapper是线程安全的，也可以并行执行。
生产者将数据集（也称blob）写入定义的输出流：
OutputStream os = new BufferedOutputStream(new FileOutputStream(snapshotFile));
HollowBlobWriter writer = new HollowBlobWriter(writeEngine);
writer.writeSnapshot(os);
为消费者生成API
客户端API基于数据模型生成必要的Java文件，并且必须在写入初始的消费者源代码前执行：
HollowAPIGenerator codeGenerator = new HollowAPIGenerator(
"MovieAPI", // a name for the API
"org.redlich.hollow.consumer.api.generated", // the path for generated API files
stateEngine); // the state engine
codeGenerator.generateFiles(apiCodeFolder);
消费者
一旦通知消费者已发布的数据集，消费者使用HollowWriteReadEngine作为数据集的句柄：
HollowReadStateEngine readEngine = new HollowReadStateEngine();
HollowBlobReader将blob从生产者消费到HollowReadStateEngine：
HollowBlobReader reader = new HollowBlobReader(readEngine);
InputStream is = new BufferedInputStream(new FileInputStream(snapshotFile));
reader.readSnapshot(is);
通过生成的API可以访问到数据集中的数据：
MovieAPI movieAPI = consumer.getAPI();
for(MovieHollow movie : movieAPI.getAllMovieHollow()) {
System.out.println(movie._getId() + ", " +
movie._getTitle()._getValue() + ", " +
movie._getReleaseYear());
}
这将打出结果输出：
1, "The Matrix", 1999
2, "Beasts of No Nation", 2015
3, "Goodfellas", 1990
4,"Inception", 2010
完整的Hollow项目可以在GitHub上找到。
