워커맨 개발 실습: 효율적인 인스턴트 메시징 시스템 구축

Workerman 개발 실습: 효율적인 인스턴트 메시징 시스템 구축

소개:
인터넷의 급속한 발전과 실시간 커뮤니케이션에 대한 사용자 수요의 증가로 인해 인스턴트 메시징 시스템은 인기 있는 개발 분야가 되었습니다. 다양한 실시간 통신 요구 사항을 충족하기 위해 PHP 오픈 소스 프레임워크인 Workerman을 사용하여 효율적이고 안정적인 인스턴트 메시징 시스템을 구축할 수 있습니다. 이 기사에서는 Workerman 프레임워크를 사용하여 강력한 인스턴트 메시징 시스템을 개발하는 방법을 소개하고 코드 예제를 첨부합니다.

1. Workerman 설치:
   먼저 Workerman 프레임워크를 설치해야 합니다. Workerman을 설치하려면 터미널에서 다음 명령을 실행하세요.

   composer require workerman/workerman

   설치가 완료되면 인스턴트 메시징 시스템 구축을 시작할 수 있습니다.

2. 서버 생성:
   인스턴트 메시징 시스템의 서버를 구축하려면 server.php라는 새 PHP 파일을 생성하세요. server.php 파일에서 다음 코드를 작성해야 합니다.

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

use WorkermanWorker;

// 创建一个Worker监听2345端口，使用websocket协议通信
$ws_worker = new Worker("websocket://0.0.0.0:2345");

// 设置进程数
$ws_worker->count = 4;

// 当客户端连接时
$ws_worker->onConnect = function($connection){
    echo "New connection
";
};

// 当客户端发送消息时
$ws_worker->onMessage = function($connection, $data){
    foreach($connection->worker->connections as $clientConnection){
        $clientConnection->send($data);
    }
};

// 当客户端断开连接时
$ws_worker->onClose = function($connection){
    echo "Connection closed
";
};

// 运行worker
Worker::runAll();

위 코드는 Worker 객체를 생성하고 포트 2345를 수신하며 WebSocket 프로토콜을 사용하여 통신합니다. 클라이언트가 연결되면 "새 연결"이 출력되고, 클라이언트가 메시지를 보내면 메시지가 연결된 모든 클라이언트에게 전송되고, "연결이 닫혔습니다."가 출력됩니다. 마지막으로 Worker::runAll() 메서드를 사용하여 Worker를 실행합니다.

3. 클라이언트 생성:
   인스턴트 메시징 시스템의 클라이언트를 구축하는 데 사용되는 client.php라는 새 PHP 파일을 생성합니다. client.php 파일에서 다음 코드를 작성해야 합니다.

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

use WorkermanWorker;
use WorkermanAutoloader;
use WorkermanConnectionAsyncTcpConnection;

$connect_list = array();

// 当用户输入消息时
function onMessage($connect)
{
    // 从终端读取用户输入的消息
    $message = trim(fgets(STDIN));
    
    // 发送消息到服务端
    $connect->send($message);
}

// 创建一个异步TCP连接到服务端
$connect = new AsyncTcpConnection('ws://127.0.0.1:2345');
$connect->onConnect = function($connection){
    echo "Connected to server
";
};
$connect->onMessage = function($connection, $data){
    echo "Received message: ".$data."
";
};
$connect->onClose = function($connection){
    echo "Disconnected from server
";
};

// 运行连接
$connect->connect();

// 将连接对象保存到连接列表中
$connect_list[] = $connect;

// 监听用户输入消息
Worker::addWorker(function(){
    readline_callback_handler_install('', function(){});
    while (true) {
        if (count($GLOBALS['connect_list']) > 0) {
            $read = array_values($GLOBALS['connect_list']);
            $write = null;
            $except = null;
            if (false === ($num_changed_streams = stream_select($read, $write, $except, 1))) {
                continue;
            } elseif ($num_changed_streams > 0) {
                foreach($read as $connect) {
                    onMessage($connect);
                }
            }
        }
    }
});
Worker::runAll();

위 코드는 AsyncTcpConnection 개체를 생성하고 서버의 2345 포트에 연결합니다. 연결이 성공하면 "서버에 연결됨"이 출력되고, 서버에서 보낸 메시지가 수신되면 "수신된 메시지:"가 출력되며, 서버에서 연결이 끊어지면 "서버에서 연결이 끊어졌습니다."라는 메시지 내용이 출력됩니다. "가 출력됩니다. 동시에 사용자가 입력한 메시지를 모니터링하여 연결 개체를 통해 서버로 전송합니다.

4. 인스턴트 메시징 시스템 실행:
   터미널에서 다음 명령을 실행하여 서버와 클라이언트를 각각 시작합니다.

   php server.php
   php client.php

   실행 후 서버와 클라이언트는 청취 상태로 들어가 서로 메시지를 보낼 수 있습니다. . 서버는 클라이언트가 보낸 메시지를 받으면 연결된 모든 클라이언트에게 메시지를 브로드캐스트합니다.

요약:
이 글에서는 Workerman을 사용하여 효율적인 인스턴트 메시징 시스템을 개발하는 방법을 소개했습니다. 서버와 클라이언트를 구축하고 해당 코드를 작성함으로써 실시간 통신 기능을 구현할 수 있습니다. Workerman은 완벽한 API 및 기능 세트를 제공하므로 강력한 인스턴트 메시징 시스템을 쉽게 구축할 수 있습니다. 이 글이 도움이 되셨으면 좋겠습니다. 읽어주셔서 감사합니다!

위 내용은 워커맨 개발 실습: 효율적인 인스턴트 메시징 시스템 구축의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!