PHP 실시간 통신 기능 구현 원리 분석-PHP 튜토리얼-php.cn

PHP 실시간 통신 기능 구현 원리 분석

王林

풀어 주다： 2023-08-10 21:06:01

원래의

1355명이 탐색했습니다.

PHP 실시간 통신 기능 구현 원리 분석

인터넷의 급속한 발전과 함께 실시간 통신은 많은 웹사이트와 애플리케이션의 기본 요구 사항이 되었습니다. 실시간 커뮤니케이션을 통해 사용자는 채팅 애플리케이션이든, 다자간 공동 편집이든, 실시간 알림이든 즉시 메시지를 주고받을 수 있어 사용자 경험을 크게 향상시킬 수 있습니다. 이 기사에서는 PHP의 실시간 통신 원리를 소개하고 해당 코드 예제를 제공합니다.

1. 실시간 통신 구현 원리

롱 폴링

롱 폴링은 가장 일반적이고 간단한 실시간 통신 방법 중 하나입니다. 이는 HTTP 요청-응답 모델을 기반으로 합니다. 서버는 요청에 대한 연결을 열어두고 새 메시지가 도착하면 즉시 응답을 반환합니다. 서버에 새 메시지가 없으면 새 메시지가 도착하거나 제한 시간에 도달할 때까지 기다렸다가 응답을 반환합니다.

Long Polling을 구현한 PHP의 코드 예시는 다음과 같습니다.

// 客户端发送请求
function longPolling() {
    while (true) {
        $newMessage = getMessage(); // 从服务器获取新消息
        if ($newMessage) {
            return $newMessage; // 有新消息时返回
        } else {
            // 没有新消息时继续等待
            usleep(1000000); // 休眠1秒钟
        }
    }
}

// 服务器返回响应
function getMessage() {
    // 从数据库或其他数据源获取新消息的逻辑
    // ...
    return $newMessage;
}

로그인 후 복사

위 코드에서 클라이언트 함수 longPolling은 무한 루프를 통해 서버에 요청을 보내고, 서버 함수는 getMessage가 사용되어 새로운 소식을 받습니다. 새 메시지가 있으면 longPolling 함수가 즉시 반환되고, 그렇지 않으면 계속 대기합니다. longPolling通过无限循环发送请求到服务器，服务器函数getMessage用于获取新消息。如果有新消息，函数longPolling将立即返回，否则继续等待。

WebSocket

WebSocket是HTML5中新增的通信协议，它支持双向通信，可以在客户端和服务器之间建立持久连接，而不必每次都发起新的HTTP请求。WebSocket使用了类似握手的方式建立连接，一旦连接建立成功，就可以通过发送数据帧来进行实时通信。

PHP实现WebSocket的代码示例如下：

// 服务器端代码
$server = new SwooleWebSocketServer("0.0.0.0", 9501);

$server->on('open', function (SwooleWebSocketServer $server, $request) {
    echo "new connection: {$request->fd}
"; 
});

$server->on('message', function (SwooleWebSocketServer $server, $frame) {
    $message = $frame->data; // 接收到的消息
    // 处理消息的逻辑
    // ...
    $server->push($frame->fd, $response); // 向客户端发送消息
});

$server->on('close', function ($ser, $fd) {
    echo "connection {$fd} closed
";
});

$server->start();

로그인 후 복사

以上代码使用了Swoole框架来实现WebSocket的服务器端。在打开连接时，回调函数open会被触发；在接收到消息时，回调函数message会被触发，你可以在其中处理消息并发送响应；close

WebSocket은 양방향 통신을 지원하며 매번 새로운 HTTP를 시작하지 않고도 클라이언트와 서버 간에 지속적인 연결을 설정할 수 있습니다. 묻다. WebSocket은 연결을 설정하기 위해 핸드셰이크와 유사한 방법을 사용합니다. 연결이 성공적으로 설정되면 데이터 프레임을 전송하여 실시간 통신을 수행할 수 있습니다.