php stomp消息如何接收 - 问答

要使用PHP接收STOMP消息，您需要安装一个STOMP客户端库，例如stomp.php。以下是使用stomp.php库接收STOMP消息的步骤：

安装stomp.php库：

您可以使用Composer来安装stomp.php库。在命令行中运行以下命令：

composer require cboden/stomp

创建一个PHP脚本以连接到STOMP服务器并订阅主题：

<?php
require_once 'vendor/autoload.php';

use Stomp\Client;
use Stomp\Connection;
use Stomp\Message;

// STOMP服务器连接信息
$host = 'localhost';
$port = 61613;
$username = 'your_username';
$password = 'your_password';

// 创建一个Stomp连接
$conn = new Connection([
    'host' => $host,
    'port' => $port,
    'username' => $username,
    'password' => $password,
    'heartbeats' => ['client' => 10000, 'server' => 10000],
]);

// 连接到STOMP服务器
$conn->connect();

// 订阅一个主题
$topic = '/topic/your_topic';
$conn->subscribe($topic, function (Message $message) {
    echo "Received message: " . $message->getBody() . PHP_EOL;
});

// 保持脚本运行以持续接收消息
while (true) {
    $conn->wait();
}

// 关闭连接
$conn->disconnect();

请确保将$host，$port，$username和$password替换为您的STOMP服务器的实际连接信息。同时，将$topic替换为您要订阅的主题。

运行PHP脚本：

在命令行中，导航到包含您的PHP脚本的目录并运行以下命令：

php your_script_name.php

现在，您的脚本应该已连接到STOMP服务器并订阅指定的主题。每当有新消息发布到该主题时，您的脚本都会接收并打印消息内容。

0 赞

0 踩