ElasticSearchClientServiceImpl

嗅探（Sniffing）

Elasticsearch Sniffer 可用于定位你所连接的集群中的 Elasticsearch 节点。 如果集群会随时间动态变化（例如为应对高负载而新增节点以维持性能）， 这会很有帮助。

嗅探还可以在运行期间遇到连接失败时更新集群中的主机列表。要启用 "Sniff on Failure"，必须同时启用 "Sniff Cluster Nodes"。

并非所有情况都适合使用嗅探，例如：

• Elasticsearch 位于负载均衡器之后，由它动态路由来自 Lynxus 的连接
• Elasticsearch 与 Lynxus 位于不同网络

有时可能还需要设置一些 Elasticsearch 网络高级设置， 例如 network.publish_host，以确保 Sniffer 发现的 HTTP 主机可被 Lynxus 访问。例如，Elasticsearch 可能使用了内网的 publish_host， Lynxus 无法访问，此时应改用 Lynxus 能理解的地址/IP。可能还需要把 同样的地址加入 Elasticsearch 的 network.bind_host 列表。

更多最佳实践参见 Elasticsearch sniffing best practices: What, when, why, how。

资源使用注意事项

该 Elasticsearch 客户端依赖使用 Apache HTTP Async Client 的 RestClient。默认情况下，它会启动一个调度线程，以及连接管理器使用的 若干工作线程。工作线程的数量等于 Lynxus 主机上本地检测到的处理器/ 核心数。因此，强烈建议每个远程 Elasticsearch 目标只创建一个该 Controller Service 实例，并让该 Controller Service 在流程中的所有 Elasticsearch Processor 之间共享。实例数量过多可能导致资源耗尽， 引发 OOM 错误。