ElasticSearch是一个基于Lucene的搜索引擎，是用Java语言开发的，能够达到实时搜索，稳定，可靠，快速，安装使用方便，作为Apache许可条款下的开放源码发布，是一种流行的企业级搜索引擎，是最受欢迎的企业搜索引擎。

〝 古人学问遗无力，少壮功夫老始成 〞

如果这篇文章能给你带来一点帮助，希望给飞兔小哥哥一键三连，表示支持，谢谢各位小伙伴们。

一、安装

通过composer安装

composer require 'elasticsearch/elasticsearch'

二、使用

创建ES类

1. <?php 
2.    
3. require 'vendor/autoload.php'; 
4.    
5. //如果未设置密码 
6. $es = \Elasticsearch\ClientBuilder::create()->setHosts(['xxx.xxx.xxx.xxx'])->build(); 
7.    
8. //如果es设置了密码 
9. $es = \Elasticsearch\ClientBuilder::create()->setHosts(['http://username:password@xxx.xxx.xxx.xxx:9200'])->build() 

三、新建ES数据库

index 对应关系型数据（以下简称MySQL）里面的数据库，而不是对应MySQL里面的索引。

1. <?php 
2. $params = [ 
3.     'index' => 'autofelix_db', #index的名字不能是大写和下划线开头 
4.     'body' => [ 
5.         'settings' => [ 
6.             'number_of_shards' => 5, 
7.             'number_of_replicas' => 0 
8.         ] 
9.     ] 
10. ]; 
11. $es->indices()->create($params); 

四、创建表

在MySQL里面，光有了数据库还不行，还需要建立表，ES也是一样的

ES中的type对应MySQL里面的表

ES6以前，一个index有多个type，就像MySQL中一个数据库有多个表一样

但是ES6以后，每个index只允许一个type

在定义字段的时候，可以看出每个字段可以定义单独的类型

在first_name中还自定义了 分词器 ik，这是个插件，是需要单独安装的

1. <?php 
2. $params = [ 
3.     'index' => 'autofelix_db', 
4.     'type' => 'autofelix_table', 
5.     'body' => [ 
6.         'mytype' => [ 
7.             '_source' => [ 
8.                 'enabled' => true 
9.             ], 
10.             'properties' => [ 
11.                 'id' => [ 
12.                     'type' => 'integer' 
13.                 ], 
14.                 'first_name' => [ 
15.                     'type' => 'text', 
16.                     'analyzer' => 'ik_max_word' 
17.                 ], 
18.                 'last_name' => [ 
19.                     'type' => 'text', 
20.                     'analyzer' => 'ik_max_word' 
21.                 ], 
22.                 'age' => [ 
23.                     'type' => 'integer' 
24.                 ] 
25.             ] 
26.         ] 
27.     ] 
28. ]; 
29. $es->indices()->putMapping($params); 

五、插入数据

现在数据库和表都有了，可以往里面插入数据了

在ES里面的数据叫文档

可以多插入一些数据，等会可以模拟搜索功能

1. <?php 
2. $params = [ 
3.     'index' => 'autofelix_db', 
4.     'type' => 'autofelix_table', 
5.     //'id' => 1, #可以手动指定id，也可以不指定随机生成 
6.     'body' => [ 
7.         'first_name' => '飞', 
8.         'last_name' => '兔', 
9.         'age' => 26 
10.     ] 
11. ]; 
12. $es->index($params); 

六、 查询所有数据

1. <?php 
2. $data = $es->search(); 
3.    
4. var_dump($data); 

七、查询单条数据

如果你在插入数据的时候指定了id，就可以查询的时候加上id

如果你在插入的时候未指定id，系统将会自动生成id，你可以通过查询所有数据后查看其id

1. <?php 
2. $params = [ 
3.     'index' => 'autofelix_db', 
4.     'type' => 'autofelix_table', 
5.     'id' =>  //你插入数据时候的id 
6. ]; 
7. $data = $es->get($params); 

八、搜索

ES精髓的地方就在于搜索

1. <?php 
2. $params = [ 
3.     'index' => 'autofelix_db', 
4.     'type' => 'autofelix_table', 
5.     'body' => [ 
6.         'query' => [ 
7.             'constant_score' => [ //非评分模式执行 
8.                 'filter' => [ //过滤器，不会计算相关度，速度快 
9.                     'term' => [ //精确查找，不支持多个条件 
10.                         'first_name' => '飞' 
11.                     ] 
12.                 ] 
13.             ] 
14.         ] 
15.     ] 
16. ]; 
17.    
18. $data = $es->search($params); 
19. var_dump($data); 

九、测试代码

基于Laravel环境，包含删除数据库，删除文档等操作

1. <?php 
2. use Elasticsearch\ClientBuilder; 
3. use Faker\Generator as Faker; 
4.    
5. /** 
6.  * ES 的 php 实测代码 
7.  */ 
8. class EsDemo 
9. { 
10.     private $EsClient = null; 
11.     private $faker = null; 
12.    
13.     /** 
14.      * 为了简化测试，本测试默认只操作一个Index，一个Type 
15.      */ 
16.     private $index = 'autofelix_db'; 
17.     private $type = 'autofelix_table'; 
18.    
19.     public function __construct(Faker $faker) 
20.     { 
21.         /** 
22.          * 实例化 ES 客户端 
23.          */ 
24.         $this->EsClient = ClientBuilder::create()->setHosts(['xxx.xxx.xxx.xxx'])->build(); 
25.         /** 
26.          * 这是一个数据生成库 
27.          */ 
28.         $this->faker = $faker; 
29.     } 
30.    
31.     /** 
32.      * 批量生成文档 
33.      * @param $num 
34.      */ 
35.     public function generateDoc($num = 100) { 
36.         foreach (range(1,$num) as $item) { 
37.             $this->putDoc([ 
38.                 'first_name' => $this->faker->name, 
39.                 'last_name' => $this->faker->name, 
40.                 'age' => $this->faker->numberBetween(20,80) 
41.             ]); 
42.         } 
43.     } 
44.    
45.     /** 
46.      * 删除一个文档 
47.      * @param $id 
48.      * @return array 
49.      */ 
50.     public function delDoc($id) { 
51.         $params = [ 
52.             'index' => $this->index, 
53.             'type' => $this->type, 
54.             'id' =>$id 
55.         ]; 
56.         return $this->EsClient->delete($params); 
57.     } 
58.    
59.     /** 
60.      * 搜索文档，query是查询条件 
61.      * @param array $query 
62.      * @param int $from 
63.      * @param int $size 
64.      * @return array 
65.      */ 
66.     public function search($query = [], $from = 0, $size = 5) { 
67. //        $query = [ 
68. //            'query' => [ 
69. //                'bool' => [ 
70. //                    'must' => [ 
71. //                        'match' => [ 
72. //                            'first_name' => 'Cronin', 
73. //                        ] 
74. //                    ], 
75. //                    'filter' => [ 
76. //                        'range' => [ 
77. //                            'age' => ['gt' => 76] 
78. //                        ] 
79. //                    ] 
80. //                ] 
81. // 
82. //            ] 
83. //        ]; 
84.         $params = [ 
85.             'index' => $this->index, 
86. //            'index' => 'm*', #index 和 type 是可以模糊匹配的，甚至这两个参数都是可选的 
87.             'type' => $this->type, 
88.             '_source' => ['first_name','age'], // 请求指定的字段 
89.             'body' => array_merge([ 
90.                 'from' => $from, 
91.                 'size' => $size 
92.             ],$query) 
93.         ]; 
94.         return $this->EsClient->search($params); 
95.     } 
96.    
97.     /** 
98.      * 一次获取多个文档 
99.      * @param $ids 
100.      * @return array 
101.      */ 
102.     public function getDocs($ids) { 
103.         $params = [ 
104.             'index' => $this->index, 
105.             'type' => $this->type, 
106.             'body' => ['ids' => $ids] 
107.         ]; 
108.         return $this->EsClient->mget($params); 
109.     } 
110.    
111.     /** 
112.      * 获取单个文档 
113.      * @param $id 
114.      * @return array 
115.      */ 
116.     public function getDoc($id) { 
117.         $params = [ 
118.             'index' => $this->index, 
119.             'type' => $this->type, 
120.             'id' =>$id 
121.         ]; 
122.         return $this->EsClient->get($params); 
123.     } 
124.    
125.     /** 
126.      * 更新一个文档 
127.      * @param $id 
128.      * @return array 
129.      */ 
130.     public function updateDoc($id) { 
131.         $params = [ 
132.             'index' => $this->index, 
133.             'type' => $this->type, 
134.             'id' =>$id, 
135.             'body' => [ 
136.                 'doc' => [ 
137.                     'first_name' => '张', 
138.                     'last_name' => '三', 
139.                     'age' => 99 
140.                 ] 
141.             ] 
142.         ]; 
143.         return $this->EsClient->update($params); 
144.     } 
145.    
146.     /** 
147.      * 添加一个文档到 Index 的Type中 
148.      * @param array $body 
149.      * @return void 
150.      */ 
151.     public function putDoc($body = []) { 
152.         $params = [ 
153.             'index' => $this->index, 
154.             'type' => $this->type, 
155.             // 'id' => 1, #可以手动指定id，也可以不指定随机生成 
156.             'body' => $body 
157.         ]; 
158.         $this->EsClient->index($params); 
159.     } 
160.    
161.     /** 
162.      * 删除所有的 Index 
163.      */ 
164.     public function delAllIndex() { 
165.         $indexList = $this->esStatus()['indices']; 
166.         foreach ($indexList as $item => $index) { 
167.             $this->delIndex(); 
168.         } 
169.     } 
170.    
171.     /** 
172.      * 获取 ES 的状态信息，包括index 列表 
173.      * @return array 
174.      */ 
175.     public function esStatus() { 
176.         return $this->EsClient->indices()->stats(); 
177.     } 
178.    
179.     /** 
180.      * 创建一个索引 Index （非关系型数据库里面那个索引，而是关系型数据里面的数据库的意思） 
181.      * @return void 
182.      */ 
183.     public function createIndex() { 
184.         $this->delIndex(); 
185.         $params = [ 
186.             'index' => $this->index, 
187.             'body' => [ 
188.                 'settings' => [ 
189.                     'number_of_shards' => 2, 
190.                     'number_of_replicas' => 0 
191.                 ] 
192.             ] 
193.         ]; 
194.         $this->EsClient->indices()->create($params); 
195.     } 
196.    
197.     /** 
198.      * 检查Index 是否存在 
199.      * @return bool 
200.      */ 
201.     public function checkIndexExists() { 
202.         $params = [ 
203.             'index' => $this->index 
204.         ]; 
205.         return $this->EsClient->indices()->exists($params); 
206.     } 
207.    
208.     /** 
209.      * 删除一个Index 
210.      * @return void 
211.      */ 
212.     public function delIndex() { 
213.         $params = [ 
214.             'index' => $this->index 
215.         ]; 
216.         if ($this->checkIndexExists()) { 
217.             $this->EsClient->indices()->delete($params); 
218.         } 
219.     } 
220.    
221.     /** 
222.      * 获取Index的文档模板信息 
223.      * @return array 
224.      */ 
225.     public function getMapping() { 
226.         $params = [ 
227.             'index' => $this->index 
228.         ]; 
229.         return $this->EsClient->indices()->getMapping($params); 
230.     } 
231.    
232.     /** 
233.      * 创建文档模板 
234.      * @return void 
235.      */ 
236.     public function createMapping() { 
237.         $this->createIndex(); 
238.         $params = [ 
239.             'index' => $this->index, 
240.             'type' => $this->type, 
241.             'body' => [ 
242.                 $this->type => [ 
243.                     '_source' => [ 
244.                         'enabled' => true 
245.                     ], 
246.                     'properties' => [ 
247.                         'id' => [ 
248.                             'type' => 'integer' 
249.                         ], 
250.                         'first_name' => [ 
251.                             'type' => 'text', 
252.                             'analyzer' => 'ik_max_word' 
253.                         ], 
254.                         'last_name' => [ 
255.                             'type' => 'text', 
256.                             'analyzer' => 'ik_max_word' 
257.                         ], 
258.                         'age' => [ 
259.                             'type' => 'integer' 
260.                         ] 
261.                     ] 
262.                 ] 
263.             ] 
264.         ]; 
265.         $this->EsClient->indices()->putMapping($params); 
266.         $this->generateDoc(); 
267.     } 
268. }

Tags: ElasticSearch

分享到：