Workerman에서 데이터 저장 및 쿼리를 위해 HBase를 사용하는 방법

Workerman은 고성능 PHP 소켓 프레임워크로, 많은 동시 연결을 처리할 수 있는 능력이 특징입니다. 기존 PHP 프레임워크와 달리 Workerman은 Apache 또는 Nginx와 같은 웹 서버에 의존하지 않고 대신 PHP 프로세스를 시작하여 전체 애플리케이션을 실행합니다. Workerman은 매우 높은 작업 효율성과 더 나은 부하 용량을 제공합니다.

동시에 HBase는 빅데이터 처리 분야에서 널리 사용되는 분산형 NoSQL 데이터베이스 시스템입니다. HBase의 장점은 강력한 수평 확장성과 대용량 데이터를 처리할 수 있는 무제한 확장성입니다. 매우 높은 확장성으로 인해 HBase는 Hadoop 생태계의 필수적인 부분이 되었으며 점차 대규모 데이터 저장 및 처리를 위한 첫 번째 선택이 되었습니다.

이 글에서는 Workerman에서 데이터 저장 및 쿼리를 위해 HBase를 사용하는 방법을 소개합니다.

1. HBase 설치 및 구성

HBase를 사용하기 전에 먼저 HBase를 설치하고 구성해야 합니다. 여기서는 설치 및 구성을 위해 HBase 공식 문서의 단계를 사용합니다.

1. HBase 다운로드

HBase 공식 웹사이트에서 최신 버전의 HBase를 다운로드하고 여기에서 hbase-2.2.4 버전을 선택하세요.

2. HBase 압축 해제

다운로드한 HBase 패키지의 압축을 풀고 지정된 디렉터리로 이동합니다.

tar -zxf hbase-2.2.4-bin.tar.gz
mv hbase-2.2.4 /usr/local/hbase

3. 구성 파일 수정

HBase 구성 파일을 수정하세요. 구성 파일은 다음 위치에 있습니다. "/usr /local/hbase/conf" 디렉토리에 있습니다. 주로 "hbase-env.sh", "hbase-site.xml", "regionservers" 등이 포함됩니다.

(1) hbase-env.sh 파일을 수정합니다.

파일 끝에 다음 콘텐츠를 추가합니다.

export JAVA_HOME=/usr/local/jdk1.8.0_211
export HBASE_MANAGES_ZK=false
export HBASE_HEAPSIZE=1024

첫 번째 줄은 Java 설치 디렉터리를 지정하고, 두 번째 줄은 HBase에 내장된 ZooKeeper를 사용하지 않음을 나타내며, 세 번째 줄은 HBase 프로세스의 최대 힙 메모리를 설정합니다.

(2) hbase-site.xml 파일을 수정합니다.

파일 끝에 다음 콘텐츠를 추가합니다.

<name>hbase.rootdir</name>
<value>file:///usr/local/hbase/data</value>

where "file:///usr /local/hbase/ data"는 지정된 HBase 데이터 저장소의 루트 디렉터리를 나타냅니다.

(3) Regionservers 파일을 수정합니다.

"/usr/local/hbase/conf/regionservers" 파일을 편집하고 파일에 로컬 IP 주소를 추가한 후 저장합니다.

4. HBase 시작

다음 명령을 실행하여 HBase를 시작합니다.

cd /usr/local/hbase
./bin/start-hbase.sh

5. HBase가 성공적으로 시작되는지 확인합니다.

다음 명령을 실행합니다. HBase가 성공적으로 시작되었는지 확인하려면:

./bin/status.sh

"HMaster" 출력은 HBase가 성공적으로 시작되었음을 나타냅니다.

2. PHP HBase 클라이언트 설치

PHP의 HBase 클라이언트에는 HBase-thrift, HBase-rest 등 선택할 수 있는 다양한 오픈 소스 패키지가 있습니다. 이 기사에서는 순수 PHP로 구현된 HBase1.0.0 프로토콜 호환 클라이언트인 HBase-PHP 라이브러리를 사용하도록 선택합니다.

1. HBase-PHP 라이브러리 설치

Composer를 통해 HBase-PHP 라이브러리를 설치할 수 있습니다. 다음 명령을 실행하여 설치하세요.

composer require rwgrier/HBase-PHP

2. HBase 연결 만들기

HBaseClient 클래스의 생성자 메서드를 호출하여 연결을 설정하세요.

require_once 'vendor/autoload.php';
use HBaseClientHBaseClient;
$ client = new HBaseClient([
'host' => 'localhost',
'port' => 9090
]);

HBase 클라이언트를 설정하려면 HBase 주소와 포트 번호를 지정해야 합니다. 연결.

3. Workerman에서 HBase 사용

Workerman에서 HBase를 사용하는 방법도 매우 간단합니다. 위 단계에서 HBase 연결을 생성하는 코드를 자신의 코드에 추가하기만 하면 됩니다. 다음은 간단한 예입니다.

use WorkermanWorker;
require_once DIR . '/vendor/autoload.php';
use HBaseClientHBaseClient;
// Workerman 인스턴스 만들기
$worker = new Worker() ;
// HBase 연결 설정
$client = new HBaseClient([
'host' => 'localhost',
'port' => 9090
]);
$worker->onMessage = 함수($connection , $data) use ($client) {
// 데이터 가져오기
$result = $client->get('mytable', 'row-key');
$row = current($result);
// 프로세스 data
$value = $row->getColumnValue('cf1:col1');
// 데이터 반환
$connection->send($value);
};
// 작업자 프로세스 시작
Worker:: runAll();

위의 예에서는 HBase 연결을 사용하여 "mytable" 테이블의 데이터를 가져오고 가져온 데이터를 클라이언트 연결로 반환합니다. HBase의 더 많은 API 사용법은 HBase-PHP 공식 문서를 참조하세요.

요약

Workerman과 HBase를 사용하면 고성능과 대용량 데이터 저장을 쉽게 구현하고 실시간 데이터 쿼리 및 처리를 실현할 수 있습니다. Workerman과 HBase는 모두 오픈 소스 소프트웨어로 뛰어난 성능과 안정성을 다수의 사용자에게 인정받고 있으며 대규모 애플리케이션의 요구 사항을 충족할 수 있습니다. 이 글에서는 데이터 저장 및 쿼리를 위해 Workerman을 HBase와 함께 사용하는 방법을 소개합니다. 실제 개발에서는 실제 상황에 맞게 조정하고 최적화해야 합니다.

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