在PHP中实现消息推送功能可以使用WebSocket技术。以下是一个简单的示例代码:
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服务器,用来接收客户端发送的消息并将消息广播给所有连接的客户端。你可以根据自己的需求对消息进行处理和推送。