在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服务器,用来接收客户端发送的消息并将消息广播给所有连接的客户端。你可以根据自己的需求对消息进行处理和推送。