PHP dan WebSocket: Bina platform tolak mesej masa nyata yang berkuasa-tutorial php-php.cn

PHP dan WebSocket: Bina platform tolak mesej masa nyata yang berkuasa

王林

Lepaskan： 2023-12-17 17:34:01

asal

647 orang telah melayarinya

PHP和WebSocket: 构建强大的实时消息推送平台

PHP dan WebSocket: Membina platform tolak mesej masa nyata yang berkuasa

Pengenalan:

Dengan pembangunan berterusan teknologi rangkaian, tolakan mesej masa nyata menjadi semakin biasa dan penting. Protokol HTTP tradisional mempunyai batasan tertentu dalam merealisasikan tolakan mesej masa nyata, manakala protokol WebSocket telah menjadi penyelesaian yang lebih cekap dan berskala. Artikel ini akan memperkenalkan cara menggunakan PHP dan WebSocket untuk membina platform tolak mesej masa nyata yang berkuasa, dan memberikan contoh kod khusus.

1. Apakah itu WebSocket?

WebSocket ialah protokol komunikasi baharu yang diperkenalkan oleh HTML5, yang membolehkan pelayan mencapai komunikasi dua hala berterusan dengan pelanggan. Berbanding dengan protokol HTTP tradisional, WebSocket tidak memerlukan klien menghantar permintaan untuk mendapatkan respons daripada pelayan Sebaliknya, pelayan boleh menolak mesej secara aktif kepada klien. Ini menjadikan pemesejan masa nyata dan pemesejan segera lebih mudah dan lebih cekap.

2. PHP melaksanakan pelayan WebSocket

Sebagai bahasa pengaturcaraan sebelah pelayan yang popular, PHP menyediakan banyak perpustakaan dan rangka kerja untuk melaksanakan pelayan WebSocket. Dalam artikel ini, kami akan menggunakan rangka kerja Ratchet untuk melaksanakan pelayan WebSocket.

Pertama, kita perlu memasang rangka kerja Ratchet. Pemasangan boleh diselesaikan menggunakan Composer:

composer require cboden/ratchet

Salin selepas log masuk

Selepas pemasangan selesai, kita boleh mula menulis kod untuk pelayan WebSocket.

<?php

use RatchetMessageComponentInterface;
use RatchetConnectionInterface;

require 'vendor/autoload.php';

class Chat implements MessageComponentInterface {
    protected $clients;

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

    public function onOpen(ConnectionInterface $conn) {
        $this->clients->attach($conn);
        echo "A new connection is opened: {$conn->resourceId}
";
    }

    public function onMessage(ConnectionInterface $from, $msg) {
        foreach ($this->clients as $client) {
            if ($client !== $from) {
                $client->send($msg);
            }
        }
    }

    public function onClose(ConnectionInterface $conn) {
        $this->clients->detach($conn);
        echo "A connection is closed: {$conn->resourceId}
";
    }

    public function onError(ConnectionInterface $conn, Exception $e) {
        echo "An error occurred: {$e->getMessage()}
";
    }
}

$server = IoServer::factory(
    new HttpServer(
        new WsServer(
            new Chat()
        )
    ),
    8080
);

$server->run();

Salin selepas log masuk

Kod di atas melaksanakan pelayan bilik sembang mudah. Apabila sambungan baharu diwujudkan atau diputuskan, peristiwa yang sepadan akan dicetuskan. Apabila mesej baru tiba, pelayan menghantar mesej kepada semua pelanggan kecuali pengirim.

3 Sambung ke pelayan WebSocket dan tolak mesej

Sekarang kami telah menyelesaikan pelaksanaan pelayan WebSocket, kami boleh menggunakan pelayar atau klien WebSocket lain untuk menyambung ke pelayan dan menolak mesej melalui pelayan dalam masa nyata.

<!DOCTYPE html>
<html>
<head>
    <title>WebSocket Chat</title>
    <script>
        var socket = new WebSocket('ws://localhost:8080');

        socket.onopen = function() {
            console.log('Connected to WebSocket server');
        };

        socket.onmessage = function(e) {
            console.log('Received message: ' + e.data);
        };

        socket.onclose = function() {
            console.log('Disconnected from WebSocket server');
        };

        function sendMessage(message) {
            socket.send(message);
        }
    </script>
</head>
<body>
    <h1>WebSocket Chat</h1>
    <input type="text" id="messageInput" placeholder="Type your message">
    <button onclick="sendMessage(document.getElementById('messageInput').value)">Send</button>
</body>
</html>

Salin selepas log masuk

Kod di atas mencipta sambungan WebSocket dan menggunakan konsol untuk mengeluarkan mesej yang diterima. Pada masa yang sama, terdapat kotak input dan butang hantar pada halaman, yang boleh digunakan untuk menghantar mesej.

Kesimpulan:

Dengan menggunakan PHP dan WebSocket, kami boleh membina platform tolak mesej masa nyata yang berkuasa dengan mudah. Artikel ini memperkenalkan cara menggunakan rangka kerja Ratchet untuk melaksanakan pelayan WebSocket mudah, dan memberikan contoh kod bahagian hadapan yang menggunakan WebSocket untuk menyambung ke pelayan dan menolak mesej. Saya harap artikel ini akan membantu anda dan membolehkan anda memahami dan menggunakan PHP dan WebSocket dengan lebih baik.

Atas ialah kandungan terperinci PHP dan WebSocket: Bina platform tolak mesej masa nyata yang berkuasa. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!