php stomp消息如何接收

PHP
小樊
81
2024-09-28 15:00:19

要使用PHP接收STOMP消息，您需要安裝一個(gè)STOMP客戶端庫(kù)，例如stomp.php。以下是使用stomp.php庫(kù)接收STOMP消息的步驟：

  1. 安裝stomp.php庫(kù)：

您可以使用Composer來(lái)安裝stomp.php庫(kù)。在命令行中運(yùn)行以下命令：

composer require cboden/stomp
  1. 創(chuàng)建一個(gè)PHP腳本以連接到STOMP服務(wù)器并訂閱主題：
<?php
require_once 'vendor/autoload.php';

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

// STOMP服務(wù)器連接信息
$host = 'localhost';
$port = 61613;
$username = 'your_username';
$password = 'your_password';

// 創(chuàng)建一個(gè)Stomp連接
$conn = new Connection([
    'host' => $host,
    'port' => $port,
    'username' => $username,
    'password' => $password,
    'heartbeats' => ['client' => 10000, 'server' => 10000],
]);

// 連接到STOMP服務(wù)器
$conn->connect();

// 訂閱一個(gè)主題
$topic = '/topic/your_topic';
$conn->subscribe($topic, function (Message $message) {
    echo "Received message: " . $message->getBody() . PHP_EOL;
});

// 保持腳本運(yùn)行以持續(xù)接收消息
while (true) {
    $conn->wait();
}

// 關(guān)閉連接
$conn->disconnect();

請(qǐng)確保將$host，$port，$username和$password替換為您的STOMP服務(wù)器的實(shí)際連接信息。同時(shí)，將$topic替換為您要訂閱的主題。

  1. 運(yùn)行PHP腳本：

在命令行中，導(dǎo)航到包含您的PHP腳本的目錄并運(yùn)行以下命令：

php your_script_name.php

現(xiàn)在，您的腳本應(yīng)該已連接到STOMP服務(wù)器并訂閱指定的主題。每當(dāng)有新消息發(fā)布到該主題時(shí)，您的腳本都會(huì)接收并打印消息內(nèi)容。

0 踩