ElasticSearch 事件监听器

Question

我的目标是仅通过利用 Elasticsearch 来构建类似MQTT 发布/订阅的服务。

我想要实现的案例研究场景是这样的：

1. 用户 A在 Elasticsearch 索引内创建消息（文档）
2. 用户 B会收到关于索引上新消息的警告和更新。

我使用普通的 java 客户端，因为在 Android 中我无法使用高级弹性搜索客户端。我拥有允许我从 ES 索引发送和读取文档的一切，但我想找到为用户 B 实现订阅服务的最佳方法，而不强迫他每隔几秒轮询一次更新。

关于这个我不知道从哪里开始。我没有在 ES 中找到任何可用的触发器/websocket 服务。请帮助提供一些想法/文档。

Answer 1

您可以使用 Elastic Search Watcher在满足特定条件时触发操作。一个示例用例是，如果您在 Elastic Search 实例中从 Meetup.com 获取实时数据，并希望接收有关您可能感兴趣的事件的电子邮件通知。

对于您的特定用例，您可以创建一个监视，当用户 A 在索引中添加文档时触发。监视操作可以是向用户 B 发送电子邮件或调用您自己的 API 负责通知已订阅用户 A 的所有用户（请参阅Webhook 操作）。

我自己还没有尝试过，但这似乎是一个很好的起点。