Workerman에서 데이터 저장을 위해 Cassandra를 사용하는 방법

Workerman에서 데이터 저장을 위해 Cassandra를 사용하는 방법

오늘날의 소프트웨어 개발에서는 다양한 데이터 저장 방법과 엔진이 널리 사용됩니다. Cassandra는 고가용성 분산형 NoSQL 데이터베이스로서 빅데이터 분야에서 중요한 역할을 하고 있습니다. 이 기사에서는 Workerman에서 데이터 저장을 위해 Cassandra를 사용하는 방법을 소개하고 관련 코드 예제를 제공합니다.

1. Cassandra PHP 확장 설치

Cassandra 사용을 시작하기 전에 Cassandra의 PHP 확장을 설치해야 합니다. 설치하려면 터미널에서 다음 명령을 실행하세요.

sudo apt-get install libuv-dev libssl-dev libcurl4-openssl-dev libsasl2-dev
pecl install cassandra

설치가 완료된 후 php.ini 파일에 다음 줄도 추가해야 합니다.

extension=cassandra.so

변경 사항을 적용하려면 PHP 웹 서버를 다시 시작하세요.

2. Cassandra 연결 구성

다음으로 Workerman에서 사용할 Cassandra 연결 정보를 구성해야 합니다. cassandra.php라는 새 PHP 파일을 만들고 다음 콘텐츠를 추가합니다.

<?php
require 'vendor/autoload.php';

use CassandraCluster;
use CassandraSimpleStatement;

$cluster = Cluster::build()
    ->withContactPoints('127.0.0.1') // Cassandra节点IP地址
    ->withPort(9042) // Cassandra端口号
    ->withDefaultConsistency(1)
    ->build();

$session = $cluster->connect('mykeyspace'); // 替换为你自己的keyspace名称

function execute_query($query) {
    global $session;
    $result = $session->execute(new SimpleStatement($query));
    return $result;
}

이 코드에서는 Cassandra PHP 드라이버를 사용하여 Cassandra 데이터베이스에 대한 연결을 설정하고 CQL 쿼리 문 실행을 위한 Execute_query 함수를 정의합니다.

3. Workerman에서 Cassandra 사용

다음으로 Workerman에서 Cassandra를 데이터 저장용으로 사용하는 방법을 보여 드리겠습니다. 먼저 Workerman 프로젝트에 Cassandra 연결 구성을 도입해야 합니다. 새 PHP 파일을 만들고 이름을 Worker.php로 지정하고 다음 내용을 추가합니다.

<?php
require_once 'cassandra.php';

use WorkermanWorker;
use WorkermanProtocolsHttpResponse;

$http_worker = new Worker('http://0.0.0.0:8000');

$http_worker->onMessage = function ($connection, $request) {
    $path = $request->path();
    $result = '';

    if ($path == '/save') {
        $name = $_POST['name'];
        $email = $_POST['email'];

        $query = "INSERT INTO users (name, email) VALUES ('$name', '$email')";
        execute_query($query);

        $result = 'Data saved successfully';
    }

    $response = new Response(200, [], $result);
    $connection->send($response);
};

Worker::runAll();

이 코드에서는 Http Worker를 만들고 HTTP 요청을 처리하기 위한 onMessage 콜백 함수를 정의합니다. 요청된 경로가 /save인 경우 POST 매개변수에서 이름과 이메일을 가져와 Cassandra 데이터베이스에 삽입합니다.

4. Workerman 서버 시작

Cassandra 연결 및 Workerman 구성이 완료되었으므로 Workerman 서버를 시작할 수 있습니다. 터미널에서 다음 명령을 실행합니다:

php worker.php start

이 시점에서 서버가 실행되기 시작하고 포트 8000에서 수신 대기합니다.

5. Test

테스트하려면 브라우저에 다음 URL을 입력하세요.

http://localhost:8000/save

POST 매개변수에 이름과 이메일을 추가하고 클릭하여 요청을 보냅니다. 모든 것이 정상이면 데이터가 성공적으로 저장되었다는 응답을 받게 됩니다.

요약

이 글에서는 Workerman에서 데이터 저장을 위해 Cassandra를 사용하는 방법을 소개합니다. Cassandra PHP 확장을 설치하고 Cassandra 연결 정보를 구성하고 Workerman에서 해당 코드를 작성하면 Cassandra 데이터베이스와 쉽게 상호 작용하고 데이터 저장 기능을 구현할 수 있습니다. 이 기사가 Workerman과 Cassandra를 사용할 때 도움이 되기를 바랍니다.

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