php 实时获取数据

基础概念

PHP（Hypertext Preprocessor）是一种广泛使用的开源脚本语言，尤其适用于Web开发。实时获取数据通常指的是应用程序能够即时从数据源（如数据库、API等）获取最新数据并展示给用户。

类型

轮询：客户端定期向服务器发送请求，检查是否有新数据。
长轮询：客户端发送请求后，服务器保持连接直到有新数据或超时。
WebSocket：一种全双工通信协议，允许服务器主动向客户端推送数据。

应用场景

聊天应用：实时聊天室、消息通知等。
股票交易：实时显示股票价格变动。
在线游戏：实时更新游戏状态和玩家位置。
社交媒体：实时更新动态和通知。

示例代码

轮询示例

<?php
// server.php
header('Content-Type: application/json');

while (true) {
    // 模拟从数据库获取数据
    $data = [
        'message' => 'Hello, World!',
        'timestamp' => date('Y-m-d H:i:s')
    ];

    echo json_encode($data);
    flush();
    sleep(5); // 每5秒发送一次数据
}
?>

<!-- client.html -->
<!DOCTYPE html>
<html>
<head>
    <title>实时数据获取</title>
</head>
<body>
    <div id="data"></div>
    <script>
        function fetchData() {
            fetch('server.php')
                .then(response => response.json())
                .then(data => {
                    document.getElementById('data').innerText = JSON.stringify(data);
                    setTimeout(fetchData, 5000); // 每5秒请求一次数据
                });
        }
        fetchData();
    </script>
</body>
</html>

WebSocket示例

<?php
// websocket_server.php
require 'vendor/autoload.php';

use Ratchet\MessageComponentInterface;
use Ratchet\ConnectionInterface;
use Ratchet\Server\IoServer;
use Ratchet\Http\HttpServer;
use Ratchet\WebSocket\WsServer;

class MyWebSocket implements MessageComponentInterface {
    protected $clients;

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

    public function onOpen(ConnectionInterface $conn) {
        $this->clients->attach($conn);
    }

    public function onMessage(ConnectionInterface $from, $msg) {
        foreach ($this->clients as $client) {
            if ($from !== $client) {
                $client->send($msg);
            }
        }
    }

    public function onClose(ConnectionInterface $conn) {
        $this->clients->detach($conn);
    }

    public function onError(ConnectionInterface $conn, \Exception $e) {
        $conn->close();
    }
}

$server = IoServer::factory(
    new HttpServer(
        new WsServer(
            new MyWebSocket()
        )
    ),
    8080
);

$server->run();
?>

<!-- client.html -->
<!DOCTYPE html>
<html>
<head>
    <title>WebSocket示例</title>
</head>
<body>
    <div id="data"></div>
    <script src="https://cdn.jsdelivr.net/npm/socket.io-client@4.0.0/dist/socket.io.js"></script>
    <script>
        const socket = io('http://localhost:8080');

        socket.on('message', function(data) {
            document.getElementById('data').innerText = JSON.stringify(data);
        });

        setInterval(() => {
            socket.emit('message', { message: 'Hello, World!', timestamp: new Date() });
        }, 5000);
    </script>
</body>
</html>