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

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

소개:
Workerman은 PHP 언어로 개발된 고성능 다중 프로세스 네트워크 프로그래밍 프레임워크로, 풍부한 네트워크 프로그래밍 인터페이스와 편리한 확장 메커니즘을 제공합니다. SQLite는 소규모 프로젝트에 사용하기에 적합한 경량 임베디드 데이터베이스입니다. 이 기사에서는 SQLite를 사용하여 Workerman에 데이터를 저장하는 방법을 소개하고 구체적인 코드 예제를 제공합니다.

1. SQLite 데이터베이스 설정
먼저 SQLite 데이터베이스 파일을 생성하고 데이터 테이블 구조를 설정해야 합니다. SQLite의 명령줄 도구나 시각적 도구(예: Navicat 등)를 사용하여 만들 수 있습니다. 다음은 데이터 테이블 구조의 예입니다.

CREATE TABLE `user` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `username` varchar(255) NOT NULL,
  `password` varchar(255) NOT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

2. SQLite 확장 설치
SQLite를 사용하기 전에 PHP의 SQLite 확장을 설치해야 합니다. 다음 명령을 통해 설치할 수 있습니다:

sudo apt-get install phpX.X-sqlite3

X.X를 PHP 버전 번호로 바꾸세요.

3. Workerman에서 SQLite 사용

1. SQLite 클래스 라이브러리 및 기타 관련 클래스 라이브러리 소개:

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

use WorkermanWorker;
use WorkermanConnectionTcpConnection;
use SQLite3;

2. Workerman 서비스 만들기:

$worker = new Worker('tcp://0.0.0.0:8000');

3. 연결 이벤트 수신 및 클라이언트 요청 처리:

$worker->onConnect = function ($connection) {
    // 连接建立成功的回调函数
};

$worker->onMessage = function ($connection, $data) {
    // 接收到客户端消息的回调函数
};

$worker->onClose = function ($connection) {
    // 连接关闭的回调函数
};

Worker::runAll();

4. 연결이 성공적으로 설정되면 콜백 함수에서 데이터베이스 연결을 생성하거나 엽니다.

$worker->onConnect = function ($connection) {
    // 连接建立成功的回调函数
    $db = new SQLite3('/path/to/your/database.sqlite');
};

/path/to/your/database.sqlite를 SQLite 데이터베이스 파일의 경로로 바꾸세요.

5. 클라이언트 메시지를 수신하는 콜백 함수에서 데이터베이스 작업 수행:

$worker->onMessage = function ($connection, $data) use ($db) {
    // 解析客户端消息...
    // 执行数据库操作...
    $username = $data['username'];
    $password = $data['password'];
    
    // 插入数据
    $query = "INSERT INTO `user` (`username`, `password`) VALUES ('{$username}', '{$password}')";
    $db->exec($query);
    
    // 查询数据
    $query = "SELECT * FROM `user`";
    $result = $db->query($query);
    while ($row = $result->fetchArray()) {
        // 处理查询结果...
    }
};

6. 연결을 닫는 콜백 함수에서 데이터베이스 연결 닫기:

$worker->onClose = function ($connection) use ($db) {
    // 连接关闭的回调函数
    $db->close();
};

4. 전체 코드 예제

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

use WorkermanWorker;
use WorkermanConnectionTcpConnection;
use SQLite3;

$worker = new Worker('tcp://0.0.0.0:8000');

$worker->onConnect = function ($connection) {
    $db = new SQLite3('/path/to/your/database.sqlite');
};

$worker->onMessage = function ($connection, $data) use ($db) {
    $username = $data['username'];
    $password = $data['password'];
  
    // 插入数据
    $query = "INSERT INTO `user` (`username`, `password`) VALUES ('{$username}', '{$password}')";
    $db->exec($query);
  
    // 查询数据
    $query = "SELECT * FROM `user`";
    $result = $db->query($query);
    while ($row = $result->fetchArray()) {
        // 处理查询结果...
    }
};

$worker->onClose = function ($connection) use ($db) {
    $db->close();
};

Worker::runAll();

참고: 위의 예제 코드 기능적 시연일 뿐이며 구체적인 비즈니스 로직과 예외 처리는 실제 상황에 따라 수정 및 개선되어야 합니다.

요약:
이 글에서는 Workerman에서 데이터 저장을 위해 SQLite를 사용하는 방법을 소개하고 구체적인 코드 예제를 제공합니다. 이 글이 독자들에게 도움이 되기를 바랍니다. 질문이나 오류가 있으면 제때에 수정해 주시기 바랍니다.

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