1 <?php
 2 namespace app\api\controller;
 3 
 4 use Elasticsearch\Client;
 5 use Elasticsearch\ClientBuilder;
 6 
 7 class Es
 8 {
 9     private static ?Client $client = null;
10 
11     //连接
12     public static function getClient(): ?Client
13     {
14         if (self::$client === null) {
15             // 一个或多个Elasticsearch节点的URL
16             $hosts = ['http://192.168.12.135:9200'];
17             self::$client = ClientBuilder::create()->setHosts($hosts)->build();
18         }
19 
20         return self::$client;
21     }
22 
23     // 插入
24     // 插入数据的方法
25     public function insertData()
26     {
27         $params = [
28             'index' => 'tp5-user',
29             'id' => 3,
30             'body' => [
31                 'id' => 3,
32                 'user_name' => 'xiaohong',
33                 'info' => '白嫖gg',
34                 'email' => 'xiaohong@qq.com',
35                 'create_at' => '1721883969'
36             ]
37         ];
38 
39         try {
40             $response = self::getClient()->index($params);
41             echo "Document inserted successfully.\n";
42             print_r($response);
43         } catch (\Exception $e) {
44             echo "Error inserting document: " . $e->getMessage();
45         }
46     }
47 
48     // 搜索
49     public function search()
50     {
51         $params = [
52             'index' => 'tp5-user',
53             'body'  => [
54                 'query' => [
55                     'match' => [
56                         'all' => 'tom'
57                     ]
58                 ]
59             ]
60         ];
61 
62         $results = self::getClient()->search($params);
63 
64         dump($results);
65     }
66 }