Workerman 네트워크 프로그래밍 실습: 고성능 인스턴트 메시징 시스템 만들기

Workerman 네트워크 프로그래밍 실습: 고성능 인스턴트 메시징 시스템 구축

소개:
인터넷의 급속한 발전과 함께 인스턴트 메시징 시스템은 사용자들로부터 점점 더 많은 관심을 받고 있습니다. QQ, WeChat 등과 같은 기존 인스턴트 메시징 시스템은 사용자 수가 많고 메시지 동시성이 높을 때 성능 병목 현상에 직면하는 경우가 많습니다. 이러한 문제를 해결하기 위해 오픈소스 프로젝트 Workerman이 탄생했습니다. 이 기사에서는 Workerman을 사용하여 고성능 인스턴트 메시징 시스템을 구축하는 방법을 소개합니다.

1. Workerman 소개
   Workerman은 PHP를 기반으로 개발된 고성능 네트워크 통신 프레임워크입니다. Apache, Nginx 등과 같은 기존 PHP 작동 모드와 비교하여 Workerman은 완전 비동기식 및 비차단 작동 모드를 채택하여 네트워크 통신의 효율성을 크게 향상시킵니다. 동시에 Workerman은 TCP, UDP 등과 같은 여러 프로토콜을 지원하므로 다양한 요구 사항에 따라 유연하게 선택할 수 있습니다. 또한 Workerman은 높은 동시성에 대한 지원도 뛰어나며 많은 사용자의 압력에도 쉽게 대처할 수 있습니다.
2. 준비
   인스턴트 메시징 시스템 개발을 시작하려면 먼저 Workerman을 설치해야 합니다. 다음 명령을 통해 설치할 수 있습니다:

composer require workerman/workerman

설치가 완료되면 Workerman의 모든 기능을 사용할 수 있습니다.

3. Create TCP 서버
   먼저 지정된 포트에서 수신 대기하는 간단한 TCP 서버를 만듭니다. 사용자가 서버에 연결하면 서버는 환영 메시지를 반환하고 사용자가 보낸 메시지를 받습니다. 다음은 간단한 코드 예입니다.

use WorkermanWorker;

// 创建一个Worker监听端口
$tcp_worker = new Worker("tcp://0.0.0.0:1234");

// 当客户端连接时的回调函数
$tcp_worker->onConnect = function ($connection) {
    $connection->send("Welcome to the chat room!
");
};

// 当接收到客户端消息时的回调函数
$tcp_worker->onMessage = function ($connection, $data) {
    // 处理接收到的消息
    echo "Received message: " . $data . "
";
    $connection->send("You said: " . $data . "
");
};

// 启动Worker
Worker::runAll();

위 코드를 사용하여 포트 1234에서 수신 대기하는 TCP 작업자를 만들었습니다. 클라이언트가 서버에 연결되면 서버는 환영 메시지를 보냅니다. 클라이언트가 메시지를 보내면 서버는 변경되지 않은 메시지를 반환합니다. Telnet과 같은 도구를 사용하여 테스트를 위해 서버에 연결할 수 있습니다.

4. WebSocket 서버 만들기
   WebSocket은 클라이언트와 서버 간에 지속적인 연결을 설정할 수 있는 전이중 통신 프로토콜입니다. Workerman은 WebSocket 프로토콜을 지원하며 Workerman을 사용하여 WebSocket 서버를 만들 수 있습니다. 다음은 간단한 코드 예입니다.

use WorkermanWorker;
use WorkermanProtocolsWebsocket;

// 创建一个WebSocket Worker监听端口
$websocket_worker = new Worker("websocket://0.0.0.0:1234");

// 设置协议处理类
$websocket_worker->onWebSocketConnect = function ($connection, $http_header) {
    // 处理握手请求
    Websocket::dealHandshake($connection, $http_header);
    // 发送欢迎消息
    $connection->send("Welcome to the chat room!
");
};

// 当接收到客户端消息时的回调函数
$websocket_worker->onMessage = function ($connection, $data) {
    // 处理接收到的消息
    echo "Received message: " . $data . "
";
    $connection->send("You said: " . $data . "
");
};

// 启动Worker
Worker::runAll();

위 코드를 사용하여 포트 1234에서 수신 대기하는 WebSocket Worker를 생성합니다. 클라이언트가 서버에 연결되면 서버는 환영 메시지를 보냅니다. 클라이언트가 메시지를 보내면 서버는 변경되지 않은 메시지를 반환합니다.

5. 인스턴트 메시징 시스템 구현
   위의 기반을 바탕으로 보다 완벽한 인스턴트 메시징 시스템을 계속해서 구현할 수 있습니다. 여기서는 개발을 위해 WebSocket 프로토콜을 사용합니다.

먼저 지정된 포트에서 수신 대기하는 WebSocket 서버를 만듭니다. 사용자가 서버에 연결하면 서버는 사용자 목록에 연결을 추가하고 사용자가 채팅방에 입장했다는 메시지를 브로드캐스트합니다. 사용자가 연결을 끊으면 서버는 사용자 목록에서 해당 사용자를 제거하고 사용자가 채팅방을 떠났다는 메시지를 브로드캐스트합니다.

다음은 간단한 코드 예시입니다.

use WorkermanWorker;
use WorkermanProtocolsWebsocket;

// 创建一个WebSocket Worker监听端口
$websocket_worker = new Worker("websocket://0.0.0.0:1234");

// 设置协议处理类
$websocket_worker->onWebSocketConnect = function ($connection, $http_header) {
    // 处理握手请求
    Websocket::dealHandshake($connection, $http_header);

    // 将连接添加到用户列表中
    global $user_list;
    $user_list[$connection->id] = $connection;

    // 广播用户进入聊天室的消息
    broadcastMessage("User #$connection->id entered the chat room.
");
};

// 当接收到客户端消息时的回调函数
$websocket_worker->onMessage = function ($connection, $data) {
    // 处理接收到的消息
    broadcastMessage("User #$connection->id: $data");
};

// 当用户断开连接时的回调函数
$websocket_worker->onClose = function ($connection) {
    // 将连接从用户列表中移除
    global $user_list;
    unset($user_list[$connection->id]);

    // 广播用户离开聊天室的消息
    broadcastMessage("User #$connection->id left the chat room.");
};

// 启动Worker
Worker::runAll();

// 广播消息给所有在线用户
function broadcastMessage($message)
{
    global $user_list;
    foreach ($user_list as $connection) {
        $connection->send($message);
    }
}

위 코드를 통해 간단한 인스턴트 메시징 시스템을 구현했습니다. 새로운 사용자가 채팅방에 입장하거나, 메시지를 보내거나, 채팅방에서 나갈 때마다 서버는 해당 메시지를 모든 온라인 사용자에게 브로드캐스팅합니다.

결론:
이 기사에서는 Workerman 프레임워크를 사용하여 간단한 샘플 코드를 통해 고성능 인스턴트 메시징 시스템을 구축하는 방법을 보여줍니다. Workerman의 비동기식 Non-Blocking 작업 모드와 높은 동시성 지원으로 수많은 사용자의 압력에 쉽게 대처할 수 있습니다. 이 글의 서론을 통해 독자들이 워커맨에 대해 더 깊이 이해하고 실제 프로젝트에 적용할 수 있기를 바란다.

위 내용은 Workerman 네트워크 프로그래밍 실습: 고성능 인스턴트 메시징 시스템 만들기의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!