转载自：
Elasticsearch有两个主要的作用：
Elasticsearch是一个分布式的使用REST接口的的搜索引擎。它目前被广泛地使用于各个IT公司。Elasticsearch是由Elastic公司创建并开源维护的。它的开源代码位于https://github.com/elastic/elasticsearch。
维基百科、Stack Overflow、Github 都采用Elasticsearch。
Elasticsearch是ELK协议栈的核心。
ELK协议栈：
Elastic公司也拥有Logstash及Kibana开源项目。这个三个开源项目组合在一起，就形成了 ELK软件栈。他们三个共同形成了一个强大的生态圈。简单地说，Logstash负责数据的采集，处理（丰富数据，数据转型等），Kibana负责数据展示，分析及管理。Elasticsearch处于最核心的位置，它可以帮我们对数据进行快速地搜索及分析。
群集是一个或多个节点（服务器）的集合， 这些节点共同保存整个数据，并在所有节点上提供联合索引和搜索功能。一个集群由一个唯一集群ID确定，并指定一个集群名（默认为“elasticsearch”）。该集群名非常重要，因为节点可以通过这个集群名加入群集，一个节点只能是群集的一部分。
确保在不同的环境中不要使用相同的群集名称，否则可能会导致连接错误的群集节点。例如，你可以使用logging-dev、logging-stage、logging-prod分别为开发、阶段产品、生产集群做记录。
节点是单个服务器实例，它是群集的一部分，可以存储数据，并参与群集的索引和搜索功能。就像一个集群，节点的名称默认为一个随机的通用唯一标识符（UUID），确定在启动时分配给该节点。如果不希望默认，可以定义任何节点名。这个名字对管理很重要，目的是要确定你的网络服务器对应于你的ElasticSearch群集节点。
我们可以通过群集名配置节点以连接特定的群集。默认情况下，每个节点设置加入名为“elasticSearch”的集群。这意味着如果你启动多个节点在网络上，假设他们能发现彼此都会自动形成和加入一个名为“elasticsearch”的集群。
在单个群集中，你可以拥有尽可能多的节点。此外，如果“elasticsearch”在同一个网络中，没有其他节点正在运行，从单个节点的默认情况下会形成一个新的单节点名为”elasticsearch”的集群。
索引是具有相似特性的文档集合。例如，可以为客户数据提供索引，为产品目录建立另一个索引，以及为订单数据建立另一个索引。索引由名称（必须全部为小写）标识，该名称用于在对其中的文档执行索引、搜索、更新和删除操作时引用索引。在单个群集中，你可以定义尽可能多的索引。
在索引中，可以定义一个或多个类型。类型是索引的逻辑类别/分区，其语义完全取决于你。一般来说，类型定义为具有公共字段集的文档。例如，假设你运行一个博客平台，并将所有数据存储在一个索引中。在这个索引中，你可以为用户数据定义一种类型，为博客数据定义另一种类型，以及为注释数据定义另一类型。
文档是可以被索引的信息的基本单位。例如，你可以为单个客户提供一个文档，单个产品提供另一个文档，以及单个订单提供另一个文档。本文件的表示形式为JSON（JavaScript Object Notation）格式，这是一种非常普遍的互联网数据交换格式。
在索引/类型中，你可以存储尽可能多的文档。请注意，尽管文档物理驻留在索引中，文档实际上必须索引或分配到索引中的类型。
这里的分片和副本的概念与kafka一样。
索引可以存储大量的数据，这些数据可能超过单个节点的硬件限制。例如，十亿个文件占用磁盘空间1TB的单指标可能不适合对单个节点的磁盘或可能太慢服务仅从单个节点的搜索请求。
为了解决这一问题，Elasticsearch提供细分你的指标分成多个块称为分片的能力。当你创建一个索引，你可以简单地定义你想要的分片数量。每个分片本身是一个全功能的、独立的“指数”，可以托管在集群中的任何节点。
Shards分片的重要性主要体现在以下两个特征：
在同一个集群网络或云环境上，故障是任何时候都会出现的，拥有一个故障转移机制以防分片和节点因为某些原因离线或消失是非常有用的，并且被强烈推荐。为此，Elasticsearch允许你创建一个或多个拷贝，你的索引分片进入所谓的副本或称作复制品的分片，简称Replicas。
Replicas的重要性主要体现在以下两个特征：
| ES概念 | 关系型数据库 |
|---|---|
| Index（索引）支持全文检索 | Database（数据库） |
| Type（类型） | Table（表） |
| Document（文档），不同文档可以有不同的字段集合 | Row（数据行） |
| Field（字段） | Column（数据列） |
| Mapping（映射） | Schema（模式） |
对于ES的访问一般有两种方式
- 使用 Restful API
- 使用postman图形工具
ES Restful API GET、POST、PUT、DELETE、HEAD含义：
1）GET：获取请求对象的当前状态。
2）POST：改变对象的当前状态。
3）PUT：创建一个对象。
4）DELETE：销毁对象。
5）HEAD：请求获取对象的基础信息。
在数据库中的增insert、删delete、改update、查search操作等价于ES中的增PUT/POST、删Delete、改_update、查GET.
以下示例使用curl演示。
curl -X GET 127.0.0.1:9200/_cat/health?v
输出：
curl -X GET 127.0.0.1:9200/_cat/indices?v
输出：
curl -X PUT 127.0.0.1:9200/www
输出：
{"acknowledged":true,"shards_acknowledged":true,"index":"www"}
curl -X DELETE 127.0.0.1:9200/www
输出：
{"acknowledged":true}
curl -H "ContentType:application/json" -X POST 127.0.0.1:9200/loves/go -d ‘
{
"name": "jiumengzi",
"age": 90,
"married": true
}‘
输出：
{
"_index": "love",
"_type": "go",
"_id": "qRuFLXIBV96XnvH_st_R",
"_version": 1,
"result": "created",
"_shards": {
"total": 2,
"successful": 1,
"failed": 0
},
"_seq_no": 0,
"_primary_term": 1
}
也可以使用PUT方法，但是需要传入id
curl -H "ContentType:application/json" -X PUT 127.0.0.1:9200/loves/go/4 -d ‘
{
"name": "sanlaizi",
"age": 90,
"married": false
}‘
Elasticsearch的检索语法比较特别，使用GET方法携带JSON格式的查询条件。
全检索：
curl -X GET 127.0.0.1:9200/loves/go/_search
输出：
{
"took": 137,
"timed_out": false,
"_shards": {
"total": 1,
"successful": 1,
"skipped": 0,
"failed": 0
},
"hits": {
"total": {
"value": 2,
"relation": "eq"
},
"max_score": 1.0,
"hits": [
{
"_index": "loves",
"_type": "go",
"_id": "qBt5LXIBV96XnvH_Xd-g",
"_score": 1.0,
"_source": {
"name": "sanlaizi",
"age": 90,
"married": false
}
},
{
"_index": "loves",
"_type": "go",
"_id": "4",
"_score": 1.0,
"_source": {
"name": "sanlaizi",
"age": 90,
"married": false
}
}
]
}
}
按条件检索：
curl -H "ContentType:application/json" -X PUT 127.0.0.1:9200/loves/go -d ‘
{
"query":{
"match": {"name": "jiumengzi"}
}
}‘
ElasticSearch默认一次最多返回10条结果，可以像下面的示例通过size字段来设置返回结果的数目。
curl -H "ContentType:application/json" -X PUT 127.0.0.1:9200/user/person/4 -d ‘
{
"query":{
"match": {"name": "sb"},
"size": 2
}
}‘
我们使用第三方库https://github.com/olivere/elastic来连接ES并进行操作。
注意下载与你的ES相同版本的client，例如我们这里使用的ES是7.2.1的版本，那么我们下载的client也要与之对应为github.com/olivere/elastic/v7。
使用go.mod来管理依赖：
require (
github.com/olivere/elastic/v7 v7.0.4
)
简单示例：
package main
import (
"context"
"fmt"
"github.com/olivere/elastic/v7"
)
// Elasticsearch demo
type Student struct {
Name string `json:"name"`
Age int `json:"age"`
Married bool `json:"married"`
}
func main() {
client, err := elastic.NewClient(elastic.SetURL("http://127.0.0.1:9200"))
if err != nil {
// Handle error
panic(err)
}
fmt.Println("connect to es success")
p1 := Student{Name: "xxx", Age: 22, Married: false}
put1, err := client.Index().Index("love").BodyJson(p1).Do(context.Background())
if err != nil {
// Handle error
panic(err)
}
fmt.Printf("Indexed user %s to index %s, type %s\n", put1.Id, put1.Index, put1.Type)
}
调试：
推荐阅读：
原文：https://www.cnblogs.com/wind-zhou/p/12920451.html