问题标签 [phpmqtt]

我们正在开发一个基于 Mosquitto 代理的 POC，其中使用了 3 个不同的 MQTT 客户端，即 C、Python 和 phpMQTT，我们需要在这些客户端之间传递消息。但是 phpMQTT 客户端没有实现 SSL/TLS，这限制了我们为整个解决方案启用 SSL。

如果我的 C 和 Python 客户端连接到安全端口上的代理，即 8883（启用 TLS 选项）和端口 1883（没有 TLS 选项）上的 phpMQTT 客户端，是否有任何方法可以在这三个客户端之间进行通信？

我已经在服务器上安装了Mosquitto，它正在运行，并且工作正常。我已经安装了 Paho mqtt 客户端插件来检查。我为android编写了代码，它在模拟器上运行良好。

现在在我自己的计算机上一切正常，我运行 php 代码，我在 android 中的应用程序接收到消息，Paho 客户端也接收到该消息。

但是当我在服务器上上传文件并运行它时，没有任何反应，尽管 php 代码成功地运行了一切，并且发布了没有任何错误的消息。甚至 mosquitto 的发布者可执行文件也可以正常工作，并且客户端会收到消息。

只有服务器上的这个 php 代码不做任何事情。

蓝犀牛 phpMQTT：

我正在尝试使用 Jquery 设置一个网页，该网页将接收来自用户的按钮点击，将这些点击值传递给 PHP 脚本，然后将它们发布到 MQTT 代理。我与经纪人的联系似乎有效。我在将变量从 JavaScript 传递到 PHP 时遇到问题。我究竟做错了什么？

这是我的 JavaScript：

这是我的PHP：

我想使用 PHP 通过 MQTT 协议连接到 IBM Bluemix，以订阅来自 IoT Foundation 的消息。我使用这段代码：

但浏览器显示此消息：

致命错误：/Library/WebServer/Documents/phpMQTT/phpMQTT.php 第 167 行的最大执行时间超过 30 秒

我已经从https://mosquitto.org/download/在我的 Windows 机器上安装了 MQTT 代理。

我正在使用https://github.com/bluerhinos/phpMQTT/tree/master/examples进行发布和订阅。发布按预期工作，但订阅不起作用。

我不明白为什么这不起作用。MQTT 代理需要连接远程 MQTT 服务器吗？我想在 php 中实现发布和订阅方法

发布：

订阅：

错误： 错误的订阅标头

获取错误表单主机错误日志

编辑：

我已经使用命令行运行了订阅脚本，它总是打印“eof receive going to reconnect for good measure\n”意味着总是从feof函数 中得到真实

代码：

我已经使用 chrome 扩展测试了我的发布页面，这意味着使用 chrome 扩展进行订阅，它工作正常意味着读取套接字中有问题。

我CloudMQTT在MQTT broker基于 Pub-Sub 的应用程序中使用它。我正在使用 mypublisher向平台发布数据，并计划CloudMQTT server在我的网页上向代理接收传输的信息。topicsubscribe

我正在使用此过程创建一个Client（订阅者）：https ://www.cloudmqtt.com/docs-php.html

代码如下：

这是phpMQTT.php文件：https ://github.com/bluerhinos/phpMQTT/blob/master/phpMQTT.php

但是，这种情况下的问题是它仅在网页打开时才接收数据。即使网​​页未打开以始终接收已发布的消息，我也想保持连接状态，我该怎么做？

编辑：如果有人可以推荐一些替代方案，我可能愿意在服务器上使用其他一些技术来处理这个订阅过程

我正在使用mosquitto 客户端开发 PHP 项目，我需要检查某些用户何时断开连接并识别用户。

我正在使用仅包含断开连接原因的代码回调函数。

函数，以便我可以处理断开连接事件。

如何将事件链接到数据库中的用户。

谢谢，

我正在尝试在基于 PHP 的页面上使用 MQTT 显示一些值。PHP 代码包含订阅者。我正在为 MQTT 代理使用 Bluemix IoT 服务。此外，消息通过 Python 代码在本地机器上发布。

当我尝试使用页面刷新在页面上显示值时，页面有时无法显示这些值。发布者端没有问题，因为这些值已由 Bluemix IoT 服务成功显示。

我的代码如下：

有人可以指导我哪里出错了吗？

我正在使用 phpMQTT 订阅来自 MQTT 代理的数据。我已经根据他们的基本实现成功地设置了一个 pub/sub 例程。我可以在 procsg() 函数中很好地回显信息。

但是，我需要获取收到的数据并将其用于运行一些数据库操作等。我似乎无法访问在 procmsg() 函数之外收到的主题或消息。如下使用 return 似乎没有产生任何结果。

显然我做错了什么 - 但我如何获得这些值以便我可以在 procmsg() 之外使用它们？非常感谢。

我有一个应用程序，我在其中订阅了 MQTT 代理上的主题。收到消息后，我需要处理消息中的数据并将其发布回同一代理，在不同的主题上。我正在使用 PHPMQTT 的 Lightning 分支，因为它维护良好（github repo）。

我的脚本如下。

我可以订阅'net/raw'就好了。处理也很好。将其发布回代理时会出现问题。如果在第 18 行开始的连接对该函数不可用，则会发生以下错误：

注意：未定义变量：第 35 行 C:\wamp64\www\sub.php 中的 mqtt

致命错误：未捕获错误：在 C:\wamp64\www\sub.php:35 中调用 null 上的成员函数 publish() 堆栈跟踪：0 [内部函数]：{closure}(Object(Lightning\Response)) 1 C:\wamp64\www\vendor\brandonhudson\lightning\Lightning\App.php(353): call_user_func(Object(Closure), Object(Lightning\Response)) 2 C:\wamp64\www\vendor\brandonhudson\lightning\ Lightning\App.php(424): Lightning\App->message('0A') 3 C:\wamp64\www\sub.php(40): Lightning\App->listen() 4 {main} 在 C 中抛出:\wamp64\www\sub.php 第 35 行

我可以在函数内部创建一个新连接，但我不想在一个足够的时候继续打开和关闭新连接。我该怎么做才能使函数内部的连接可用？