Elasticsearch 入门（三）使用Elasticsearch.Net & NEST作为elasticsearch客户端

Elasticsearch 入门（三）使用Elasticsearch.Net & NEST作为elasticsearch客户端

GitHub仓库

• https://github.com/elastic/elasticsearch-net
• 选择 Elasticsearch.Net 作为客户端
• 连接方式

var node = new Uri("http://myserver:9200");
var config = new ConnectionConfiguration(node);
var client = new ElasticLowLevelClient(config);

var myJson = @"{ ""hello"" : ""world"" }";
client.Index<StringResponse>("myindex", "1", myJson);
var myJson = new { hello = "world" };
client.Index<BytesResponse>("myindex", "1", PostData.Serializable(myJson));

Elasticsearch.Net 封装

• 新建 ElasticSearchClient类

    public class ElasticSearchClient
    {
        public ElasticLowLevelClient Client { get; }

        private readonly IConfiguration _configuration;

        public ElasticSearchClient(IConfiguration configuration)
        {
            _configuration = configuration;
            Client = InitClient();
        }

        #region Methods
        public async Task<string> Index(string index, string id, PostData body)
        {
            var response = await Client.IndexAsync<StringResponse>(index, id, body);

            ResponseValidate(response);
            return response.Body;
        }

        public async Task<List<string>> SearchWithHighLight(string index, string query)
        {
            var response = await Client.SearchAsync<StringResponse>(
                index,
                PostData.Serializable(new
                {
                    from = 0,
                    size = 100,
                    query = new
                    {
                        match = new
                        {
                            content = query
                        }
                    },
                    highlight = new
                    {
                        pre_tags = new[] { "<tag1>", "<tag2>" },
                        post_tags = new[] { "/<tag1>", "/<tag2>" },
                        fields = new
                        {
                            content = new { }
                        }
                    }
                }));

            ResponseValidate(response);
            var responseJson = (JObject)JsonConvert.DeserializeObject(response.Body);

            var hits = responseJson["hits"]["hits"] as JArray;

            var result = new List<string>();

            foreach (var hit in hits)
            {
                var id = hit["_id"].ToObject<string>();

                result.Add(id);
            }

            return result;
        }

        public async Task Delete(string index, string id)
        {
            var response = await Client.DeleteAsync<StringResponse>(index, id);

            ResponseValidate(response);
        }
        #endregion

        #region privates
        private ElasticLowLevelClient InitClient()
        {
            var node = new Uri(_configuration.GetConnectionString("ElasticSearch"));
            var settings = new ConnectionConfiguration(node);
            var client = new ElasticLowLevelClient(settings);

            return client;
        }

        private void ResponseValidate(StringResponse response)
        {
            if (response.Success == false)
            {
                throw new ResultException(response.Body);
            }
        }

        #endregion

    }

• 依赖注入 Startup.csservices.AddScoped<ElasticSearchClient>();
• 使用

private readonly ElasticSearchClient _elasticSearchClient;
await _elasticSearchClient.Index(Article.EsIndex, article.ArticleUID,PostData.Serializable(article));