PHP와 WebSocket을 사용하여 실시간 모니터링 애플리케이션을 개발하는 방법

composer require cboden/ratchet

use RatchetMessageComponentInterface;
use RatchetConnectionInterface;

require 'vendor/autoload.php';

class MyServer implements MessageComponentInterface {
    protected $clients;

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

    public function onOpen(ConnectionInterface $conn) {
        $this->clients->attach($conn);
        echo "New client connected: {$conn->resourceId}
";
    }

    public function onMessage(ConnectionInterface $from, $msg) {
        echo "Received message from client: {$from->resourceId}
";
        $data = json_decode($msg, true);
        // 处理接收到的消息
        // ...
    }

    public function onClose(ConnectionInterface $conn) {
        $this->clients->detach($conn);
        echo "Client disconnected: {$conn->resourceId}
";
    }

    public function onError(ConnectionInterface $conn, Exception $e) {
        echo "An error occurred: {$e->getMessage()}
";
        $conn->close();
    }
}

$server = new RatchetApp('localhost', 8080);
$server->route('/monitor', new MyServer(), ['*']);
$server->run();

var socket = new WebSocket('ws://localhost:8080/monitor');

socket.addEventListener('open', function(event) {
    console.log('Connected to server');
});

socket.addEventListener('message', function(event) {
    console.log('Received message from server: ', event.data);
    // 处理接收到的消息
    // ...
});

socket.addEventListener('close', function(event) {
    console.log('Disconnected from server');
});

// 发送消息给服务器
function sendMessage(message) {
    socket.send(message);
}

use RatchetMessageComponentInterface;
use RatchetConnectionInterface;

require 'vendor/autoload.php';

class StockMonitor extends MyServer {
    protected $stocks = [
        'AAPL' => 0, // 苹果公司股票
        'GOOGL' => 0, // 谷歌公司股票
        'MSFT' => 0, // 微软公司股票
    ];

    public function onOpen(ConnectionInterface $conn) {
        parent::onOpen($conn);
        $this->sendStockPrices($conn); // 发送股票价格给新连接的客户端
    }

    public function sendStockPrices(ConnectionInterface $conn) {
        // 模拟获取股票价格
        foreach ($this->stocks as $symbol => $price) {
            $this->stocks[$symbol] = rand(100, 200); // 随机生成股票价格
        }

        $conn->send(json_encode($this->stocks));
    }
}

$server = new RatchetApp('localhost', 8080);
$server->route('/monitor', new StockMonitor(), ['*']);
$server->run();

var stockPrices = {};

function displayStockPrices(prices) {
    // 展示股票价格
    // ...
}

var socket = new WebSocket('ws://localhost:8080/monitor');

socket.addEventListener('open', function(event) {
    console.log('Connected to server');
});

socket.addEventListener('message', function(event) {
    var prices = JSON.parse(event.data);
    stockPrices = prices;
    displayStockPrices(prices);
});

socket.addEventListener('close', function(event) {
    console.log('Disconnected from server');
});

// 发送消息给服务器
function sendMessage(message) {
    socket.send(message);
}