在PHP中實現消息推送功能可以使用WebSocket技術。以下是一個簡單的示例代碼:
<?php
// 創建WebSocket服務器
$server = new swoole_websocket_server("0.0.0.0", 9501);
// 監聽WebSocket連接打開事件
$server->on('open', function (swoole_websocket_server $server, $request) {
echo "WebSocket連接打開: {$request->fd}\n";
});
// 監聽WebSocket消息事件
$server->on('message', function (swoole_websocket_server $server, $frame) {
echo "收到消息: {$frame->data}\n";
// 廣播消息給所有連接的客戶端
foreach ($server->connections as $fd) {
$server->push($fd, $frame->data);
}
});
// 監聽WebSocket連接關閉事件
$server->on('close', function ($ser, $fd) {
echo "WebSocket連接關閉: {$fd}\n";
});
// 啟動WebSocket服務器
$server->start();
通過上面的代碼,你可以創建一個簡單的WebSocket服務器,用來接收客戶端發送的消息并將消息廣播給所有連接的客戶端。你可以根據自己的需求對消息進行處理和推送。