Не удается подключиться к серверу Mosquitto с помощью Mosquitto-PHP - PullRequest
0 голосов
/ 04 апреля 2019

Я установил брокер комаров на сервер Centos.для связи я установил Mosquitto-PHP библиотеку.издатель и подписчик работают нормально на одном сервере, но когда я пытаюсь опубликовать сообщение с этого сервера Centos и запускаю сценарий подписчика с локального компьютера (Ubuntu), то получаю следующую ошибку -

PHP Fatal error: Uncaught Mosquitto\Exception: The client is not currently connected. in /home/sujit/Desktop/php_test.php:12
Stack trace:
#0 /home/sujit/Desktop/php_test.php(12): Mosquitto\Client->subscribe('#', 1)
#1 {main}
thrown in /home/sujit/Desktop/php_test.php on line 12

Библиотека Mosquitto-PHPуже установлен на локальном компьютере.

Ниже находится файл subscriber.php, который я запускаю -

<?php
define('BROKER', 'ip address of server');
define('PORT', 1883);
define('CLIENT_ID', "pubclient_" . getmypid());

$client = new Mosquitto\Client(CLIENT_ID);
$client->onConnect('connect');
$client->onDisconnect('disconnect');
$client->onSubscribe('subscribe');
$client->onMessage('message');
$client->connect(BROKER, PORT, 60);
$client->subscribe('#', 1); // Subscribe to all messages

$client->loopForever();

function connect($r) {
        echo "Received response code {$r}\n";
}

function subscribe() {
        echo "Subscribed to a topic\n";
}

function message($message) {
        printf("Got a message on topic %s with payload:\n%s\n", $message->topic, $message->payload);
}

function disconnect() {
        echo "Disconnected cleanly\n";
}

1 Ответ

0 голосов
/ 04 апреля 2019

Переместите вызов на $client->subscribe('#', 1); внутри обратного вызова onConnect.

...