问题标签 [phpmqtt]

我在使用 mqtt 和 amqp 通信时遇到问题

重点是：

我有一个带有 MQTT 插件的 RabbitMQ 实例，我也有一个 mqtt 生产者/消费者和一个 AMQP 生产者/消费者（在 symfony RabbitMqBundle 上使用 php-amqplib）

RabbitMQ 文档说所有 MQTT 主题都适用于 amq.topic 交换。

正确的

我的情况：

MQTT 消费者/生产者订阅了 /topic/test 主题 AMQP 消费者在 amq.topic 交换上，在路由键 .topic.test 上（我不知道这一点，但兔子替换 / for . on mqtt 主题）

AMQP 消费 MQTT 消息：OK AMQP 产生消息到 MQTT：NOT MQTT 到 MQTT：OK AMQP 到 AMQP：OK

我的 mqtt pub/sub 是一个 JS 客户端（经过一些测试）我的 AMQP pub/sub 与 php/symfony

OBS：

如果我去 RabbitMQ，在 amq.topic 交换，.topic.test 队列中发送消息，mqtt 客户端接收正确

问题出在php客户端

似乎这在其他语言和库中不会发生：http: //blog.airasoul.io/the-internet-of-things-with-rabbitmq-node-js-mqtt-and-amqp/

我是 MQTT 的新手。任何人都可以帮助如何在 PHP 中使用 Rabbitmq mqtt，我在云中有 MQTT 代理，所以我想在本地系统中基于 PHP 进行开发。我们要下载任何库吗？任何人都可以在 Ubuntu 中提供帮助吗？

我已经mqttlens从google chorme apps.

它在几周内运行良好，但最近当我启动它时它出现在缩放中。

我该如何解决？

.

我有一个yii2带有高级模板的项目，我想使用mosquitto broker. 我已经完成了发布部分并正在工作，现在我想在订阅我的前端应用程序上的主题方面获得一些帮助。我已经尝试过了，但是当我订阅任何主题时，页面似乎停止工作。有什么简单的方法或教程可以使用吗？如果需要更多信息，请询问。

PS：我的想法是：当我在前端打开任何页面时，我会检查消息，将它们保存在一个数组中，将它们设置为视图参数，然后渲染我的页面。

编辑：到目前为止，我已经尝试了以下

班级

SiteController：我试图在 beforeAction 方法上获取消息

我从 cloudmqtt 获取数据时遇到了问题。我已经从这个链接GitHub下载了项目。

订阅.php

在我的文件中，从文件中调用subscribe.php了一个函数名procphpMQTT.php。这是subscribe.php文件代码

phpMQTT.php

在我的phpMQTT.php文件中，定义如下的函数proc 。

如果我set_limit_time(0);在 phpMQTT.php 文件顶部使用。然后，当我subscribe.php在浏览器中浏览时，它永远不会结束加载。

如果我set_limit_time(60);在 phpMQTT.php 文件顶部使用。然后，当我subscribe.php在 60 秒后浏览浏览器时，我得到一些数据（6 个数据）并出现此错误。

致命错误：第 275 行的 C:\xampp\htdocs\phpMQTT\examples\phpMQTT.php 中的最大执行时间超过了 60 秒

第 275 行表明usleep(100000);.

如果我set_limit_time(30);在 phpMQTT.php 文件顶部使用。然后，当我subscribe.php在 30 秒后浏览浏览器时，我得到一些数据（3 个数据）并出现此错误。

致命错误：第 275 行的 C:\xampp\htdocs\phpMQTT\examples\phpMQTT.php 中的最大执行时间超过 30 秒

我哪里错了？我该如何解决这个问题？

我对 paho mqtt 库有一点问题。我注册了一个回调函数 MQTTClient_messageArrived 和 MQTTClient_connectionLost。

我在这个回调函数中调用了 MQTTClient_subscribe() 或 MQTTClient_unsubscribe()。运行此回调函数后。我从 MQTTClient_connectionLost 收到错误代码 (-3)。此外，我打印的原因是NULL。

我的问题有什么可能的问题吗？谢谢

这是我的初始化函数和回调函数：

我正在编写一个程序，将 PHP 中的 Web 服务连接到 MQTT 代理。代理在 Raspberry Pi 上运行 Mosquitto。

这个想法是让 Web 服务发送请求（提交表单），然后将发布发送到 MQTT 代理，然后等待回复。

但是，问题在于循环似乎会导致 PHP 致命错误，因为它是一个无限循环。

我尝试添加 quitstop() 函数以在收到消息后退出循环，但程序在到达该点之前崩溃。

MQTT 对我来说仍然很新，但我需要发送请求，然后保持循环打开，直到我收到答案才能继续执行我的程序。

这是处理表单提交的代码：

我们可以使用 Mosquitto 而不是https://fcm.googleapis.com/fcm/send使用 php 从 Web 服务器向 android 用户发送推送通知吗？如果可能的话，请详细解释如何？我阅读了许多 mosquitto 文档，但没有发现我们可以使用与 fcm 相同的技术。

我在 centos 服务器上安装了 mosquitto 代理。为了交流，我安装了 Mosquitto-PHP 库。发布者和订阅者在同一台服务器上工作正常，但是当我试图从这个 centos 服务器发布消息并从本地机器（ubuntu）运行订阅者脚本时，出现以下错误 -

Mosquitto-PHP 库已经安装在本地机器上。

下面是我正在运行的subscriber.php 文件 -

我正在使用 Mosquitto/Client php 库。我已经在经纪人和客户之间建立了正确的连接。当我执行发布者和订阅者时，订阅者会显示许多消息，但我想在发布者发布消息时获得一条已发布的消息。我将如何通过订阅已发布的消息获得单条消息？

订阅者.php

发布者.php

我想在特定的时间间隔内发布/订阅。Publisher.php 在间隔时间段内发布带有消息的主题，subscriber.php 在间隔时间段内获取带有该消息的主题。