PHP怎样处理STOMP心跳包 STOMP心跳包处理技巧保持长连接稳定

<?php

use Stomp\Client;
use Stomp\Exception\StompException;

$stompHost = 'tcp://localhost:61613';
$stompUser = 'guest';
$stompPass = 'guest';
$destination = '/queue/test';

$maxRetries = 5;
$retryDelay = 1; // seconds

for ($attempt = 1; $attempt <= $maxRetries; $attempt++) {
    try {
        $stomp = new Client($stompHost);
        $stomp->setLogin($stompUser, $stompPass);
        $stomp->setReadTimeout(10); // 设置读取超时时间
        $stomp->connect();

        echo "Connected to STOMP server on attempt {$attempt}\n";

        // 发送消息
        $stomp->send($destination, "Hello, STOMP!");
        echo "Sent message to {$destination}\n";

        // 接收消息
        $stomp->subscribe($destination);
        $msg = $stomp->readFrame();

        if ($msg != null) {
            echo "Received message: " . $msg->body . "\n";
        } else {
            echo "No message received\n";
        }

        $stomp->unsubscribe($destination);
        $stomp->disconnect();

        break; // Connection successful, exit loop

    } catch (StompException $e) {
        echo "Connection failed on attempt {$attempt}: " . $e->getMessage() . "\n";
        sleep($retryDelay);
        $retryDelay *= 2; // Exponential backoff
    } catch (\Exception $e) {
        echo "An unexpected error occurred: " . $e->getMessage() . "\n";
        break; // Exit loop on unexpected error
    }
}

if ($attempt > $maxRetries) {
    echo "Failed to connect after {$maxRetries} attempts\n";
}

?>