Guide de développement PHP Websocket pour implémenter la fonction de requête d'informations sur le trafic en temps réel-tutoriel php-php.cn

Guide de développement PHP Websocket pour implémenter la fonction de requête d'informations sur le trafic en temps réel

王林

Libérer： 2023-12-04 10:32:01

original

1186 Les gens l'ont consulté

PHP Websocket开发指南，实现实时交通信息查询功能

Guide de développement PHP Websocket pour implémenter la fonction de requête d'informations sur le trafic en temps réel

Avant-propos
Websocket est une technologie qui implémente une communication bidirectionnelle sur le Web. Elle peut mettre à jour les données en temps réel et convient aux scénarios qui le nécessitent. interaction en temps réel. Cet article présentera comment utiliser PHP pour développer une fonction de requête d'informations sur le trafic en temps réel et fournira des exemples de code correspondants.
Préparation
Avant de commencer le développement, vous devez préparer les travaux suivants :
Un hébergeur avec des serveurs PHP et Apache installés, avec des connaissances de base en programmation PHP
Un navigateur prenant en charge Websocket, tel que Chrome, Firefox, etc.
Installez Composer pour installer les bibliothèques dépendantes associées
Démarrer le développement
3.1 Installer les bibliothèques dépendantes de Websocket
Installez la bibliothèque Ratchet via Composer C'est un choix populaire pour développer des applications Websocket en PHP. Vous pouvez exécuter la commande suivante dans le terminal pour l'installer :
```
composer require cboden/ratchet
```
Copier après la connexion

3.2 Créer un serveur Websocket
Créez un fichier server.php dans le répertoire racine du projet et ajoutez le code suivant : server.php文件，并添加以下代码：

<?php
require 'vendor/autoload.php';

use RatchetServerIoServer;
use RatchetHttpHttpServer;
use RatchetWebSocketWsServer;

$server = IoServer::factory(
    new HttpServer(
        new WsServer(
            new TrafficInfo()
        )
    ),
    8080 // 服务器端口号
);

$server->run();

Copier après la connexion

这段代码创建了一个Websocket服务器并监听8080端口。其中，TrafficInfo是我们将会创建的Websocket应用类。

3.3 创建Websocket应用类
在项目根目录下创建一个TrafficInfo.php文件，并添加以下代码：

<?php
use RatchetMessageComponentInterface;
use RatchetConnectionInterface;

class TrafficInfo implements MessageComponentInterface
{
    private $connections;

    public function __construct()
    {
        $this->connections = new SplObjectStorage();
    }

    public function onOpen(ConnectionInterface $conn)
    {
        // 当一个新的连接建立时触发
        $this->connections->attach($conn);
    }

    public function onMessage(ConnectionInterface $from, $msg)
    {
        // 当接收到客户端发送的消息时触发
        // 在这里处理相应的逻辑，并将数据发送给所有连接的客户端
        $this->broadcast($msg);
    }

    public function onClose(ConnectionInterface $conn)
    {
        // 当一个客户端连接关闭时触发
        $this->connections->detach($conn);
    }

    public function onError(ConnectionInterface $conn, Exception $e)
    {
        // 当发生错误时触发
        $conn->send($e->getMessage());
        $conn->close();
    }

    private function broadcast($msg)
    {
        foreach ($this->connections as $conn) {
            $conn->send($msg);
        }
    }
}

Copier après la connexion

这段代码定义了一个TrafficInfo类，并实现了MessageComponentInterface接口。在该类中，我们重写了onOpen、onMessage、onClose和onError等方法，用于处理与客户端的交互，并实现了一个broadcast方法，用于将数据发送给所有连接的客户端。

客户端代码
在项目根目录下创建一个index.html文件，并添加以下代码：

<!DOCTYPE html>
<html lang="en">
<head>
    <meta charset="UTF-8">
    <title>Traffic Info</title>
</head>
<body>
    <h1>Traffic Info</h1>

    <div id="traffic-info"></div>

    <script>
        var socket = new WebSocket('ws://localhost:8080');

        socket.onmessage = function (event) {
            var data = JSON.parse(event.data);
            // 处理接收到的实时交通信息
            document.getElementById('traffic-info').innerHTML = data.message;
        };

        socket.onclose = function () {
            // 服务器连接关闭时触发
            console.log('Connection closed');
        };
    </script>
</body>
</html>

Copier après la connexion

这段代码创建了一个Websocket连接，并监听服务器的消息。当收到消息时，将数据解析为JSON格式，并将实时交通信息显示在页面上。

运行程序
将上述文件放置在Apache服务器的根目录下，并使用命令行进入项目根目录，运行以下命令启动Websocket服务器：
```
php server.php
```
Copier après la connexion

在浏览器中打开index.htmlrrreee

Ce code crée un serveur Websocket et écoute le port 8080. Parmi eux, TrafficInfo est la classe d'application Websocket que nous allons créer.

3.3 Créer une classe d'application Websocket

Créez un fichier TrafficInfo.php dans le répertoire racine du projet et ajoutez le code suivant :
rrreee

Ce code définit une classe TrafficInfo, et implémente l'interface MessageComponentInterface. Dans cette classe, nous remplaçons les méthodes telles que onOpen, onMessage, onClose et onError pour traiter les interactions avec les clients et implémente une méthode broadcast pour envoyer des données à tous les clients connectés. 🎜

index.html

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!