Возникла проблема с отправкой сообщения из облака на устройство через концентратор rabbitmq (протокол amqp) - PullRequest
Новая
       24

Возникла проблема с отправкой сообщения из облака на устройство через концентратор rabbitmq (протокол amqp)

0 голосов
/ 05 марта 2019

Я хочу отправить сообщение из облака на устройство iot hub с протоколом amqp, для этого я использую брокер сообщений rabbitmq со ссылкой в php.Я пробовал приведенный ниже код на localhost: 

//send.php
    <?php
        require_once __DIR__ . '/vendor/autoload.php';
    use PhpAmqpLib\Connection\AMQPStreamConnection;
    use PhpAmqpLib\Message\AMQPMessage;

    $connection = new AMQPStreamConnection('HUBNAME.azure-devices.net', 5671
    , 'HUBNAME.azure-devices.net/DEVICENAME/?api-version=2018-06-30'
    , 'SharedAccessSignature sr=HUBNAME.azure-devices.net
    &sig=XXXX&se=XXXX&skn=iothubowner');

    $channel = $connection->channel();
    $channel->queue_declare('hello', false, false, false, false);
    $json = '{"id":123, "value":"xyz"}';
    $msg = new AMQPMessage($json);
    $channel->basic_publish($msg, '', 'hello');    
    echo " [x] Sent 'Hello World!'\n";    
    $channel->close();
    $connection->close();

, когда я запускаю этот send.php файл, я получаю ошибку:

фатальная ошибка: Uncaught PhpAmqpLib \ Exception \ AMQPConnectionClosedException:Разорванный канал или закрытое соединение в C: \ xampp \ htdocs \ amqp \ vendor \ php-amqplib \ php-amqplib \ PhpAmqpLib \ Wire \ IO \ StreamIO.php: 222

Пожалуйста, помогите мне.

1 Ответ

0 голосов
/ 06 марта 2019

Вы не можете отправлять сообщения Cloud-to-Device с вашего IotHub с помощью rabbitmq.

"Вы отправляете сообщения« облако на устройство »через конечную точку, ориентированную на службу (/ messages / devicebound) . Затем устройство получает сообщения через конечную точку, специфичную для устройства (/devices/ndomdeviceIdcasts/messages/devicebound).

Чтобы настроить таргетинг каждого сообщения облако на устройство на одном устройстве, IoT Hub устанавливает для свойства в значение / devices / {deviceId} / messages / devicebound . "

Подробнее здесь .

Вы можете \ должны использовать SDK службы Azure IoT Hub Service -см здесь .

...