问题标签 [mqtt]

我正在为 Android 编写一个 MQTT 客户端。我正在使用 ia92 库 (wmqtt.jar) 并尝试从 MQ 获取消息，以便将它们显示为 android 通知。我的问题是我第一次尝试连接MQ时，我的android客户端应用程序连接成功，并且可以正常获取MQ消息。当我关闭 Wi-Fi 并断开网络连接时，MQTT 客户端连接按预期断开，但是当我再次打开它时，应用程序没有建立 MQ 连接并抛出 MQTTException，没有错误代码。

这有什么问题？我非常需要任何一点帮助..

提前致谢

我已经搜索了很长时间，但我还没有找到任何有用的东西。
我正在尝试实现一个 MQTT-Javascript-Client。随着 Mosquitto V1.0 的发布，在http://mosquitto.org/js/mosquitto-1.0.js上发布了一个 javascript/websocket-client。
但我不知道如何以正确的方式实现这一点。
例如：我使用http://broker.mqttdashboard.com上的示例服务器作为代理。当我在我的 xampp-Server 上运行以下 html 时，没有任何反应，并且在代理端没有连接客户端。我认为我实现它的方式有一些不正确的地方。如果有人可以帮助我，那就太好了。

我也知道 node.js-thing，但我更喜欢使用 websocket-way。谢谢。

我的应用程序通过 Websphere AS 上的 JMS 接收 MQTT 消息。MQTT 端点是一个 Websphere MQ。

有什么方法可以识别消息的发送者（发送设备，而不是 Websphere MQ ;-)）？我在 jms 消息头中找不到匹配的字段...

我们正在研究适用于 Android 的推送通知平台（Google 的 C2DM 的故障转移）我正在使用 Eclipse Paho Java 客户端连接到 mosquitto 代理（1.0.3）。代理安装在 Ubuntu 12.04（AWS EC2 实例）上，我使用非加密 TCP 连接成功地将客户端连接到服务器。顺便说一句，在调整内核参数后，我能够在中型 EC2 机器上为一个代理实例打开 10 万个并发客户端。干得好，蚊子！

现在我正在尝试使用 SSL 建立安全连接。我想使用客户端证书对客户端进行身份验证。我按照蚊子tls页面中的说明为服务器和客户端生成了密钥和自签名证书。将服务器配置为使用 SSL。

对于客户端部分，我查看了 mosquitto_tls_set 的签名并注意到它需要 CA 证书、客户端密钥和证书文件。我认为CA证书用于客户端对服务器进行身份验证，而客户端密钥和证书用于服务器对客户端进行身份验证。我对吗？

所以我在这里是我在 Java 方面所做的：

1. 使用 bouncy castle 加载上述三个文件。
2. 将 CA 证书放入密钥库并使用它来创建 TrustManagerFactory。
3. 将客户端密钥和证书放在另一个密钥库中，并使用它来创建 KeyManagerFactory。
4. 创建了一个 SSLContext 并使用两个工厂对其进行了初始化。
5. 从 SSLContext 创建一个 SSLSocketFactory 并将其传递给 Paho 的 MqttConnectOptions

当我进行连接时，我从 mosquitto 收到以下错误

编辑：现在我在客户端看到以下异常

这是完整的代码

蚊子.conf 看起来像这样

我尝试在 Mosquitto 和 ActiveMQ 上使用 eclipse paho。当keepalive少于30​​秒时，一切正常。当 keepalive 超过 30 秒时，服务器会在大约 5 分钟后断开连接。

我们已经有一个推送通知系统，它由服务器端的 Websphere MQTT 和 Android 端的 Paho 客户端组成。我们现在想把它的范围扩展到Windows Phone 8，但据我从微软的文档中了解到，为了在WP8中实现通知，有必要使用MPNS。我的问题是，我们是否有任何解决方法来使用我们现有的通知系统（Websphere MQTT）而不使用 MPNS 的任何部分？

我们编写的 .NET 客户端与我们的系统完美配合，我相信经过一些修改后它可以在 WP8 平台上运行，不知何故。

提前致谢

我在Windows7平台上安装xampp-v9，android打开sql apache，并安装mqtt代理，确保mqtt服务已打开，使用mqtt php管理器服务器，当我运行时，显示为follos

Tokudu Android Push Demo Server 状态：connect(SAM_MQTT, array(SAM_HOST => '127.0.0.1', SAM_PORT => 1883)); if ($result) { $conn->disconnect(); print_r("在线"); } else { print_r("离线"); } ?>

所以为什么？

我在一个 android 应用程序中使用 MQTT，使用 Eclipse Paho 页面上的最新 jar。

我通过在 1 的 QOS 下发送偶尔发布来手动检查连接，如果在特定超时下未交付，我断开 MQTT 并重新连接。当数据连接丢失然后重新连接时，我也强制重新连接。

问题是 disconnect 方法会挂起线程并且永远不会完成 - 即使超时为零或负超时。它应该有一个 30 秒的内部超时，但它已经过了很长时间并且永远不会完成。

MqttClient 对象需要断开连接，否则它会在后台处理数据。我现在正在做的是分离一个单独的线程来断开 MQTT，然后完全创建一个新的 MqttClient。它停止使用数据，但这是一个糟糕的解决方案，因为新线程只是挂起。

有任何想法吗？

编辑：在进一步调查中，它似乎阻止了尝试在第 70 行停止 CommsReceiver：

我有一个 C# 桌面插件应用程序，我需要 dds 实现插件通信，我尝试了 openslicdds、opendds 和 MQTT 消息传递协议。

我找不到轻量级的解决方案，主要是因为需要与我的应用程序一起安装的轻量级 C# 服务器不可用，或者它们中的大多数都依赖于 cygwin。

我们也希望这必须用 mono 编译才能在 linux 中运行。

我也尝试过使用 MSMQ，但默认情况下未启用它，也不支持发布订阅模式。

如果有的话，请向我推荐一个轻量级的免费解决方案。

我正在尝试使用 paho 客户端库在我的 android 服务中创建一个 mqtt 客户端。mosquitto 代理正在我的本地机器上运行。当我尝试创建 MQTTClient 的新实例时，我收到了 MqttPersistenceException 异常。

//创建客户端端口=1883 mqttConnSpec="tcp://"+ipaddressOflocalMachine+":"+端口 mqttClient = new MqttClient(mqttConnSpec, mqttClientId)

例外没有给出任何理由。我能够成功地使用 java 控制台应用程序进行通信。在android模拟器中运行它时是否需要额外的东西。任何帮助深表感谢

谢谢本