.Net Api 中使用Elasticsearch存储文档的方法

 /// 
 /// ES配置类 /// 
 public class EsConfig { /// 
 /// 账号 /// 
 public string username { get; set; } /// 
 /// 密码 /// 
 public string password { get; set; } /// 
 /// ES地址 /// 
 public string url { get; set; } }

 /// 
 /// ES客户端 /// 
 public interface IElasticsearchClient { /// 
 /// 获取ElasticClient /// 
 ///  ElasticClient GetClient(); /// 
 /// 指定index获取ElasticClient /// 
 ///  ///  ElasticClient GetClient(string indexName); }

/// 
 /// ES客户端 /// 
 public class ElasticsearchClient : IElasticsearchClient { public EsConfig _EsConfig; /// 
 /// 构造函数 /// 
 ///  public ElasticsearchClient(IOptions esConfig) { _EsConfig = esConfig.Value; } /// 
 /// 获取elastic client /// 
 ///  public ElasticClient GetClient() { if (_EsConfig == null || _EsConfig.url == null || _EsConfig.url == "") { throw new Exception("urls can not be null"); } return GetClient(_EsConfig.url, ""); } /// 
 /// 指定index获取ElasticClient /// 
 ///  ///  public ElasticClient GetClient(string indexName) { if (_EsConfig == null || _EsConfig.url == null || _EsConfig.url == "") { throw new Exception("urls can not be null"); } return GetClient(_EsConfig.url, indexName); } /// 
 /// 根据url获取ElasticClient /// 
 ///  ///  ///  private ElasticClient GetClient(string url, string defaultIndex = "") { if (string.IsNullOrWhiteSpace(url)) { throw new Exception("urls can not be null"); } var uri = new Uri(url); var connectionSetting = new ConnectionSettings(uri); if (!string.IsNullOrWhiteSpace(url)) { connectionSetting.DefaultIndex(defaultIndex); } connectionSetting.BasicAuthentication(_EsConfig.username, _EsConfig.password); //设置账号密码 return new ElasticClient(connectionSetting); } /// 
 /// 根据urls获取ElasticClient /// 
 ///  ///  ///  private ElasticClient GetClient(string[] urls, string defaultIndex = "") { if (urls == null || urls.Length <1) { throw new Exception("urls can not be null"); } var uris = urls.Select(p => new Uri(p)).ToArray(); var connectionPool = new SniffingConnectionPool(uris); var connectionSetting = new ConnectionSettings(connectionPool); if (!string.IsNullOrWhiteSpace(defaultIndex)) { connectionSetting.DefaultIndex(defaultIndex); } return new ElasticClient(connectionSetting); } } 

services.Configure(Configuration.GetSection("EsConfig"));

 /// 
 /// ElasticClient 扩展类 /// 
 public static class ElasticClientExtension { /// 
 /// 创建索引 /// 
 ///  ///  ///  ///  ///  ///  public static bool CreateIndex(this ElasticClient elasticClient, string indexName = "", int numberOfShards = 10, int numberOfReplicas = 1) where T : class { if (string.IsNullOrWhiteSpace(indexName)) { indexName = typeof(T).Name; } if (elasticClient.Indices.Exists(indexName).Exists) { return false; } else { var indexState = new IndexState() { Settings = new IndexSettings() { NumberOfReplicas = numberOfReplicas, NumberOfShards = numberOfShards, }, }; var response = elasticClient.Indices.Create(indexName, p => p.InitializeUsing(indexState).Map(p => p.AutoMap())); return response.Acknowledged; } } }

  public class XXX { public int xid { get; set; } [Text(Name = "xml")] public string xml { get; set; } }

  public class ElaticSearchBase { private IElasticsearchClient _client; public ElaticSearchBase(IElasticsearchClient client) { _client = client; } /// 
 /// XXX文档索引 /// 
 public ElasticClient Client_XXX => GetXXX(); private ElasticClient GetXXX() { //如果数据库中存在xxx则直接连接，如果不存在则新建后连接 var client = _client.GetClient("XXX"); if (!client.Indices.Exists("XXX").Exists) { client.CreateIndex("XXX"); } return client; } } 

private ElaticSearchBase _es = new ElaticSearchBase(_client); //实例化对象 var xxx1 = new XXX(){tempid = 1,xml = "xmlstring"}; //存储xxx1 var res =_es.Client_XXX.IndexDocument(xxx1); //获得Es主键 var esid = res.Id;

var res = _es.Client_XXX.Get(esid);

var res = _es.Client_XXX.Delete(esid) 

//实例化对象 var xxx2 = new XXX(){tempid = 2,xml = "xmlstring2"}; var upRes= _es.Client_XXX.Update(ex.xmlid, upt => upt.Doc(xxx2));