elasticsearch-是一个比较好的搜索服务器,用于做数据搜索和数据分析都比较适用
elasticsearch安装和启动：
(1)、安装docker运行环境;
(2)、下载elasticsearch的docker镜像，docker pull docker.elastic.co/elasticsearch/elasticsearch:7.1.1;
(3)、启动elasticsearch服务,docker run -itd -p 9200:9200 -p 9300:9300 -e "discovery.type=single-node" docker.elastic.co/elasticsearch/elasticsearch:7.1.1;
(4)、访问http://127.0.0.1:9200/ 地址查看elasticsearch是否启动成功;
(5)、测试环境目前安装的是单机版本。
elasticsearch的golang sdk 下载和试例代码:
(1)、到github.com上下载elasticsearch客户端代码,github.com/olivere/elastic
（2)、选择与elasticsearch版本对应的客户端版本，当前elasticsearch版本为 7.1.1,对应的sdk版本为 github.com/olivere/elastic/v7
（3）、连接es服务器写入一个文档数据，然后在查询数据，测试代码如下:
package main
import (
"context"
"fmt"
es "github.com/olivere/elastic/v7"
)
func main() {
addr := []string{"http://127.0.0.1:9200"}
cli :=es.SetURL(addr...)
client, err :=es.NewClient(es.SetSniff(false), cli)
if err !=nil {
panic(err)
}
_, _, err = client.Ping(addr[0]).Do(context.Background())
if err !=nil {
panic(err)
}
name :="test"
data :=make(map[string]interface{})
data["name"] ="zhu"
data["age"] =30
data["date"] ="1989-10-14"
_, err = client.Index().Index(name).Id(fmt.Sprint(1)).BodyJson(data).Do(context.Background())
if err !=nil {
fmt.Println("write err:", err)
}else {
fmt.Println("write ok")
}
get, err := client.Get().Index(name).Id("1").Do(context.Background())
if err !=nil {
fmt.Println("query err:", err)
}else {
fmt.Println(fmt.Sprintf("query ok,id:%s,data:%s", get.Id, string(get.Source)))
}
}
