Akka Percolator 使用Akka与Elasticsearch实现Java 8中的实时日志渗透

阿卡渗滤器用法：示例项目，灵感来自Andrew Easter的文章[2]。主要是Akka和Elasticsearch技术的游乐场。这个项目是用Java 8编写的，不包括UI部分和Play框架。首先，在Eclipse中导入项目，运行Main.java类。一百(NUM_QUERIES)个简单的搜索查询被插入到Elasticsearch中，然后通过发送针对查询的虚拟生成的日志条目开始处理。日志条目以5毫秒的间隔生成并针对搜索查询进行过滤。您应该看到匹配日志条目的输出流，如下所示： 907===>{"timestamp":"2014-12-21 17:56:16.362","response time":"907","method":"DELETE","path":"/c","status":"500","device":"TV","

流程：

1. 将项目导入Eclipse并运行Main.java类。

2. 向Elasticsearch中插入100个简单搜索查询。

3. 开始处理生成的虚拟日志条目并进行过滤。

4. 日志条目每5毫秒生成一次，过滤并输出匹配项。