Classification et analyse comparative des méthodes de mise en œuvre de la fonction de communication en temps réel PHP

Classification et analyse comparative des méthodes de mise en œuvre de la fonction de communication en temps réel PHP

Introduction :
Avec le développement rapide d'Internet, la fonction de communication en temps réel est devenue une exigence essentielle de nombreux sites Web et applications. Les capacités de communication en temps réel signifient que les utilisateurs peuvent envoyer, recevoir et traiter des messages en temps réel. Dans le domaine de PHP, il existe de nombreuses façons d'implémenter des fonctions de communication en temps réel. Cet article classera et comparera ces méthodes et fournira des exemples de code correspondants.

1. Méthode de communication en temps réel basée sur une connexion longue
La méthode de communication en temps réel basée sur une connexion longue permet au serveur de transmettre des messages au client en temps réel en établissant une connexion persistante. Cette méthode est généralement implémentée à l'aide de Socket ou WebSocket.

1. Méthode de communication en temps réel Socket
   Socket est un mécanisme de communication basé sur le protocole TCP/IP, qui peut réaliser une communication bidirectionnelle en temps réel entre le client et le serveur. PHP fournit les API correspondantes via des extensions de socket pour implémenter les fonctions de communication Socket.

Ce qui suit est un exemple simple de communication en temps réel Socket, code côté serveur :

<?php
// 创建socket
$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
// 绑定IP和端口
socket_bind($socket, '0.0.0.0', 8888);
// 监听连接
socket_listen($socket);
// 客户端连接处理
$connection = socket_accept($socket);
// 循环接收和发送消息
while (true) {
    // 接收客户端消息
    $message = socket_read($connection, 1024);
    echo "客户端消息：" . $message . PHP_EOL;
    // 发送消息给客户端
    socket_write($connection, "服务器消息：收到消息了！");
}
// 关闭socket连接
socket_close($socket);
?>

Code côté client :

<?php
// 创建socket
$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
// 连接服务器
socket_connect($socket, '127.0.0.1', 8888);
// 循环发送和接收消息
while (true) {
    // 发送消息给服务器
    socket_write($socket, "客户端消息：hello");
    // 接收服务器消息
    $message = socket_read($socket, 1024);
    echo "服务器消息：" . $message . PHP_EOL;
}
// 关闭socket连接
socket_close($socket);
?>

2. Méthode de communication en temps réel WebSocket
   WebSocket est un mécanisme de communication bidirectionnel basé sur Protocole HTTP, qui peut être utilisé dans le navigateur. Établissez une longue connexion avec le serveur et transmettez les données en temps réel. PHP fournit le support WebSocket via des bibliothèques d'extensions telles que Swoole.

Ce qui suit est un exemple simple de communication en temps réel WebSocket, code côté serveur :

<?php
// 创建WebSocket服务器
$server = new swoole_websocket_server("0.0.0.0", 8888);
// 监听连接事件
$server->on('open', function ($server, $req) {
    echo "客户端连接成功！
";
});
// 监听消息事件
$server->on('message', function ($server, $frame) {
    echo "客户端消息：" . $frame->data . "
";
    // 发送消息给客户端
    $server->push($frame->fd, "服务器消息：收到消息了！");
});
// 监听关闭事件
$server->on('close', function ($server, $fd) {
    echo "客户端关闭连接！
";
});
// 启动服务器
$server->start();
?>

Code côté client :

<script>
// 创建WebSocket连接
var socket = new WebSocket("ws://127.0.0.1:8888");
// 连接成功事件
socket.onopen = function (event) {
    console.log("连接服务器成功！");
};
// 接收消息事件
socket.onmessage = function (event) {
    console.log("服务器消息：" + event.data);
    // 发送消息给服务器
    socket.send("客户端消息：hello");
};
// 关闭连接事件
socket.onclose = function (event) {
    console.log("与服务器断开连接！");
};
</script>

2. Méthode de communication en temps réel basée sur une longue interrogation
Méthode de communication en temps réel basée sur une interrogation longue est planifiée via le client. Envoyez une demande au serveur, et le serveur renverra une réponse uniquement lorsqu'un message arrivera.

Ce qui suit est un exemple simple de communication en temps réel à interrogation longue basé sur AJAX, code côté serveur :

<?php
// 获取客户端发送的最新消息
$data = '';
while (empty($data)) {
    $data = $_POST['data'];
    usleep(100000);
}
// 返回最新消息给客户端
echo "服务器消息：收到消息了！";
?>

Code côté client :

<script>
// 发送请求获取最新消息
function getData() {
    var xhr = new XMLHttpRequest();
    xhr.onreadystatechange = function () {
        if (xhr.readyState == 4 && xhr.status == 200) {
            console.log("服务器消息：" + xhr.responseText);
        }
    };
    xhr.open("POST", "server.php", true);
    xhr.setRequestHeader("Content-type", "application/x-www-form-urlencoded");
    xhr.send("data=");
    setTimeout(getData, 1000); // 每秒发送请求
}
// 开始获取最新消息
getData();
</script>

3. Méthode de communication en temps réel du service Push
Le service Push est un type de. communication spécifiquement utilisée pour réaliser des services fonctionnels de communication en temps réel, tels que Firebase Cloud Messaging (FCM), Pusher, etc. PHP implémente l'intégration de services push via le SDK ou l'API correspondant.

Ce qui suit est un exemple simple de communication en temps réel Pusher, code côté serveur :

<?php
// 引入Pusher SDK
require __DIR__ . '/vendor/autoload.php';
// 创建Pusher对象
$options = array(
    'cluster' => 'your_cluster',
    'encrypted' => true
);
$pusher = new PusherPusher(
    'your_app_key',
    'your_app_secret',
    'your_app_id',
    $options
);
// 触发事件推送消息
$pusher->trigger('my-channel', 'my-event', array('message' => 'Hello world'));
?>

Code côté client :

<script src="https://js.pusher.com/7.0/pusher.min.js"></script>
<script>
// 创建Pusher实例
var pusher = new Pusher('your_app_key', {
    cluster: 'your_cluster',
    encrypted: true
});
// 订阅频道并监听事件
var channel = pusher.subscribe('my-channel');
channel.bind('my-event', function(data) {
    console.log("服务器消息：" + data.message);
});
</script>

Conclusion :
Cet article traite des méthodes de communication en temps réel basées sur de longues connexions, de la communication en temps réel des méthodes basées sur de longues interrogations et des services push. Les méthodes de communication en temps réel sont classées et comparées, et des exemples de code correspondants sont fournis. Selon les besoins et les scénarios spécifiques, le choix d'une méthode de communication en temps réel appropriée peut aider les développeurs à réaliser des fonctions de communication en temps réel efficaces et fiables.

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!