Go实战全家桶之十二：自研ES微服务goesagent

由于原始代码较长，以下是核心函数的简化示例，展示如何创建一个简单的ES微服务：

package main
 
import (
    "context"
    "fmt"
    "github.com/olivere/elastic/v7"
)
 
// 创建Elasticsearch客户端
func NewElasticClient(addr string) (*elastic.Client, error) {
    client, err := elastic.NewSimpleClient(elastic.SetURL(addr))
    if err != nil {
        return nil, err
    }
    info, _, err := client.Ping(addr).Do(context.Background())
    if err != nil {
        return nil, err
    }
    fmt.Printf("Elasticsearch connection successful, status: %s\n", info.Status)
    return client, nil
}
 
// 创建ES微服务
func main() {
    client, err := NewElasticClient("http://localhost:9200")
    if err != nil {
        panic(err)
    }
    // 使用client进行进一步的操作，例如索引管理、搜索等
}

这个示例展示了如何创建一个Elasticsearch客户端并连接到Elasticsearch服务。在实际应用中，你需要根据具体需求扩展这个客户端，添加更多的功能，比如索引管理、文档CRUD操作、搜索等。