PHP Swoole 框架咋實(shí)現(xiàn)消息推送

PHP Swoole 框架可以實(shí)現(xiàn)消息推送的功能，主要通過 Swoole WebSocket 服務(wù)器來實(shí)現(xiàn)。下面是一個(gè)簡單的實(shí)現(xiàn)消息推送的示例：

1. 首先，安裝 Swoole 擴(kuò)展：

pecl install swoole

2. 創(chuàng)建一個(gè) WebSocket 服務(wù)器：

<?php

$server = new Swoole\WebSocket\Server("0.0.0.0", 9501);

$server->on('open', function ($server, $request) {
    echo "connection open: {$request->fd}\n";
});

$server->on('message', function ($server, $frame) {
    echo "received message: {$frame->data}\n";

    // 廣播消息給所有客戶端
    foreach ($server->connections as $fd) {
        $server->push($fd, $frame->data);
    }
});

$server->on('close', function ($server, $fd) {
    echo "connection close: {$fd}\n";
});

$server->start();

3. 在客戶端使用 JavaScript 來連接 WebSocket 服務(wù)器：

var ws = new WebSocket("ws://your-server-ip:9501");

ws.onopen = function() {
    console.log("Connected to WebSocket server");
};

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

ws.onclose = function() {
    console.log("Disconnected from WebSocket server");
};

// 發(fā)送消息給服務(wù)器
ws.send("Hello, Swoole!");

通過以上步驟，即可實(shí)現(xiàn)簡單的消息推送功能。當(dāng)客戶端連接到 WebSocket 服務(wù)器后，可以通過發(fā)送消息給服務(wù)器，服務(wù)器再將消息廣播給所有客戶端。當(dāng)客戶端斷開連接時(shí)，服務(wù)器會(huì)收到 close 事件。