PHP dan WebSocket: Membina platform sembang masa nyata berprestasi tinggi

Dengan perkembangan berterusan Internet, komunikasi masa nyata telah menjadi fungsi penting untuk banyak tapak web dan aplikasi, jadi membina platform sembang masa nyata berprestasi tinggi menjadi sangat penting. Dalam pembangunan, menggunakan PHP dan WebSocket boleh memenuhi keperluan komunikasi masa nyata, dan gabungan kedua-dua teknologi ini juga boleh meningkatkan prestasi platform dengan sangat baik.

WebSocket ialah protokol komunikasi dupleks penuh yang melaluinya sambungan berpanjangan boleh diwujudkan antara penyemak imbas dan pelayan, supaya pelayan boleh menghantar mesej masa nyata secara aktif kepada pelanggan. Protokol ini dicirikan oleh kecekapan tinggi, kebolehpercayaan, dan prestasi masa nyata yang baik, jadi ia sangat sesuai untuk membina platform komunikasi masa nyata.

PHP kini merupakan salah satu bahasa pembangunan web yang paling banyak digunakan, dan terdapat banyak rangka kerja matang yang tersedia, seperti Laravel, Symfony, dsb. Gunakan PHP untuk membina platform sembang masa nyata, gunakan WebSocket sebagai protokol komunikasi, dan gunakan alatan yang disediakan oleh rangka kerja untuk melaksanakan logik perniagaan dengan pantas untuk mencapai pembangunan pesat dan prestasi tinggi.

Yang berikut akan membina contoh platform sembang web berdasarkan rangka kerja Laravel, dan menggunakan WebSocket untuk menolak mesej masa nyata. Mula-mula anda perlu memuat turun dan memasang perpustakaan Ratchet, yang merupakan perpustakaan pelayan WebSocket berdasarkan ReactPHP dan sangat mudah digunakan.

Pasang perpustakaan Ratchet:

composer require cboden/ratchet

Kemudian tentukan laluan WebSocket dalam fail routes/web.php: routes/web.php文件中定义WebSocket的路由：

use AppHttpControllersChatController;
use RatchetHttpHttpServer;
use RatchetServerIoServer;
use RatchetWebSocketWsServer;

Route::get('/chat', function () {
    $server = IoServer::factory(
        new HttpServer(
            new WsServer(
                new ChatController()
            )
        ),
        8080
    );
    $server->run();
})->name('chat');

ChatController就是WebSocket的控制器，用于处理WebSocket的连接和消息。我们在app/Http/Controllers/ChatController.php中定义：

namespace AppHttpControllers;

use RatchetMessageComponentInterface;
use RatchetConnectionInterface;

class ChatController implements MessageComponentInterface
{
    protected $clients;

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

    public function onOpen(ConnectionInterface $conn)
    {
        $this->clients->attach($conn);
        echo "New connection! ({$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 "Connection {$conn->resourceId} has disconnected
";
    }

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

ChatController实现了MessageComponentInterface接口，包含了四个方法：onOpen、onMessage、onClose和onError。其中，onOpen在连接建立时触发，onMessage在接收到消息时触发，onClose在连接关闭时触发，onError在发生错误时触发。在onOpen中，将连接保存到$clients数组中；在onMessage中，将接收到的消息发送给所有其他连接；在onClose中，从$clients数组中删除关闭的连接；在onError

var conn = new WebSocket("ws://localhost:8080/chat");

conn.onmessage = function (event) {
    // 接收到聊天信息后的处理
};

function sendChatMessage(message) {
    conn.send(message);
}

rrreee

rrreee

Atas ialah kandungan terperinci PHP dan WebSocket: Membina platform sembang masa nyata berprestasi tinggi. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!