ES Client

梦里梦外; 2023-08-17 16:16 122阅读 0赞

关于 ElasticSearch的学习参见：[ELK | wjcx\_sqh][ELK _ wjcx_sqh]  
本文分别学习 .Net | Java 下操作 ES：

# .Net #

目前主流的 .Net 客户端有 2 种：

*  PlainElastic.Net
 *  Elasticsearch.Net.dll 和 Nest.dll

PlainElastic.Net 简单了解即可，具体参见：[https://www.cnblogs.com/eggTwo/p/4039779.html][https_www.cnblogs.com_eggTwo_p_4039779.html]

## Elasticsearch.Net + Nest ##

直接在 [Nuget | 官网][Nuget _] 下载对应的 .nuget包，在项目中引入即可。

*  [Elasticsearch.Net 6.8.0][]
 *  [NEST 6.8.0][]

注意不同版本 .dll 对 .Net Framework 框架的依赖。

### 查询 ###

*  对象方式查询
 *  Fluent API

TermQuery 是整词搜索；MatchQuery 是按分词器分词搜索，可以搭配 from 和 size 从指定位置返回指定条数。  
注意 match 与 match\_phrase 的不同。

Search After  
通过上一页的结果检索下一页，使用search\_after参数时，from的值必须设为0或-1：[search\_after][search_after]

*  from和size：深度分页或size特别大时，会出[deep pagination][]，es自保机制max\_result\_window预设值10000，建议`from + size <= 1万`
 *  scroll：代表某时刻的snapshot，不适合实时查询，scroll后接超时时间，频繁发起scroll请求，也会出现一系列问题

search\_after解决scroll的非实时取值问题，提供live cursor规避消耗存储和时间的性能问题：[search\_after性能][search_after 1]

### 索引 ###

ES的mapping一旦创建不能再次修改，需删除再重新创建

client.Indices.Create(index_name, 
        c => c.Map<MyClassObj>(h => h.AutoMap().Properties(
        ps => ps.Text(s => s.Name(n => n.OneFieldInMyClassObj)
        .Analyzer("ik_max_word").SearchAnalyzer("ik_smart"))
    )));

### 问题解决 ###

问题1：Kibana显示的时间比实际插入ES的时间多8个小时  
原因：NEST的序列化器默认DateTime类型是UTC时区，序列化时丢弃了时区信息，而Kibana设置是东八区  
解决：创建client时传入设置参数

var settings = new ConnectionSettings(pool, 
        sourceSerializer: (builtin, setting) => new JsonNetSerializer(builtin, setting, 
            () => new Newtonsoft.Json.JsonSerializerSettings { 
                DateTimeZoneHandling = Newtonsoft.Json.DateTimeZoneHandling.Local 
    }));

问题2：实现超时自动重试  
解决：通过添加max\_retries和retry\_on\_timeout两个参数

es = Elasticsearch( hosts=[{'host': 'localhost', 'port': 9200}], timeout=60, max_retries=3, retry_on_timeout=True);

### 序列化 ###

ElasticSearch 是 Restful 相关，自然经常用到 json  
推荐学习：[Custom Serialization][]

# Java #

## 原生APi ##

## SpringBoot + Elasticsearch ##

SpringBoot 集成 Elasticsearch，支持 4 种方式

*  REST Client
 *  Jest
 *  Spring Data
 *  Spring Data Elasticsearch Repositories

### Spring Data Elasticsearch ###

Spring Data 子模块套件，支持快速初始化maven项，[官网移步][Link 1]

*  SpringBoot：v
 *  Elasticsearch：v6.8.0

务必保证 SpringBoot 和 Elasticsearch 的版本匹配，[对应关系][Link 2]  
[参考教程][Link 3]

转载于:https://www.cnblogs.com/wjcx-sqh/p/11294683.html

[ELK _ wjcx_sqh]: https://www.cnblogs.com/wjcx-sqh/p/11228371.html
[https_www.cnblogs.com_eggTwo_p_4039779.html]: https://www.cnblogs.com/eggTwo/p/4039779.html
[Nuget _]: https://www.nuget.org/
[Elasticsearch.Net 6.8.0]: https://www.nuget.org/packages/Elasticsearch.Net/6.8.0
[NEST 6.8.0]: https://www.nuget.org/packages/NEST/6.8.0
[search_after]: http://www.piaoyi.org/database/Elasticsearch-Search_After.html
[deep pagination]: http://www.piaoyi.org/database/Elasticsearch-from-size-scroll.html
[search_after 1]: https://blog.csdn.net/zzh920625/article/details/84593590
[Custom Serialization]: https://www.elastic.co/guide/en/elasticsearch/client/net-api/current/custom-serialization.html#custom-serialization
[Link 1]: https://spring.io/projects/spring-data-elasticsearch
[Link 2]: https://github.com/spring-projects/spring-data-elasticsearch/wiki/Spring-Data-Elasticsearch---Spring-Boot---version-matrix
[Link 3]: https://blog.csdn.net/li521wang/article/details/83792552