Galosys.Foundation.Elastic 26.5.20.1

Galosys.Foundation.Elastic

成熟度: 🟡 可用 — 功能完整，测试或文档可能不完善

简介

Galosys.Foundation.Elastic 是对 Elasticsearch 8.0 客户端的封装，提供基于 Microsoft.Extensions.DependencyInjection 的依赖注入支持，简化在 .NET 应用中集成 Elasticsearch 的配置和使用。

特性

• 支持 Elasticsearch 8.0 客户端
• 支持单节点和多节点集群配置
• 支持基本认证（用户名/密码）
• 基于 Microsoft.Extensions.DependencyInjection 的依赖注入
• 通过 IOptions 模式进行配置管理
• 支持请求超时配置

安装

dotnet add package Galosys.Foundation.Elastic

配置

1. 添加配置文件

在 appsettings.json 中添加 Elasticsearch 配置：

{
 "Elasticsearch": {
 "Uris": [ "http://localhost:9200" ],
 "UserName": "your-username",
 "Password": "your-password"
 }
}

使用

1. 注册服务

在 Program.cs 或 Startup.cs 中注册 Elasticsearch 服务：

using Microsoft.Extensions.DependencyInjection;

var builder = WebApplication.CreateBuilder(args);

// 添加 Elasticsearch 服务
builder.Services.AddElastic8_0();

var app = builder.Build();

基本操作

索引文档

var product = new Product { Id = "1", Name = "示例产品", Price = 99.99m };
var response = await _client.IndexAsync(product, idx => idx
 .Index("products")
 .Id(product.Id));

获取文档

var response = await _client.GetAsync<Product>("1", g => g.Index("products"));
if (response.IsSuccess)
{
 var product = response.Source;
}

删除文档

var response = await _client.DeleteAsync("products", "1");

搜索

基本搜索

var response = await _client.SearchAsync<Product>(s => s
 .Index("products")
 .Query(q => q
 .Match(m => m
 .Field(f => f.Name)
 .Query("示例")
 )
 )
);

foreach (var product in response.Documents)
{
 Console.WriteLine(product.Name);
}

高级搜索

var response = await _client.SearchAsync<Product>(s => s
 .Index("products")
 .Query(q => q
 .Bool(b => b
 .Must(m => m
 .Match(t => t
 .Field(f => f.Name)
 .Query("示例")
 )
 )
 .Filter(f => f
 .Range(r => r
 .NumberRange(n => n
 .Field(f => f.Price)
 .Gte(50)
 .Lte(200)
 )
 )
 )
 )
 )
 .Size(10)
 .From(0)
 .Sort(so => so
 .Field(f => f.Price, f => f.Order(SortOrder.Asc))
 )
);

核心类

依赖

• elastic.clients.elasticsearch - Elasticsearch 8.0 客户端
• - 核心库

注意事项

1. 请求超时默认设置为 2 分钟
2. 支持单节点和多节点集群自动配置
3. 认证方式支持基本认证（BasicAuthentication）
4. 异常处理：配置错误时会抛出 ArgumentNullException
5. 客户端注册为单例模式，线程安全