问题标签 [mqtt]

我有一个大问题，我找不到解决方案。需要你的帮助。

当我尝试使用 service 在活动中仅发送一条消息时，它可以工作。但是当我尝试在另一个之后发送 2 条消息（这意味着一个接一个），使用相同的 publishTopic2 和 pushMsg2 发送消息两次。

代码是：

1-这是由于同步关键字的错误使用造成的吗？2-是否可以在没有的情况下一个接一个地发送两个味精

我使用 fusesource 代码将 mqtt 消息发布到 Apollo 服务器时遇到问题。我用如下代码编写了消息发布者

我还编写了订阅该主题的消息消费者。如果我先启动消费者，再启动发布者，消费者可以正确获取所有消息。但是，如果我先启动发布者再启动消费者，消费者将不会收到消息。另外，我进入了 Apollo 管理控制台，在队列中找不到任何消息。（请参阅随附的屏幕截图）。

我应该怎么做才能解决这个问题？我不能让我的消费者一直运行，我不想丢失来自发布者的任何消息。当消费者离线时，代理（Apollo）不应该保留所有消息吗？如果是，我怎么看不到？

这似乎是一个愚蠢的问题，但我对 MQTT 很陌生，我确实需要一些帮助。

我对 MQTT 的功能和整体推送设计有一些简短的问题。所以这里有一个场景，让我们以 Twitter 为例；Twitter 希望向个人用户发送推送通知。因此，假设您在我发推文时订阅了我的通知主题。这将是 MQTT 的适当主题层次结构和用例吗？

根据我对发布/订阅系统的了解，这会变得非常麻烦。您不必为每个单独的用户设置一个主题吗？这类系统中的主题是否有限制？拥有数百万用户的大型应用程序如何发送推送通知？

我遇到了这个问题，在一个测试程序中，我正在为 MQTT 开发一个客户端，我订阅了一个主题，之后，我等待从服务器到我的客户端的“发布”消息。

在良好的接收（发布消息）或接收超时后，我向服务器发送一个 mqtt PINGREQ。

在 A PINGREQ 之后，我将等待 PINGRESP，然后我调用 recv，就像我在等待 PUBLISH 消息一样。

如果流程是这样的：

比服务器发布消息丢失。如何解决这个问题？我在 QOS 0 上使用 MQTT，在这个 QOS 级别上解决这个问题是有意义的，还是在 QOS1 上检查这个案例是明智的？

我们计划使用 MQTT 将消息从我们的服务器传递到我们决定使用开源服务器 mosquitto 的 android 设备。

在大多数情况下，这已经足够了。（发布/订阅）但我们有客户端需要发送参数并从服务器获取响应的情况。我知道直接的方法是使用 Http（例如 Servlet）。但是我们可以使用 MQTT 来实现这一点，因为这意味着用户的带宽消耗会降低吗？

我是 Mosquitto 的新手，我想写一个简单的 C 客户端连接到 Mosquitto 的测试服务器：http ://test.mosquitto.org/

这是简单 C 客户端的代码，它是 Mosquitto 网站上示例的 99.9%：http: //pastie.org/private/orwicqjfjz8g8biurznca

编辑1：

我按照评论写了一个makefile而不是做

生成文件如下所示：

这是我得到的输出，这似乎是将 mosquitto 库与 gcc 链接起来的一些问题：

注意：我使用自制软件安装 mosquitto，所以 lib 的路径是

感谢任何帮助！

问候

我正在对 MQTT 进行一些试验，但我遇到了一些奇怪的问题。这可能是由于我的特定设置，但我想我还是会问。

我使用 Node.JS 和 mqttjs 作为代理。我还在使用用 Java 编写的 IBM ia92 测试客户端。

当我订阅一个主题/system/app，然后我向/system/appp我的客户发布一条消息时，我会收到这条消息，尽管主题名称不一样。请注意，如果我发布到/system/ap我不会收到消息。当然发布/system/app工作正常。

这是否意味着 MQTT “自动填充”到类似的东西，或者这是客户端/代理中的错误？我知道+和#通配符，但我不知道这个“功能/错误”。

我正在使用的经纪人可以在这里找到：

https://github.com/adamvr/MQTT.js/blob/master/examples/server/orig.js

它在第 23 行有一些奇怪的正则表达式，我试图弄清楚为什么需要它以及它的作用。如果这不是功能，也许它可能是导致错误的原因？如果有人对此有任何想法，我将不胜感激。

我们正在考虑在我们正在构建的新设备上使用 MQTT 作为消息传递协议。我们还想要该设备的 Web 界面。有谁知道您是否可以实现与 MQTT 对话的浏览器客户端应用程序（无需额外插件）？

我正在用 COSM 测试 MQTT。

要发布数据，我使用以下命令：

要订阅，我使用以下命令：

我希望在订阅方面，只要更新提要或数据流，它就应该获得更新状态。但我只在订阅后立即获得设备的当前状态。

我错过了什么吗？

我正在为 android 构建一个简单的 MQTT 客户端，并且在 RMBS 控制台上出现“客户端标识符的套接字错误”错误。这只发生在客户端的 android 实现中（我还创建了一个 Java 桌面客户端并且运行没有问题）。对于 Android 客户端，我正在起诉 Paho Java 客户端库。这是我的代码：

这是安卓客户端：

这是桌面 Java 客户端：

只是一些注意事项：

我通过 WiFi 连接到我的 android 设备，当我运行 Java Dekstop 客户端时，我的桌面也是如此。

Java Destop 客户端与 RSMB 在同一台机器上运行

Java 桌面客户端创建并订阅主题“House/Kitchen/Bulb”并发送带有字符串“Hello”的消息

Android 客户端还订阅“House/Kitchen/Bulb”并尝试显示带有接收到的消息的 Toast。

我在 android manifest 上添加了 Internet 权限

android 设备似乎可以很好地连接到代理，但是一旦我初始化 Java 桌面服务客户端（或 Eclipse 中的 Paho 客户端插件并发布消息），我就会收到提到的错误。

我在 RSMB 运行的同一台机器上使用模拟器运行了应用程序，我得到了同样的错误。

可能是什么问题？

更新：

最初，我遇到了“主线程上的网络”异常，因此我将连接操作移至 AsyncTask。现在，当我使用 Java 客户端发布消息时，Android 客户端似乎仍处于连接状态（Asynctask 可能一直在创建问题），但似乎没有调用 MqttCallback() 的 messageArrived()。

更新 2：

我设法使它工作。这是我现在使用的代码：