Panduan pembangunan PHP Websocket untuk melaksanakan fungsi pertanyaan maklumat trafik masa nyata-tutorial php-php.cn

Panduan pembangunan PHP Websocket untuk melaksanakan fungsi pertanyaan maklumat trafik masa nyata

王林

Lepaskan： 2023-12-04 10:32:01

asal

1123 orang telah melayarinya

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

Panduan Pembangunan Soket Web PHP untuk melaksanakan fungsi pertanyaan maklumat trafik masa nyata

Kata Pengantar
Websocket ialah teknologi yang melaksanakan komunikasi dua hala di Web Ia boleh mengemas kini data dalam masa nyata dan sesuai untuk senario yang memerlukan interaksi masa nyata. Artikel ini akan memperkenalkan cara menggunakan PHP untuk membangunkan fungsi pertanyaan maklumat trafik masa nyata dan menyediakan contoh kod yang sepadan.
Persediaan
Sebelum memulakan pembangunan, anda perlu menyediakan kerja berikut:
Hos dengan pelayan PHP dan Apache dipasang, dengan pengetahuan pengaturcaraan PHP asas
Pelayar yang menyokong Websocket, seperti Chrome, Firefox, dll.
Pasang Komposer untuk memasang perpustakaan bergantung yang berkaitan
Mulakan pembangunan
3.1 Pasang perpustakaan bergantung Websocket
Pasang perpustakaan Ratchet melalui Komposer Ia adalah pilihan yang popular untuk membangunkan aplikasi Websocket dalam PHP Anda boleh menjalankan arahan berikut dalam terminal untuk memasang:
```
composer require cboden/ratchet
```
Salin selepas log masuk

3.2 Buat pelayan Websocket
Buat fail server.php dalam direktori akar projek dan tambah kod berikut: 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();

Salin selepas log masuk

这段代码创建了一个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);
        }
    }
}

Salin selepas log masuk

这段代码定义了一个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>

Salin selepas log masuk

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

运行程序
将上述文件放置在Apache服务器的根目录下，并使用命令行进入项目根目录，运行以下命令启动Websocket服务器：
```
php server.php
```
Salin selepas log masuk

在浏览器中打开index.htmlrrreee

Kod ini mencipta pelayan Websocket dan mendengar port 8080. Antaranya, TrafficInfo ialah kelas aplikasi Websocket yang akan kami buat.

3.3 Cipta kelas aplikasi Websocket

Buat fail TrafficInfo.php dalam direktori akar projek dan tambah kod berikut:
rrreee

Kod ini mentakrifkan kelas TrafficInfo , dan melaksanakan antara muka MessageComponentInterface. Dalam kelas ini, kami mengatasi kaedah seperti onOpen, onMessage, onClose dan onError untuk pemprosesan Berinteraksi dengan pelanggan dan melaksanakan kaedah broadcast untuk menghantar data kepada semua pelanggan yang disambungkan. 🎜

index.html

Atas ialah kandungan terperinci Panduan pembangunan PHP Websocket untuk melaksanakan fungsi pertanyaan maklumat trafik masa nyata. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!