Workerman을 통한 실시간 메시지 푸시 및 채팅 기록 저장 구현 방법

Workerman을 통한 실시간 메시지 푸시 및 채팅 기록 저장 구현 방법

인터넷의 급속한 발전과 함께 실시간 메시지 푸시 및 채팅 기능은 많은 애플리케이션에서 요구되는 기본 기능이 되었습니다. 고성능 PHP 소켓 서비스 프레임워크인 Workerman은 실시간 메시지 푸시 및 채팅 기록 저장을 구현하는 간단하고 효과적인 방법을 제공합니다. 이번 글에서는 Workererman을 통해 이러한 기능을 구현하는 방법을 소개하겠습니다.

먼저 우리의 목표는 실시간 메시지 푸시 시스템과 채팅 기록 저장 시스템을 구현하는 것임을 분명히 해야 합니다. 실시간 메시지 푸시 시스템의 목표는 사용자가 메시지를 보낸 후 특정 사용자에게 실시간으로 메시지를 푸시하는 것입니다. 채팅 기록 저장 시스템의 목표는 향후 참조를 위해 사용자의 채팅 기록을 지속적으로 저장하는 것입니다.

다음으로 작업자 환경을 구축해야 합니다. 먼저, 작곡가를 통해 수행할 수 있는 Workererman의 종속성을 설치해야 합니다. 명령줄에서 다음 명령을 실행하세요.

composer require workerman/workerman

설치가 완료되면 start.php라는 이름의 Workerman 시작 파일을 만들 수 있습니다. 이 파일에서는 Workerman의 Autoloader 및 Worker 클래스를 소개한 다음 Worker 개체를 만들어야 합니다. 샘플 코드는 다음과 같습니다. start.php。在这个文件中，我们需要引入workerman的Autoloader和Worker类，然后创建一个Worker对象。示例代码如下：

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

$worker = new Worker();
// 设置监听的端口
$worker->listen('websocket://0.0.0.0:2346');

Worker::runAll();

在这个示例中，我们创建了一个Worker对象，并设置监听的端口为2346

$worker->onConnect = function($connection) {
    // 当用户连接时执行的逻辑，比如记录用户信息等
};

$worker->onClose = function($connection) {
    // 当用户断开时执行的逻辑，比如更新用户在线状态等
};

이 예에서는 Worker 개체를 생성하고 수신 포트를 2346으로 설정합니다. WebSocket 프로토콜은 양방향 실시간 통신을 달성할 수 있기 때문에 여기서는 통신에 WebSocket 프로토콜이 사용됩니다. 물론 HTTP 긴 연결이나 TCP 소켓과 같은 다른 프로토콜을 선택할 수도 있습니다.

다음으로 특정 비즈니스 로직 코드를 작성해야 합니다. 먼저 사용자 연결 및 연결 해제를 처리해야 합니다. 이는 Worker 객체의 onConnect 및 onClose 메서드를 사용하여 달성할 수 있습니다. 샘플 코드는 다음과 같습니다.

$worker->onMessage = function($connection, $data) {
    // 当收到用户的消息时执行的逻辑，比如向特定用户推送消息等
};

이 예에서는 사용자가 연결되면 onConnect 메서드가 호출되고, 사용자가 연결을 끊으면 onClose 메서드가 호출됩니다. 여기서는 사용자 정보 기록이나 사용자의 온라인 상태 업데이트와 같은 몇 가지 논리를 수행할 수 있습니다.

다음으로 사용자 메시지 푸시를 처리해야 합니다. 이는 Worker 객체의 onMessage 메서드를 사용하여 달성할 수 있습니다. 샘플 코드는 다음과 같습니다.

$worker->onMessage = function($connection, $data) {
    // 解析用户的消息
    $message = json_decode($data, true);
    // 将消息存储到数据库中
    // ...
    // 向特定用户推送消息
    // ...
};

이 예제에서는 사용자로부터 메시지가 수신되면 onMessage 메서드가 호출됩니다. 여기에서는 특정 사용자에게 메시지를 푸시하는 등 몇 가지 논리를 수행할 수 있습니다.

동시에 채팅 기록 저장 기능을 구현하려면 사용자의 채팅 기록을 저장할 데이터베이스를 사용해야 합니다. MySQL 또는 다른 데이터베이스를 선택할 수 있습니다. 사용자로부터 메시지를 받은 후 메시지를 데이터베이스에 저장합니다. 샘플 코드는 다음과 같습니다.

$worker->onMessage = function($connection, $data) {
    // 解析用户的消息
    $message = json_decode($data, true);
    // 向特定用户推送消息
    $uid = $message['uid'];
    Gateway::sendToUid($uid, $data);
};

이 예제에서는 json_decode 함수를 사용하여 사용자의 메시지를 배열로 구문 분석한 다음 메시지를 데이터베이스에 저장합니다. 여기서 구체적인 구현은 선택한 데이터베이스에 따라 적절하게 코딩되어야 합니다.

특정 사용자에게 메시지를 보낼 때 Workerman의 게이트웨이 구현을 사용할 수 있습니다. 게이트웨이는 특정 연결이나 그룹에 메시지를 푸시할 수 있습니다. 샘플 코드는 다음과 같습니다.

var socket = new WebSocket('ws://localhost:2346');

socket.onopen = function() {
    // 连接成功时执行的逻辑
};

socket.onmessage = function(event) {
    var data = JSON.parse(event.data);
    // 收到消息时执行的逻辑
};

socket.onclose = function() {
    // 连接断开时执行的逻辑
};

// 发送消息
function sendMsg(message) {
    socket.send(JSON.stringify(message));
}

이 예에서는 Gateway::sendToUid 메서드를 사용하여 특정 사용자에게 메시지를 푸시합니다. 여기서 $uid는 사용자의 고유 식별자로, 사용자가 연결할 때 필요에 따라 생성될 수 있습니다.

마지막으로 프런트엔드가 서버와 통신할 수 있도록 하려면 프런트엔드 코드를 작성해야 합니다. WebSocket API를 사용하여 서버와 통신할 수 있습니다. 샘플 코드는 다음과 같습니다.

rrreee

이 예제에서는 WebSocket API를 사용하여 WebSocket 개체를 생성하고 연결 주소와 포트를 지정합니다. 그런 다음 onopen, onmessage 및 onclose 이벤트를 사용하여 연결 성공, 메시지 수신 및 연결 끊김을 처리할 수 있습니다. 동시에, message.send 메소드를 통해 서버로 메시지를 보낼 수 있습니다.

결산하자면, Workerman을 통해 실시간 메시지 푸시 기능과 채팅 기록 저장 기능을 쉽게 구현할 수 있습니다. 이는 단순한 예일 뿐이며 실제 구현에는 사용자 신원 인증, 그룹 관리, 메시지 푸시 전략 등과 같은 더 많은 세부 사항을 고려해야 할 수도 있습니다. 그러나 Workerman이 제공하는 고성능 소켓 서비스 프레임워크를 통해 이러한 기능을 쉽게 구현하고 필요에 따라 유연하게 확장 및 최적화할 수 있습니다. 🎜

위 내용은 Workerman을 통한 실시간 메시지 푸시 및 채팅 기록 저장 구현 방법의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!