开箱即用的 GoWind Admin｜风行，企业级前后端一体中后台框架：支持ElasticSearch

ElasticSearch（简称 ES）是一款开源的分布式全文搜索引擎，同时也是一个基于 Lucene 的实时分布式存储、搜索和分析引擎。它由Elastic 公司开发，主要用于解决海量数据的实时检索、分析和存储问题，具有高性能、高可用、易扩展等特点，广泛应用于日志分析、全文检索、业务监控等场景。

ElasticSearch 的核心概念

ElasticSearch 与关系型数据库的差异

docker pull bitnami/elasticsearch:latest

docker run -itd \
    --name elasticsearch \
    -p 9200:9200 \
    -p 9300:9300 \
    -e ELASTICSEARCH_USERNAME=elastic \
    -e ELASTICSEARCH_PASSWORD=elastic \
    -e ELASTICSEARCH_NODE_NAME=elasticsearch-node-1 \
    -e ELASTICSEARCH_CLUSTER_NAME=elasticsearch-cluster \
    bitnami/elasticsearch:latest

在 Go Wind Admin 中使用 ElasticSearch

我把ElasticSearch的SDK封装了起来，并且提供了配置文件的支持，使用起来非常简单。

首先，我们需要安装库：

go get github.com/tx7do/kratos-bootstrap/database/elasticsearch

接着在数据库的配置文件data.yaml中添加ElasticSearch的配置：

data:
  elastic_search:
    addresses:
      - "http://localhost:9200"
    username: "elastic"
    password: "elastic"

现在，我们开始创建客户端：

package data

import (
    "github.com/tx7do/kratos-bootstrap/database/elasticsearch"
)

func NewElasticSearchClient(logger log.Logger, cfg *conf.Bootstrap) *elasticsearch.Client {
   
    cli, err := elasticsearch.NewClient(logger, cfg)
    if err != nil {
   
        return nil
    }
    return cli
}

在data/init.go注入到wire：

//go:build wireinject
// +build wireinject

package data

import "github.com/google/wire"

var ProviderSet = wire.NewSet(
    NewElasticSearchClient,
)

在这里，我们以股票的K线（蜡烛图）为实例，来讲解如何使用ElasticSearch。

首先，定义模型：

package data

import "time"

type Candle struct {
   
    Timestamp *time.Time `json:"timestamp"`
    Symbol    *string    `json:"symbol"`
    Open      *float64   `json:"open"`
    High      *float64   `json:"high"`
    Low       *float64   `json:"low"`
    Close     *float64   `json:"close" `
    Volume    *float64   `json:"volume"`
}

const CandleMapping = `
{
  "mappings": {
    "properties": {
      "timestamp": {"type": "date"},
      "symbol": {"type": "keyword"},
      "open": {"type": "double"},
      "high": {"type": "double"},
      "low": {"type": "double"},
      "close": {"type": "double"},
      "volume": {"type": "double"}
    }
  }
}`

最后，实现CancleRepo：

package data

import (
    "github.com/go-kratos/kratos/v2/log"
    "github.com/tx7do/kratos-bootstrap/database/elasticsearch"
)

const candleIndex = "candles"

type CandleRepo struct {
   
    client *elasticsearch.Client
    log    *log.Helper
}

func NewCandleRepo(logger log.Logger, client *elasticsearch.Client) *CandleRepo {
   
    repo := &CandleRepo{
   
        log:    log.NewHelper(log.With(logger, "module", "candle/elasticsearch/repo")),
        client: client,
    }

    ctx := context.Background()

    if exists, _ := repo.client.IndexExists(ctx, candleIndex); !exists {
   
        _ = repo.client.CreateIndex(ctx, candleIndex, CandleMapping, "")
    }

    return repo
}

func (r *CandleRepo) Create(ctx context.Context, req *Candle) error {
   
    if req == nil {
   
        return candleV1.ErrorBadRequest("request data is required")
    }

    err := r.client.InsertDocument(ctx, candleIndex, "", req)
    if err != nil {
   
        r.log.Errorf("create candle failed: %s", err.Error())
        return candleV1.ErrorInternalServerError("create candle failed")
    }
    return nil
}

项目代码

• go-wind-admin Gitee
• go-wind-admin Github