Workerman에서 데이터 저장 및 검색을 위해 ElasticSearch를 사용하는 방법

웹 개발에 있어서 데이터 저장과 검색은 매우 중요한 부분입니다. ElasticSearch는 데이터 검색 및 분석에 널리 사용되는 오픈 소스 분산 검색 엔진입니다. 대용량 데이터를 처리할 수 있으며 효율적인 검색 및 집계 기능을 제공합니다. Workerman은 실시간 통신, 온라인 게임, 높은 동시성 웹 서비스와 같은 애플리케이션 개발에 적합한 고성능 PHP 소켓 프레임워크입니다. 이번 글에서는 Workerman에서 데이터 저장 및 검색을 위해 ElasticSearch를 활용하는 방법을 소개하겠습니다.

1. ElasticSearch 설치 및 구성

시작하기 전에 ElasticSearch를 설치하고 구성해야 합니다. ElasticSearch 공식 홈페이지 https://www.elastic.co/downloads/elasticsearch 에서 최신 설치 패키지를 다운로드 하신 후 운영체제 종류에 맞게 설치하시면 됩니다. 설치가 완료되면 다음 명령을 사용하여 ElasticSearch를 시작할 수 있습니다.

$ cd elasticsearch/bin
$ ./elasticsearch

동시에 리스닝 포트, 클러스터 이름 및 데이터 저장소 설정과 같은 config/elasticsearch.yml 파일에서 ElasticSearch를 구성할 수도 있습니다. 길.

2. Workerman 설치 및 구성

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 프로세스가 시작될 때의 동작도 정의합니다.

3. 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);

4. 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에서 데이터를 검색하고 결과를 클라이언트에 보냅니다.

5. 요약

이 글에서는 Workerman에서 데이터 저장 및 검색을 위해 ElasticSearch를 사용하는 방법을 소개합니다. ElasticSearch의 데이터 추가, 삭제, 쿼리 및 수정 작업을 마스터함으로써 웹 애플리케이션에서 데이터를 빠르게 저장하고 검색할 수 있습니다. 동시에 위의 작업을 더 잘 이해하고 적용하기 위해 Workerman에 간단한 ElasticSearch 애플리케이션도 구현했습니다.

위 내용은 Workerman에서 데이터 저장 및 검색을 위해 ElasticSearch를 사용하는 방법의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!