elasticsearch-5.0 基础实践

基础概念

elasticsearch：搜索引擎
kibana：数据可视化
logstash：数据处理工具（此处用于转换mysql数据到elasticsearch）
elasticsearch-head：第三方elasticsearch插件
x-pack: 官方elasticsearch插件包

实践环境

JAVA：1.8.0_51
OS：Windows 10

elasticsearch集群

下载官方elasticsearch文件，解压缩，并拷贝2分，作3节点elasticsearch集群。
修改：config/elasticsearch.xml

#集群名
cluster.name: cluster
#当前elasticsearch副本的节点名字
node.name: node-1
# 以下配置elasticsearch可跨域调用，主要给elasticsearch-head使用
http.cors.enabled: true
http.cors.allow-origin: "*"
http.cors.allow-headers: "Authorization"

同理，配置另外两个elasticsearch副本。
通过elasticsearch.bat启动相应的elasticsearch副本，如下图：

访问http://localhost:9200/，如下：

安装x-pack包

安装x-pack包进行扩展：

1	bin/elasticsearch-plugin.bat install x-pack

重新启动所有elasticsearch副本，此时elasticsearch已经自带登录校验，默认用户密码：elastic/changeme，此时访问http://localhost:9200/需要输入账号密码。

部署elasticsearch-head

由于elasticsearch5.0变动，所有2.4版本的插件安装方法在5.0下已经不适用了。
Github地址
以下是独立部署的方法：

# git clone git://github.com/mobz/elasticsearch-head.git
# cd elasticsearch-head
# npm install （或yarn install）
# npm install -g grunt
# grunt server

此时，head服务已经启动，并监听9100端口：

通过以下链接，可以访问web ui：
访问链接：http://localhost:9100/?auth_user=elastic&auth_password=changeme
效果如下：

安装Kibana

Kibana是一个elastic的可视化组件，用于对elasticsearch中的数据进行可视化处理。

1、下载windows下的部署包：下载链接
2、修改config/kibana.yml中的elasticsearch.url为当前elasticsearch地址，如：http://localhost:9200
3、为配合elasticsearch中的x-pack，需安装Kibana的x-pack包：bin/kibana-plugin.bat install x-pack
4、通过bin下的kibana.bat启动Kibana

最终效果如下图：

通过上图中的访问url:http://localhost:5601打开web界面

账号密码：elastic/changeme

将mysql数据导入至elasticsearch

以下内容只演示使用logstash导入数据
logstash是一个elastic的数据处理工具，可将日志、数据库等类型数据输入至elasticsearch。
下载windows下的工具包：下载链接
下载mysql-connector-java-6.0.5.jar，可放置在bin目录下
创建配置文件：mysql.conf，可放置在bin目录下，内容可参考如下：

input {
    jdbc {
        jdbc_connection_string => "jdbc:mysql://localhost:3306/xxxxxt"
        jdbc_user => "root"
        jdbc_password => "xxxxx"
        schedule => "* * * * *"
        jdbc_validate_connection => true
        jdbc_driver_library => "mysql-connector-java-6.0.5.jar"
        jdbc_driver_class => "com.mysql.cj.jdbc.Driver"
        statement => "SELECT * from company"		
    }
}
output {
	elasticsearch {
        action => create
        index => "company"
        document_type => "company"
        document_id => "%{id}"
        hosts => ["http://127.0.0.1:9200"]
        user => elastic
        password => changeme
    }
}

在bin目录下，运行以下命令

1	logstash.bat -f mysql.conf

可在head下查看相应的数据，如下图：

简易使用kibana

登录Kibana的web界面
设置默认索引：

设置数据搜索：