1. ElasticSearch安装

直接使用brew install elasticsearch 安装最新版本的es，基本没有障碍。

2.laravel5.1框架添加elasticsearch支持

在composer.json文件中添加elasticsearch-php依赖:

{    "require": {        "elasticsearch/elasticsearch": "~5.0"    }}

执行composer命令更新es代码加载到当前laravel框架中

composer update

laravel控制器中使用es

use Elasticsearch\ClientBuilder;//引入$client = ClientBuilder::create()->build();//初始化$params = [    'index' => 'my_index',    'type' => 'my_type',    'id' => 'my_id',    'body' => ['testField' => 'abc']];$response = $client->index($params);//添加索引print_r($response);$params = [    'index' => 'my_index',    'type' => 'my_type',    'id' => 'my_id'];$response = $client->get($params);//获取my_id对应的数据print_r($response);……

实例：

    client = ClientBuilder::create()->build();    }    /**     * Display a listing of the resource.     *     * @return \Illuminate\Http\Response     */    public function index()    {        for ($i=0;$i<5000;$i++) {            $params = [                'index' => 'my_index',                'type' => 'my_type',                'id' => 'my_id' . $i,                'body' => ['testField' => $i . '、Kitty,今天气很好!!!']            ];            $response = $this->client->index($params);        }        dd($response);    }    /**     * Display the specified resource.     *     * @param  string  $str     * @return \Illuminate\Http\Response     */    public function show($str='abc')    {//        $params = [//            'index' => 'my_index',//            'type' => 'my_type',//            'id' => $id//        ];        $params = [            'index' => 'my_index',            'type' => 'my_type',            //"scroll" => "3s",            "from" => 0,            "size" => 100,            'body' => [                'query' => [                    'match' => [                        'testField' => $str,                    ]                ]            ]        ];        $response = $this->client->search($params);        dd($response);    }}

3. 实时导入插件go-mysql-elasticsearch

安装go环境，设置环境变量

brew install go    vi ~/.bash_profile 添加以下PATH和GOPATH，并在命令行中执行这两条命令    export PATH=$PATH:/usr/local/Cellar/go/1.7.4_2/bin/    export GOPATH=/Users/User/go

获取go-mysql-elasticsearch

go get github.com/siddontang/go-mysql-elasticsearch

编译go-mysql-elasticsearch

cd $GOPATH/src/github.com/siddontang/go-mysql-elasticsearch make

配置elasticsearch的etc目录下的river.toml

# MySQL address, user and password# user must have replication privilege in MySQL.my_addr = "192.168.0.1:3306"#mysql地址my_user = "test"#用户名my_pass = "test123"#密码# Elasticsearch addresses_addr = "127.0.0.1:9200"#es安装地址# Path to store data, like master.info, and dump MySQL datadata_dir = "./var"# Inner Http status addressstat_addr = "127.0.0.1:12800"# pseudo server id like a slaveserver_id = 1001# mysql or mariadbflavor = "mysql"#mysql数据库# mysqldump execution path# if not set or empty, ignore mysqldump.mysqldump = "mysqldump"# MySQL data source[[source]]schema = "dev_cms"#数据库名称# Only below tables will be synced into Elasticsearch.# "test_river_[0-9]{4}" is a wildcard table format, you can use it if you have many sub tables, like table_0000 - table_1023# I don't think it is necessary to sync all tables in a database.tables = ["test_content"]#数据表名称，可以多个# Below is for special rule mapping#[[rule]]#schema = "test"#table = "test_river"#index = "river"#type = "river"# only MySQL field in filter will be synced#filter=["title","tags"]    # title is MySQL test_river field name, es_title is the customized name in Elasticsearch    #[rule.field]    # This will map column title to elastic search my_title    #title="es_title"    # This will map column tags to elastic search my_tags and use array type    #tags="my_tags,list"    # This will map column keywords to elastic search keywords and use array type    #keywords=",list"# wildcard table rule, the wildcard table must be in source tables[[rule]]schema = "dev_cms"#数据库名称table = "test_content"#数据表名称index = "es_dev_cms"#生成es数据索引名称，对应schematype = "es_test_content"#生成es数据类型，对应table    # title is MySQL test_river field name, es_title is the customized name in Elasticsearch    [[rule.fields]]    mysql = "title"    elastic = "es_title"

执行命令，导入数据

cd $GOPATH/src/github.com/siddontang/go-mysql-elasticsearch ./bin/go-mysql-elasticsearch -config=./etc/river.toml &

可以在谷歌浏览器安装sense插件查看es数据