Elasticsearch集群配置和管理教程

ElasticSearch集群服务器配置

一、安装

ElasticSearch是基于Lence的，而Lence是用Java编写的开源库，需要依赖Java的运行环境。现在使用的ELasticSearch版本是1.6，它需要jdk1.7或以上的版本。
本文使用的是linux系统，安装配置好Java环境，把download下来，解压后直接执行启动就可以了。

1.安装启动elasticsearch：
cd到elasticsearch-1.6.0.tar.gz 放置的目录，
解压 tar -xvf elasticsearch-1.6.0.tar.gz
启动 ./elasticsearch-1.6.0/bin/elasticsearch，查看启动信息，会提到http的默认端口是9200，transport的默认端口是9300，这个非常重要。

接下来可以在Terminal输入一下命令，查看一些基本信息
查看集群
curl 'localhost:9200/_cat/health?v'
查看节点
curl 'localhost:9200/_cat/nodes?v'
查看索引
curl 'localhost:9200/_cat/indices?v'
以上这些信息均可在安装head插件后，在http://localhost:9200/_plugin/head/中查看

2. 安装head插件
cd到elasticsearch-1.6.0/bin目录，运行./plugin -install mobz/elasticsearch-head，
安装并启动elasticsearch后，在浏览器打开http://localhost:9200/_plugin/head/，即可看到es的集群、节点、索引、数据等等的信息。


二、启动

1.自带脚本启动

1）bin/elasticsearch，不太任何参数，默认在前端启动

2）bin/elasticsearch-d，带参-d，表示在后台作为服务线程启动

还可以设置更多的参数：bin/elasticsearch-Xmx2g-Xms2g-Des.index.store.type=memory--node.name=my-node

注意：如果是在局域网中运行elasticsearch集群也是很简单的，只要cluster.name设置一致，并且机器在同一网段下，启动的es会自动发现对方，组成集群。


2.elasticsearch-servicewrapper

1)安装

到github,https://github.com/elastic/elasticsearch-servicewrapper下载，把service拷贝到ES_HOME/bin目录下。

2)使用

ES_HOME/bin/service/elasticsearch + console/start/stop...

在service目录下有个elasticsearch.conf配置文件，主要是设置一些java运行环境参数，其中比较重要的是下面的

参数：

#es的home路径，不用用默认值就可以
set.default.ES_HOME=

#分配给es的内存大小

set.default.ES_HEAP_SIZE=1024


#启动等待超时时间（以秒为单位）
wrapper.startup.timeout=300

#关闭等待超时时间（以秒为单位）

wrapper.shutdown.timeout=300

#ping超时时间(以秒为单位)

wrapper.ping.timeout=300



三、配置浅涉

elasticsearch的config文件夹里面有两个配置文件：elasticsearch.yml和logging.yml，第一个是es的基本配置文件，第二个是日志配置文件，es也是使用log4j来记录日志的，所以logging.yml里的设置按普通log4j配置文件来设置就行了。下面主要讲解下elasticsearch.yml这个文件中可配置的东西。


cluster.name:elasticsearch
配置es的集群名称，默认是elasticsearch，es会自动发现在同一网段下的es，如果在同一网段下有多个集群，就可以用这个属性来区分不同的集群。

node.name:"FranzKafka"
节点名，默认随机指定一个name列表中名字，该列表在es的jar包中config文件夹里name.txt文件中，其中有很多作者添加的有趣名字。

node.master:true
指定该节点是否有资格被选举成为node，默认是true，es是默认集群中的第一台机器为master，如果这台机挂了就会重新选举master。

node.data:true
指定该节点是否存储索引数据，默认为true。

index.number_of_shards:5
设置默认索引分片个数，默认为5片。

index.number_of_replicas:1
设置默认索引副本个数，默认为1个副本。

path.conf:/path/to/conf
设置配置文件的存储路径，默认是es根目录下的config文件夹。

path.data:/path/to/data
设置索引数据的存储路径，默认是es根目录下的data文件夹，可以设置多个存储路径，用逗号隔开，例：
path.data:/path/to/data1,/path/to/data2

path.work:/path/to/work
设置临时文件的存储路径，默认是es根目录下的work文件夹。

path.logs:/path/to/logs
设置日志文件的存储路径，默认是es根目录下的logs文件夹

path.plugins:/path/to/plugins
设置插件的存放路径，默认是es根目录下的plugins文件夹

bootstrap.mlockall:true
设置为true来锁住内存。因为当jvm开始swapping时es的效率会降低，所以要保证它不swap，可以把ES_MIN_MEM和ES_MAX_MEM两个环境变量设置成同一个值，并且保证机器有足够的内存分配给es。同时也要允许elasticsearch的进程可以锁住内存，linux下可以通过`ulimit-l unlimited`命令。

network.bind_host:192.168.0.1
设置绑定的ip地址，可以是ipv4或ipv6的，默认为0.0.0.0。


network.publish_host:192.168.0.1
设置其它节点和该节点交互的ip地址，如果不设置它会自动判断，值必须是个真实的ip地址。

network.host:192.168.0.1
这个参数是用来同时设置bind_host和publish_host上面两个参数。

transport.tcp.port:9300
设置节点间交互的tcp端口，默认是9300。

transport.tcp.compress:true
设置是否压缩tcp传输时的数据，默认为false，不压缩。

http.port:9200
设置对外服务的http端口，默认为9200。

http.max_content_length:100mb
设置内容的最大容量，默认100mb

http.enabled:false
是否使用http协议对外提供服务，默认为true，开启。

gateway.type:local
gateway的类型，默认为local即为本地文件系统，可以设置为本地文件系统，分布式文件系统，hadoop的HDFS，和amazon的s3服务器，其它文件系统的设置方法下次再详细说。

gateway.recover_after_nodes:1
设置集群中N个节点启动时进行数据恢复，默认为1。

gateway.recover_after_time:5m
设置初始化数据恢复进程的超时时间，默认是5分钟。

gateway.expected_nodes:2
设置这个集群中节点的数量，默认为2，一旦这N个节点启动，就会立即进行数据恢复。

cluster.routing.allocation.node_initial_primaries_recoveries:4
初始化数据恢复时，并发恢复线程的个数，默认为4。

cluster.routing.allocation.node_concurrent_recoveries:2
添加删除节点或负载均衡时并发恢复线程的个数，默认为4。

indices.recovery.max_size_per_sec:0
设置数据恢复时限制的带宽，如入100mb，默认为0，即无限制。

indices.recovery.concurrent_streams:5
设置这个参数来限制从其它分片恢复数据时最大同时打开并发流的个数，默认为5。

discovery.zen.minimum_master_nodes:1
设置这个参数来保证集群中的节点可以知道其它N个有master资格的节点。默认为1，对于大的集群来说，可以设置大一点的值（2-4）

discovery.zen.ping.timeout:3s
设置集群中自动发现其它节点时ping连接超时时间，默认为3秒，对于比较差的网络环境可以高点的值来防止自动发现时出错。

discovery.zen.ping.multicast.enabled:false
设置是否打开多播发现节点，默认是true。

discovery.zen.ping.unicast.hosts:["host1", "host2:port","host3[portX-portY]"]
设置集群中master节点的初始列表，可以通过这些节点来自动发现新加入集群的节点


四、集群配置多个节点

1.概述

本例子的集群将部署4个节点：

10.0.0.11 es1

10.0.0.209 es2

10.0.0.206 es3

10.0.0.208 es4


2.集群配置

上文提到过，只要集群名相同，且机器处于同一局域网同一网段，es会自动去发现其他的节点。


2.1es2的配置

vimES_HOME/config/elasticsearch.yml


在文件尾部添加一下内容：

cluster.name:elasticsearch #集群的名称，同一个集群该值必须设置成相同的

node.name:"es2" #该节点的名字

node.master:true #该节点有机会成为master节点

node.data:true #该节点可以存储数据

node.rack:rack2 #该节点所属的机架

index.number_of_shards:5 #shard的数目

index.number_of_replicas:3 #数据副本的数目

network.bind_host:0.0.0.0 #设置绑定的IP地址，可以是IPV4或者IPV6

network.publish_host:10.0.0.209 #设置其他节点与该节点交互的IP地址

network.host:10.0.0.209 #该参数用于同时设置bind_host和publish_host

transport.tcp.port:9300 #设置节点之间交互的端口号

transport.tcp.compress:true #设置是否压缩tcp上交互传输的数据

http.port:9200 #设置对外服务的http端口号

http.max_content_length:100mb #设置http内容的最大大小

http.enabled:true #是否开启http服务对外提供服务

discovery.zen.minimum_master_nodes:2 #设置这个参数来保证集群中的节点可以知道其它N个有master资格的节点。默认为1，对于大的集群来说，可以设置大一点的值（2-4）

discovery.zen.ping.timeout:120s #设置集群中自动发现其他节点时ping连接的超时时间

discovery.zen.ping.multicast.enabled:true #设置是否打开多播发现节点

discovery.zen.ping.unicast.hosts:["10.0.0.209:9300","10.0.0.206:9300","10.0.0.208:9300"] #设置集群中的Master节点的初始列表，可以通过这些节点来自动发现其他新加入集群的节点


2.2es3的配置

相似地，在206的机子上

vimES_HOME/config/elasticsearch.yml


在文件尾部添加一下内容：

cluster.name:elasticsearch #集群的名称，同一个集群该值必须设置成相同的

node.name:"es3" #该节点的名字

node.master:true #该节点有机会成为master节点

node.data:true #该节点可以存储数据

node.rack:rack3 #该节点所属的机架

index.number_of_shards:5 #shard的数目

index.number_of_replicas:3 #数据副本的数目

network.bind_host:0.0.0.0 #设置绑定的IP地址，可以是IPV4或者IPV6

network.publish_host:10.0.0.206 #设置其他节点与该节点交互的IP地址

network.host:10.0.0.206 #该参数用于同时设置bind_host和publish_host

transport.tcp.port:9300 #设置节点之间交互的端口号

transport.tcp.compress:true #设置是否压缩tcp上交互传输的数据

http.port:9200 #设置对外服务的http端口号

http.max_content_length:100mb #设置http内容的最大大小

http.enabled:true #是否开启http服务对外提供服务

discovery.zen.minimum_master_nodes:2 #设置这个参数来保证集群中的节点可以知道其它N个有master资格的节点。默认为1，对于大的集群来说，可以设置大一点的值（2-4）

discovery.zen.ping.timeout:120s #设置集群中自动发现其他节点时ping连接的超时时间

discovery.zen.ping.multicast.enabled:true #设置是否打开多播发现节点

discovery.zen.ping.unicast.hosts:["10.0.0.209:9300","10.0.0.206:9300","10.0.0.208:9300"] #设置集群中的Master节点的初始列表，可以通过这些节点来自动发现其他新加入集群的节点


2.3 208的机子上的es配置就参考上面两个节点的


2.4验证结果

启动节点：

ES_HOME/bin/service/elasticsearchstart


成功启动各个节点后，浏览器打开http://10.0.0.209:9200/_plugin/head/，界面会列出各个节点的信息。


3.节点添加和删除

3.1添加节点非常简单，几乎与上面设置节点的步骤一致。

在10.0.0.11机子上，vimES_HOME/config/elasticsearch.yml


cluster.name:elasticsearch #集群的名称，同一个集群该值必须设置成相同的

node.name:"es5" #该节点的名字

node.master:false #该节点有机会成为master节点

node.data:true #该节点可以存储数据

node.rack:rack5 #该节点所属的机架

index.number_of_shards:5 #shard的数目

index.number_of_replicas:3 #数据副本的数目

network.bind_host:0.0.0.0 #设置绑定的IP地址，可以是IPV4或者IPV6

network.publish_host:10.0.0.11 #设置其他节点与该节点交互的IP地址

network.host:10.0.0.11 #该参数用于同时设置bind_host和publish_host

transport.tcp.port:9300 #设置节点之间交互的端口号

transport.tcp.compress:true #设置是否压缩tcp上交互传输的数据

http.port:9200 #设置对外服务的http端口号

http.max_content_length:100mb #设置http内容的最大大小

http.enabled:true #是否开启http服务对外提供服务

discovery.zen.minimum_master_nodes:2 #设置这个参数来保证集群中的节点可以知道其它N个有master资格的节点。默认为1，对于大的集群来说，可以设置大一点的值（2-4）

discovery.zen.ping.timeout:120s #设置集群中自动发现其他节点时ping连接的超时时间

discovery.zen.ping.multicast.enabled:true #设置是否打开多播发现节点

discovery.zen.ping.unicast.hosts:["10.0.0.209:9300","10.0.0.206:9300","10.0.0.208:9300"] #设置集群中的Master节点的初始列表，可以通过这些节点来自动发现其他新加入集群的节点


写好配置，启动此es节点。

查看集群的状态：

    http://10.0.0.11:9200/_nodes

elasticsearch采用广播的方式自动发现节点，需要等待一段时间才能发现新的节点：

耐心等待...最后可以在此界面看到各个节点的信息。


3.2节点删除

在想要删除节点的机子上，运行ES_HOME/bin/service/elasticsearchstop，等待一会后，查看集群状态，会发现该节点没有了。

Elasticsearch集群管理

ES通过设置【节点的名字】和【集群的名字】，就能自动的组织相同集群名字的节点加入到集群中，并使很多的技术对用户透明化。
如果用户想要管理查看集群的状态，可以通过一些REST API来实现。
其他的ES文档翻译参考：Elasticsearch文档总结


REST API用途

ES提供了很多全面的API，大致可以分成如下几种：

1 检查集群、节点、索引的健康情况

2 管理集群、节点，索引数据、元数据

3 执行CRUD，创建、读取、更新、删除 以及 查询

4 执行高级的查询操作，比如分页、排序、脚本、聚合等

查看集群状态

可以通过CURL命令发送REST命令，查询集群的健康状态：

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

Localhost是主机的地址，9200是监听的端口号，ES默认监听的端口号就是9200.

这里需要注意的是，windows下安装的CURL有可能不支持单引号，如果有报错，还请改成双引号，内部使用转义字符转义。

得到的相应结果：

epoch      timestamp cluster       status node.total node.data shards pri relo init unassign
1394735289 14:28:09  elasticsearch green           1         1      0   0    0    0        0

可以看到集群的名字是默认的"elasticsearch"，集群的状态时"green"。这个颜色之前也有说过：

1 绿色，最健康的状态，代表所有的分片包括备份都可用

2 黄色，基本的分片可用，但是备份不可用（也可能是没有备份）

3 红色，部分的分片可用，表明分片有一部分损坏。此时执行查询部分数据仍然可以查到，遇到这种情况，还是赶快解决比较好。

上面的结果还可以看到，目前有一个节点，但是没有分片，这是因为我们的ES中还没有数据，一次也就没有分片。

 

当使用elasticsearch作为集群名字时，会使用单播，查询本机上是否还运行着其他的节点。如果有，则组成一个集群。

（如果使用其他的名字作为集群名字，那么就可能采用多播了！这个在工作中，经常会遇到，大家使用的是一个集群名字，分片总是被搞在一起，导致有人的机器下线后，自己的也无法使用）

 

通过下面的命令，可以查询节点的列表：

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

得到的结果如下：

curl 'localhost:9200/_cat/nodes?v'
host         ip        heap.percent ram.percent load node.role master name
mwubuntu1    127.0.1.1            8           4 0.00 d         *      New Goblin


查看所有的索引

在ES中索引有两个意思：

1 动词的索引，表示把数据存储到ES中，提供搜索的过程；这期间可能正在执行一个创建搜索的过程。

2 名字的索引，它是ES中的一个存储类型，与数据库类似，内部包含type字段，type中包含各种文档。

通过下面的命令可以查看所有的索引：

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

得到的结果如下：

curl 'localhost:9200/_cat/indices?v'
health index pri rep docs.count docs.deleted store.size pri.store.size

由于集群中没有任何的数据，上面的结果中也就只包含列的信息了。

创建索引

下面是创建索引，以及查询索引的例子：


curl -XPUT 'localhost:9200/customer?pretty'
{
  "acknowledged" : true
}

curl 'localhost:9200/_cat/indices?v'
health index    pri rep docs.count docs.deleted store.size pri.store.size
yellow customer   5   1          0            0       495b           495b



上面的结果中，customer索引的状态是yellow,这是因为此时虽然有5个主分片和一个备份。但是由于只是单个节点，我们的分片还在运行中，无法动态的修改。因此当有其他的节点加入到集群中，备份的节点会被拷贝到另一个节点中，状态就会变成green。

索引和搜索文档

之前说过，索引里面还有类型的概念，在索引文档之前要先设置类型type。

执行的命令如下：

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

执行成功后会得到如下的信息：


{
  "_index" : "customer",
  "_type" : "external",
  "_id" : "1",
  "_version" : 1,
  "created" : true
}



注意2.0版本的ES在同一索引下，不同的类型，相同的字段名字，是不允许字段类型不一致的。

上面的例子中，为我们创建了一个文档，并且id自动设置为1.

ES不需要再索引文档前，不需要明确的创建索引，如果执行上面的命令，索引不存在，也会自动的创建索引。

执行下面的命令查询，返回信息也如下：


curl -XGET 'localhost:9200/customer/external/1?pretty'
{
  "_index" : "customer",
  "_type" : "external",
  "_id" : "1",
  "_version" : 1,
  "found" : true, "_source" : { "name": "John Doe" }
}



这里会新增两个字段：

1 found 描述了请求信息

2 _source 为之前索引时的数据

删除索引

执行下面的命令就可以删除索引：

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

返回结果：

{
    "acknowledged": true
}


总结

总结上面涉及到的命令大致如下：

curl -XPUT 'localhost:9200/customer'//创建索引
//插入数据
curl -XPUT 'localhost:9200/customer/external/1'-d '
{
  "name": "John Doe"
}'
curl 'localhost:9200/customer/external/1'//查询数据
curl -XDELETE 'localhost:9200/customer'//删除索引