摘要：安裝地址有兩種模式模式支持映射非模式支持原生使用首先創(chuàng)建或地址端口索引名稱索引名稱然后使用對(duì)進(jìn)行操作搜索新增更新刪除使用首先構(gòu)建調(diào)用中的方法對(duì)進(jìn)行操作其他方法類似創(chuàng)建同步數(shù)據(jù)到

composer 安裝：composer require ethansmart/es-for-laravel

github 地址：https://github.com/roancsu/es-for-laravel

ES for Laravel

Usage

EsBuilder 有兩種模式

ES ORM Client (ORM模式)：支持Model映射

ES Client (非ORM模式)：支持原生ES

使用 ES ORM Client

首先創(chuàng)建ORM Model

use EthansmartEsBuilderModelEsModel;
/**

* Class AtPerson
* $host ES IP或URL地址
* $port ES 端口
* $index ES 索引名稱
* $type ES 索引 type名稱
* @package EthanEsBuilderModel
*/

class AtPerson extends EsModel
{
    protected $host = "127.0.0.1";
    protected $port = "32800";
    protected $index = "accounts";
    protected $type = "person";
}

然后使用Model對(duì)ES進(jìn)行CURD操作

搜索

try {
    $result = AtPerson::build()
              ->select("user")
              ->where("user","==","chengluo")
              ->where("title,desc","like","AI")
              ->where("create_time","<","2018-10-05")
              ->get();
} catch (Exception $e) {
    return ["code"=>-1, "msg"=>$e->getMessage()];
}
return $result;

新增

try {
    $id = 5;
    $data = [
      "id"=>$id,
      "params"=>[
            "user"=>"Ethan Cheng",
            "title"=>"AI ".str_random(8),
            "desc"=>"AI ".str_random(12)
      ]
    ];
    $result = AtPerson::build()->create($data);
} catch (Exception $e) {
    return ["code"=>-1, "msg"=>$e->getMessage()];
}

return $result;

更新

try {
    $id = 5;
    $data = [
        "id"=>$id,
        "params"=>[
            "user"=>"Ethan Cheng",
            "title"=>"AI ".str_random(8),
            "desc"=>"AI ".str_random(12)
        ]
    ];
    $result = AtPerson::build()->update($data);
} catch (Exception $e) {
    return ["code"=>-1, "msg"=>$e->getMessage()];
}

return $result;

刪除

try {
    $id = 5;
    $result = AtPerson::build()->delete($id);
} catch (Exception $e) {
    throw $e;
}

return $result;

使用 ES Client

首先構(gòu)建 Client

private $client ;
public function __construct()
{
    $host = "127.0.0.1";
    $port = "32800";
    $this->client = EsClientBuilder::create()
        ->setHosts($host)
        ->setPort($port)
        ->build();
}

調(diào)用Client中的方法對(duì)ES進(jìn)行CURD操作

$data = [
    "index"=>"accounts",
    "type"=>"person",
    "body"=>[
          "query"=>[
              "bool"=>[
                  "must"=>[
                        "match"=>[
                              "user"=>"ethan"
                        ]
                  ]
              ]
          ]
    ],
];

try {
    $result = $this->client->search($data);
} catch (Exception $e) {
    return ["code"=>-1, "msg"=>$e->getMessage()];
}

return $result;

其他方法類似

創(chuàng)建Laravel Job 同步數(shù)據(jù)到 ES

use EthansmartEsBuilderBuilderEsClientBuilder;

class EsService
{
    private $client ;
    public function __construct()
    {
        $host = "127.0.0.1";
        $port = "32800";
        $this->client = EsClientBuilder::create()
            ->setHosts($host)
            ->setPort($port)
            ->build();
    }

    public function create($id)
    {
        $data = [
            "index"=>"accounts",
            "type"=>"person",
            "id"=>$id,
            "body"=>[
                "user"=>str_random(6),
                "title"=>str_random(12),
                "desc"=>str_random(16),
            ]
        ];

        try {
            $result =  $this->client->create($data);
        } catch (Exception $e) {
            return ["code"=>-1, "msg"=>$e->getMessage()];
        }
        return $result;

    }

}

Q:

在使用 composer 安裝過程中會(huì)出現(xiàn) 如下異常：

[InvalidArgumentException]

Could not find a version of package ethansmart/es-for-laravel matching your minimum-stability (stable). Require it with an explicit version constraint allowing its desired stability.

解決方法：

在項(xiàng)目composer.json文件中加入：

"repositories": [
        {
            "packagist.org": false
        },
        {
            "type": "composer",
            "url": "https://packagist.org"
        }
    ],

將國(guó)內(nèi)的composer鏡像換成 packagist.org 就可以了。