채팅방과 온라인 게임 기능을 갖춘 PHP 기반 실시간 채팅 시스템

PHP 기반 실시간 채팅 시스템의 채팅방 및 온라인 게임 기능

인터넷 기술의 지속적인 발전과 대중화로 인해 실시간 커뮤니케이션은 사람들의 삶에서 없어서는 안 될 부분이 되었습니다. 그 중 중요한 부분으로 실시간 채팅 시스템이 다양한 온라인 소셜 플랫폼과 웹사이트에서 널리 사용되고 있습니다. 이번 글에서는 PHP를 기반으로 한 실시간 채팅 시스템과 채팅방 및 온라인 게임 기능을 추가하는 방법을 소개하겠습니다.

실시간 채팅 시스템의 핵심은 사용자가 시스템 내에서 실시간으로 메시지를 주고받을 수 있도록 인스턴트 메시징 기능을 구현하는 것입니다. PHP에서는 WebSocket 기술을 사용하여 실시간 통신을 구현할 수 있습니다. WebSocket은 단일 TCP 연결을 통한 전이중 통신을 위한 프로토콜로, 서버에 너무 많은 부담을 주지 않고 지속적인 연결을 제공할 수 있습니다.

먼저 실시간 메시지 송수신을 처리하기 위해 WebSocket 서버를 만들어야 합니다. 다음은 간단한 PHP 코드 예입니다.

<?php
$server = new SwooleWebSocketServer("0.0.0.0", 9501);

// 监听 WebSocket 连接打开事件
$server->on('open', function (SwooleWebSocketServer $server, $request) {
    echo "客户端 {$request->fd} 进入聊天室
";
});

// 监听 WebSocket 消息事件
$server->on('message', function (SwooleWebSocketServer $server, $frame) {
    echo "收到客户端消息：{$frame->data}
";

    // 将消息发送给所有连接的客户端
    foreach ($server->connections as $fd) {
        $server->push($fd, $frame->data);
    }
});

// 监听 WebSocket 连接关闭事件
$server->on('close', function ($ser, $fd) {
    echo "客户端 {$fd} 离开聊天室
";
});

// 启动 WebSocket 服务器
$server->start();
?>

위 코드에서는 Swoole 확장을 사용하여 WebSocket 서버를 생성합니다. 새 클라이언트가 연결되면 open 이벤트가 트리거됩니다. 클라이언트가 메시지를 보내면 message 이벤트가 트리거됩니다. code>message 이벤트가 트리거됩니다. close 이벤트. 이러한 이벤트의 콜백 함수에서 해당 처리를 수행할 수 있습니다. open事件，当有客户端发送消息时，会触发message事件，当有客户端关闭连接时，会触发close事件。我们可以在这些事件的回调函数中进行相应的处理。

接下来，我们可以为聊天室添加一些基本的功能，例如显示在线用户列表和私聊功能。修改上述代码：

<?php
$server = new SwooleWebSocketServer("0.0.0.0", 9501);

// 在线用户列表
$onlineUsers = [];

// 监听 WebSocket 连接打开事件
$server->on('open', function (SwooleWebSocketServer $server, $request) use (&$onlineUsers) {
    echo "客户端 {$request->fd} 进入聊天室
";

    // 将用户添加到在线用户列表
    $onlineUsers[$request->fd] = $request->fd;
});

// 监听 WebSocket 消息事件
$server->on('message', function (SwooleWebSocketServer $server, $frame) use (&$onlineUsers) {
    echo "收到客户端消息：{$frame->data}
";

    $data = json_decode($frame->data, true);

    // 判断消息类型
    switch ($data['type']) {
        case 'message':
            // 将消息发送给所有连接的客户端
            foreach ($onlineUsers as $fd) {
                $server->push($fd, json_encode([
                    'type' => 'message',
                    'username' => $data['username'],
                    'content' => $data['content'],
                ]));
            }
            break;
        case 'private_message':
            // 私聊功能
            $receiver = $data['receiver'];
            $content = $data['content'];

            // 判断接收者是否在线
            if (isset($onlineUsers[$receiver])) {
                $server->push($receiver, json_encode([
                    'type' => 'private_message',
                    'sender' => $frame->fd,
                    'content' => $content,
                ]));
            } else {
                // 如果接收者不在线，则提示发送失败
                $server->push($frame->fd, json_encode([
                    'type' => 'error',
                    'content' => '发送失败，接收者不在线！',
                ]));
            }
            break;
    }
});

// 监听 WebSocket 连接关闭事件
$server->on('close', function ($ser, $fd) use (&$onlineUsers) {
    echo "客户端 {$fd} 离开聊天室
";

    // 将用户从在线用户列表中移除
    unset($onlineUsers[$fd]);
});

// 启动 WebSocket 服务器
$server->start();
?>

在上述代码中，我们添加了一个$onlineUsers数组，用来保存在线用户的fd。当有新的用户连接时，将其fd添加到该数组中；当有用户断开连接时，从数组中移除。并且在消息事件中，我们增加了判断消息类型的逻辑，如果是私聊消息，则向接收者发送私聊内容，否则向所有连接的客户端广播聊天内容。

除了聊天室功能之外，我们还可以为实时聊天系统添加在线游戏功能。例如，我们可以实现一个猜数字游戏。修改上述代码：

// 监听 WebSocket 消息事件
$server->on('message', function (SwooleWebSocketServer $server, $frame) use (&$onlineUsers) {
    echo "收到客户端消息：{$frame->data}
";

    $data = json_decode($frame->data, true);

    // 判断消息类型
    switch ($data['type']) {
        ...
        case 'guess_number':
            // 猜数字游戏
            $numbers = range(1, 10);
            $answer = array_rand($numbers);

            if ($data['number'] == $answer) {
                $server->push($frame->fd, json_encode([
                    'type' => 'guess_number',
                    'result' => '猜对了！',
                ]));
            } else {
                $server->push($frame->fd, json_encode([
                    'type' => 'guess_number',
                    'result' => '猜错了！答案是' . $answer,
                ]));
            }
            break;
    }
});

在上述代码中，我们添加了一个guess_number

다음으로 온라인 사용자 목록 표시 및 비공개 채팅 기능과 같은 몇 가지 기본 기능을 채팅방에 추가할 수 있습니다. 위 코드 수정:

rrreee

위 코드에서는 온라인 사용자의 fd를 저장하기 위해 $onlineUsers 배열을 추가했습니다. 새로운 사용자가 연결하면 해당 fd가 배열에 추가되고, 사용자가 연결을 끊으면 배열에서 제거됩니다. 그리고 메시지 이벤트에 메시지 유형을 결정하는 로직을 추가했습니다. 비공개 채팅 메시지인 경우 비공개 채팅 콘텐츠가 수신자에게 전송되고, 그렇지 않으면 채팅 콘텐츠가 연결된 모든 클라이언트에게 방송됩니다. 🎜🎜채팅방 기능 외에도 라이브 채팅 시스템에 온라인 게임 기능을 추가할 수도 있습니다. 예를 들어 숫자 추측 게임을 구현할 수 있습니다. 위 코드를 수정하세요: 🎜rrreee🎜 위 코드에서는 추측 게임의 논리를 처리하기 위해 guess_number 메시지 유형을 추가했습니다. 클라이언트가 숫자를 추측하기 위해 메시지를 보내면 서버는 임의의 답을 생성하고 이를 클라이언트의 추측과 비교한 후 결과를 클라이언트에 반환합니다. 🎜🎜위의 샘플 코드를 사용하면 PHP 기반의 간단한 실시간 채팅 시스템을 구현하고 채팅방 및 온라인 게임 기능을 추가할 수 있습니다. 물론 이는 단순한 예시에 불과하며, 실제 적용 시에는 좀 더 자세한 내용과 보안이 고려되어야 할 것이다. 이 기사가 도움이 되기를 바랍니다! 🎜

위 내용은 채팅방과 온라인 게임 기능을 갖춘 PHP 기반 실시간 채팅 시스템의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!