问题标签 [mosquitto]

我是新手Mosquitto，MQTT我下载了Mosquitto服务器库，但我不知道如何测试它。

有什么方法可以测试Mosquitto服务器吗？

我有一个运行 mosquitto 的远程服务器。我可以使用 mosquitto_pub 和 mosquitto_sub 连接到该服务器并交换消息。如果我尝试使用一些带有 paho.mqtt.client 的 python 进行相同操作，我将无法连接。我的脚本一直在运行，但永远不会调用 on_connection 钩子。但是，相同的脚本可以在我的本地 mosquitto 服务器上完美运行。

连接问题的可能原因是什么？我怎样才能获得更多关于正在发生的事情的反馈？有什么建议么？

编辑：我添加了一个最小的代码示例

编辑2：在玩耍时，我注意到用“test.mosquitto.org”替换“localhost”导致OSError: [Errno 101] Network is unreachable虽然我通过mosquitto_sub连接它没有问题

I am new to Paho android Service and MQTT protocol. I have been trying to write a simple code that connects to the mqtt broker through "xx.xx.xx.xxx:1883". When i run the below posted code, it generates the logcat output.

why i am getting this NPE?

note:

I have the mosquitto server installed

line_35

Code:

logcat:

当我尝试通过这个 JS 连接到 Mosquitto 服务器时，我收到这个错误：

我从控制台尝试过，它工作正常。我尝试使用 Java 客户端作为提供者和消费者，它工作正常。所以我不明白我应该怎么做才能让它工作。

这是 JS：

这是Java（工作）：

我正在尝试使用 MQTT 协议，并且我是一个业余爱好者。我使用 MQTTKit ( https://github.com/jmesnil/MQTTKit )在 Mosquitto 库上尝试了 Objective-C 代码。

我可以使用它将消息发布到一些测试服务器并且一切正常，但我仍然有一些基本问题，对我来说不是很清楚：

1. Mosquitto 库是否也在下面包含 Web 套接字？
2. 是否可以创建连接，订阅主题，然后服务器也可以通过实时行为向设备发布消息？换句话说，我们可以将它用于服务器和客户端（在本例中为 iOS 设备）之间的双向实时通信吗？

我创建了一个client类型MqttClient，如下面的代码所示，我创建了一个客户端并设置了它的Asynchronous callback. 问题是，

1-当我运行程序时，System.out.println("Client is Connected");出现了，但我没有收到onSuccess来自 o 或 o的响应onFailure，为什么？我在代码中做错了什么。

2-我实现了static IMqttAsyncClient asynchClientCB = new IMqttAsyncClient()接口，但由于我有一个类型的客户端MqttClient，我不能使用这个IMqttAsyncClient接口。我尝试使用mqttAsynchClien，但因为我为 java 编程而不是因为Android我不能使用它。如何使用IMqttAsyncClient界面。？

更新_1

在下面的代码“Updated_code_1”中，我稍微修改了代码，但我希望每次成功连接到同步回调中broker​​的消息时都会打印出来，并且在连接终止的情况下打印同步回调中​​的消息，例如当我故意断开网络时。但是在我连接到的时候，既不也不显示任何东西。那么，它们的设计目的是什么？onSuccessonFailurebrokeronSuccessonFailur

*Update_2_17_Dec_2014

我有一个询问可能会引导我们找到解决方案，也就是说，我通过有线/无线网络连接到代理是否重要？这会改变同步和异步监听器的行为吗？

更新_1_code：

新客户：

异步回调：

我正在为我的新 diy 家庭自动化系统设置传感器网络，但遇到了一个主要障碍。我使用 OpenHAB 作为系统的“基地”，并且由于它具有 MQTT 绑定，我认为这将是让所有节点与之对话的好方法。我知道我可以连接到 test.mosquitto.org，这非常适合测试。但是，显然，到目前为止，对于永久服务器来说，这还不够安全（而且，我很确定他们明确表示不要将该服务器用于永久事物）。

经过大量的谷歌搜索，我找到了大量关于 Mosquitto 和 MQTT 的信息，但老实说，因为我刚刚开始，大部分信息都在我脑海中。我的问题是，大多数人似乎已经知道了，我该如何在 Raspberry Pi 上设置自己的 MQTT 服务器来运行所有内容？或者这不是常态，我应该找一个公共服务器（比如 test.mosquitto.org）吗？这似乎不是最实用的方法。

在此先感谢您的帮助。

我们可以阻止设备连接到 MQTT 服务器吗？

我们可以阻止设备订阅主题吗？

我们在 MQTT 服务器上是否有任何设备注册。所以我们只能允许已知设备？如果我们有一些注册机制，我们可以使用 API 动态完成吗？

我一直在阅读有关 MQTT 的信息，并且我了解它使用 TCP 进行网络传输。因此，如果我有一个将发送订阅请求的移动应用程序，我认为这将是一个全双工连接，因此可以通知客户端传入的推送数据。

那么这如何提高电池和网络效率呢？我的意思是你仍然建立了一个开放的 TCP 连接。还有它如何处理断开连接，它会自动重新连接到代理吗？

我已经在 Google Cloud 的 Ubuntu VM 实例中安装了 mosquitto 代理。我还可以看到代理在 VM 的 1883 端口上运行。VM 的外部 IP 是 130.211.173.165 。现在，当我尝试通过命令为该代理创建客户端时

我收到一条错误消息，指出连接被远程 IP 主动拒绝。

我还添加了一条网络防火墙规则，说明以下内容，但似乎没有任何效果。

有人可以帮忙吗？