首頁 > php框架 > Workerman > 主體

如何在Workerman中使用ElasticSearch進行資料儲存與搜尋

王林
發布: 2023-11-07 13:40:50
原創
722 人瀏覽過

如何在Workerman中使用ElasticSearch進行資料儲存與搜尋

在Web開發中,資料儲存與搜尋是非常重要的一部分。 ElasticSearch是一個開源的分散式搜尋引擎,被廣泛應用於資料搜尋和分析。它能夠處理大量數據並提供高效的搜尋和聚合功能。 Workerman是高效能的PHP socket框架,適用於開發即時通訊、線上遊戲和高並發Web服務等應用。在本文中,我們將介紹如何在Workerman中使用ElasticSearch進行資料儲存與搜尋。

  1. ElasticSearch安裝與設定

在開始之前,我們需要先安裝並設定ElasticSearch。可以在ElasticSearch的官方網站https://www.elastic.co/downloads/elasticsearch下載最新的安裝包,依照作業系統類型進行安裝。安裝完成後,可以透過以下指令來啟動ElasticSearch:

$ cd elasticsearch/bin
$ ./elasticsearch
登入後複製

同時,我們也可以在config/elasticsearch.yml檔案中進行ElasticSearch的配置,例如設定監聽埠、叢集名稱和資料儲存路徑等。

  1. Workerman的安裝與設定

在使用Workerman之前,我們需要先安裝並設定它。可以透過在終端機中輸入以下命令來安裝Workerman:

$ composer require workerman/workerman
登入後複製

安裝完成後,我們需要建立一個PHP腳本文件,並在其中引入Workerman的Autoloader類,並添加以下程式碼來啟動Workerman:

    require_once __DIR__ . '/vendor/autoload.php';
    use WorkermanWorker;

    $worker = new Worker();
    $worker->count = 4;
    $worker->onWorkerStart = function($worker){
      // do something
    };

    Worker::runAll();
登入後複製

在上述程式碼中,我們建立了一個Worker對象,並設定了進程數為4。同時,我們也透過onWorkerStart回呼函數來定義了Worker進程啟動時的行為。

  1. ElasticSearch中資料的增刪查改

在Workerman中使用ElasticSearch進行資料儲存與搜索,我們需要掌握ElasticSearch中資料的增刪查改操作,具體操作如下所示:

a. 資料的建立

在ElasticSearch中,資料的建立是透過對指定索引和文件類型的HTTP PUT請求完成的,可以使用以下程式碼來建立數據:

curl -XPUT http://localhost:9200/{index}/{type}/{id} -d '{
  "title":"ElasticSearch tutorial",
  "tags":["search","elasticsearch"],
  "body":"ElasticSearch is a powerful search engine."
}'
登入後複製

當然,我們也可以使用PHP程式碼來完成資料的建立:

$client = ElasticsearchClientBuilder::create()->build();
$params = [
    'index' => 'my_index',
    'type' => 'my_type',
    'id' => 'my_id',
    'body' => [
        'title' => 'ElasticSearch tutorial',
        'tags' => ['search', 'elasticsearch'],
        'body' => 'ElasticSearch is a powerful search engine.'
    ]
];
$response = $client->index($params);
登入後複製

b. 資料的查詢

在ElasticSearch中,資料的查詢分為精確查詢和模糊查詢兩種方式。其中,精確查詢是指透過指定欄位和值來尋找數據,而模糊查詢是指透過模糊匹配來尋找數據。可以使用以下程式碼來完成資料的查詢:

// 精确查询
$client = ElasticsearchClientBuilder::create()->build();
$params = [
    'index' => 'my_index',
    'type' => 'my_type',
    'body' => [
        'query' => [
            'match' => [
                'title' => 'ElasticSearch tutorial'
            ]
        ]
    ]
];
$response = $client->search($params);

// 模糊查询
$client = ElasticsearchClientBuilder::create()->build();
$params = [
    'index' => 'my_index',
    'type' => 'my_type',
    'body' => [
        'query' => [
            'wildcard' => [
                'title' => '*search*'
            ]
        ]
    ]
];
$response = $client->search($params);
登入後複製

c. 資料的更新

#在ElasticSearch中,資料的更新操作是透過對指定索引和文件類型的HTTP POST請求完成的,可以使用以下程式碼來更新資料:

curl -XPOST http://localhost:9200/{index}/{type}/{id}/_update -d '{
  "doc":{
    "title":"New ElasticSearch tutorial"
  }
}'
登入後複製

當然,我們也可以使用PHP程式碼來完成資料的更新:

$client = ElasticsearchClientBuilder::create()->build();
$params = [
    'index' => 'my_index',
    'type' => 'my_type',
    'id' => 'my_id',
    'body' => [
        'doc' => [
            'title' => 'New ElasticSearch tutorial'
        ]
    ]
];
$response = $client->update($params);
登入後複製

d. 資料的刪除

在ElasticSearch中,資料的刪除操作是透過對指定索引和文件類型的HTTP DELETE請求完成的,可以使用以下程式碼來刪除資料:

curl -XDELETE http://localhost:9200/{index}/{type}/{id}
登入後複製

當然,我們也可以使用PHP程式碼來完成資料的刪除:

$client = ElasticsearchClientBuilder::create()->build();
$params = [
    'index' => 'my_index',
    'type' => 'my_type',
    'id' => 'my_id'
];
$response = $client->delete($params);
登入後複製
  1. Workerman中的ElasticSearch範例

透過上述操作,我們已經掌握了在ElasticSearch中進行資料儲存與搜尋的基本操作。接下來,我們將在Workerman中實作一個使用ElasticSearch進行資料儲存與搜尋的範例,具體程式碼如下所示:

require_once __DIR__ . '/vendor/autoload.php';
use WorkermanWorker;
use ElasticsearchClientBuilder;

// 创建一个Worker对象
$worker = new Worker();
$worker->count = 4;

// 启动一个ElasticSearch客户端
$client = ClientBuilder::create()->build();

// 处理连接请求
$worker->onConnect = function($connection) {
    echo "New connection from " . $connection->getRemoteIp() . PHP_EOL;
};

// 处理数据请求
$worker->onMessage = function($connection, $data) use($client) {
    $params = [
        'index' => 'my_index',
        'type' => 'my_type',
        'body' => [
            'query' => [
                'wildcard' => [
                    'title' => '*' . $data . '*'
                ]
            ]
        ]
    ];

    // 从ElasticSearch检索数据
    $response = $client->search($params);

    // 处理检索结果
    $hits = $response['hits']['hits'];
    if(count($hits) > 0) {
        $result = 'Results:' . PHP_EOL;
        foreach($hits as $hit) {
            $result .= $hit['_source']['title'] . PHP_EOL;
        }
    } else {
        $result = 'No results found.' . PHP_EOL;
    }

    // 发送结果给客户端
    $connection->send($result);
};

Worker::runAll();
登入後複製

在上述程式碼中,我們首先啟動一個ElasticSearch客戶端,並建立一個Worker物件來處理連線和資料請求。當有客戶端連線進來後,在接收到資料請求時,我們從ElasticSearch中檢索數據,並將結果傳送給客戶端。

  1. 總結

本文介紹如何在Workerman中使用ElasticSearch進行資料儲存與搜尋。透過掌握ElasticSearch中資料的增刪查改操作,我們可以快速地在Web應用中進行資料的儲存與搜尋。同時,我們也在Workerman中實作了一個簡單的ElasticSearch應用,以便更好地理解並運用上述操作。

以上是如何在Workerman中使用ElasticSearch進行資料儲存與搜尋的詳細內容。更多資訊請關注PHP中文網其他相關文章!

來源:php.cn
本網站聲明
本文內容由網友自願投稿,版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容,請聯絡admin@php.cn
最新問題
熱門教學
更多>
最新下載
更多>
網站特效
網站源碼
網站素材
前端模板