ES使用分享

官网地址：https://www.elastic.co/

 

安装

最低要求jdk1.7，下载解压就可以了。

配置

配置文件位置：$ES_HOME/config/elasticsearch.yml

虽然es默认配置就能直接用，但是建议修改一下默认配置，如集群名字，分片数，节点名，数据存放位置，日志存放位置。

启动

$ES_HOME/bin/elasticsearch -d 

-d参数表示后台启动，还可以指定其他启动参数，如内存大小。 -Xmx3g -Xms3g -XX:PermSize=80

常用命令

查看集群健康状态

curl 'localhost:9200/_cat/health?v'

列出所有索引

curl 'localhost:9200/_cat/indices?v'

创建一个索引

curl -XPUT 'localhost:9200/customer?pretty'

 

插入一个文档（指定id 如果不指定id会随机生成一个id）

curl -XPUT 'localhost:9200/customer/external/1?pretty' -d '
{
  "name": "John Doe"
}'

 

 根据id查找

curl -XGET 'localhost:9200/customer/external/1?pretty'

 

删除索引

curl -XDELETE 'localhost:9200/customer?pretty'

 

修改文档

curl -XPOST 'localhost:9200/customer/external/1/_update?pretty' -d '
{
  "doc": { "name": "Jane Doe" }
}'

 

不指定id插入文档（不指定id用POST）

curl -XPOST 'localhost:9200/customer/external?pretty'-d '
{
  "name": "Jane Doe"
}'

 

删除文档

curl -XDELETE 'localhost:9200/customer/external/2?pretty'

 

普通搜索

curl 'localhost:9200/bank/_search?q=*&pretty'

 

创建mapping

PUT /{indices}/_mapping/{type}
{
    "my_index": {
        "mappings": {
            "my_type": {...}
        }
    }
}

curl -XPUT  http://localhost:9200/fstore/_mapping/test -d '{
    "test": {
        "properties": {
            "api": {
                "type": "string",
                "index": "not_analyzed"
            },
            "appId": {
                "type": "long"
            },
            "appName": {
                "type": "string",
                "index": "not_analyzed"
            }
        },
        "_source":{"excludes":["appName"]}
    }
}'

 

查看mapping

GET /{indices}/_mapping/{types}

curl localhost:9200/fstore/_mapping/test?pretty

 

聚合

curl -XPOST 'localhost:9200/bank/_search?pretty'-d '
{
  "size": 0,
  "aggs": {
    "group_by_state": {
      "terms": {
        "field": "state"
      }
    }
  }
}'

 

基于位置的搜索

 Geo Location and Search

一个完整的搜索

curl -XPOST '192.168.3.82:9200/tclappstore/_search?pretty' -d '
{
    "from": 0,
    "size": 10,
    "query": {
        "filtered": {
            "query": {
                "bool": {
                    "should": [
                        {
                            "multi_match": {
                                "query": "途牛",
                                "fields": [
                                    "name",
                                    "recommend_name",
                                    "search_keywords"
                                ],
                                "boost": 50
                            }
                        },
                        {
                            "wildcard": {
                                "name.raw_lowercase": {
                                    "wildcard": "*途牛*",
                                    "boost": 100
                                }
                            }
                        },
                        {
                            "wildcard": {
                                "recommend_name": {
                                    "wildcard": "*途牛*",
                                    "boost": 100
                                }
                            }
                        },
                        {
                            "match": {
                                "name.first_letter_pinyin": {
                                    "query": "途牛",
                                    "type": "boolean"
                                }
                            }
                        },
                        {
                            "match": {
                                "name.full_letter_pinyin": {
                                    "query": "途牛",
                                    "type": "boolean",
                                    "boost": 10
                                }
                            }
                        },
                        {
                            "match": {
                                "name.ik_pinyin": {
                                    "query": "途牛",
                                    "type": "boolean"
                                }
                            }
                        }
                    ]
                }
            },
            "filter": {
                "bool": {
                    "must": [
                        {
                            "term": {
                                "status": 1
                            }
                        },
                        {
                            "terms": {
                                "cates": [
                                    1
                                ]
                            }
                        }
                    ]
                }
            }
        }
    },
    "sort": [
        {
            "_score": {
                "order": "desc"
            }
        },
        {
            "get_real_download_count": {
                "order": "desc"
            }
        },
        {
            "sort": {
                "order": "desc"
            }
        }
    ]
}'

 

 

 

另外还有批量插入，批量修改文档等

 

JAVA中连接ES

有两种方式连接ES

建议客户端jar包版本和集群ES版本一直

• NodeClient :以节点形式加入集群

• TransportClient：作为一个普通客户端连接集群

Client client = TransportClient.builder().build()
        .addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("host1"), 9300))
        .addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("host2"), 9300));

    如果不是默认集群名，需要设置集群名

Settings settings = Settings.settingsBuilder()
        .put("cluster.name", "myClusterName").build();
Client client = TransportClient.builder().settings(settings).build();

文档API

 创建索引

CreateIndexRequest createIndexRequest = new CreateIndexRequest(esIndexName);
// 从指定位置读取json文件作为mapping
String setting = readMapping("elasticsearch/settings/app-index.json");
createIndexRequest.source(setting);
// 创建索引
EsClient.getInstance().getClient().admin().indices().create(createIndexRequest).actionGet();

 删除一个文档

DeleteResponse response = client.prepareDelete("twitter", // 索引名
 "tweet",                                                 // type  
 "1"                                                      //文档id
).get();

 搜索API

 如果debug可以看到查询的dsl语句，可以直接用dsl语句去查寻

setExplain(true) 可以看到返回结果的评分详细

升级

 备份数据

https://www.elastic.co/guide/en/elasticsearch/reference/current/backup.html

Upgrade From Upgrade To Supported Upgrade Type

0.90.x	1.x, 2.x	Full cluster restart
< 0.90.7	0.90.x	Full cluster restart
>= 0.90.7	0.90.x	Rolling upgrade
1.0.0 - 1.3.1	1.x	Rolling upgrade (if indices.recovery.compress set to false)
>= 1.3.2	1.x	Rolling upgrade
1.x	2.x	Full cluster restart

 

插件

安装插件

$ES_HOME/bin/plugin  加 -h 参数可以查看功能

$ES_HOME/bin/plugin list查看已经安装的插件

建议安装插件head

安装方法：$ES_HOME/bin/plugin -install mobz/elasticsearch-head

中文分词插件ik安装方法

http://my.oschina.net/xiaohui249/blog/232784 (没试是否可以成功，记得大概是这样的)

 

json查看：http://json.iapolo.com/