-
0 votesanswersviews
使用Kii Cloud Service与Mqtt连接
我试图通过使用Kii Cloud service从浏览器 Build MQTT连接，但它失败了 . 请问任何建议吗？ [事件] 我尝试使用从Kii Cloud MQTT获得的 endpoints Build 连接，但返回了以下错误 . ※我使用paho作为MQTT客户端 . WebSocket连接到'ws：// [我从Kil Cloud获得的主机名]：[我从Kil Cloud获得的端口] / m... -
1 votesanswersviews
在AWS EC2 Ubuntu Ruby on Rails上使用mosquitto设置Paho Javascript客户端（MQTT）
我一直在尝试使用端口1883在我的AWS EC2服务器上设置MQTT代理 . 到目前为止，它与ruby-mqtt gem一起使用，但是我在使用Paho Javascript Client为网站设置时遇到了问题 . 到目前为止我做了什么： Mosquitto 在我的AWS EC2实例上安装了mosquitto，它正在1883端口上运行和监听 . 我使用命令在本地订阅了一个主题 mosquitto_s... -
-1 votesanswersviews
MQTT 1884连接失败
我在我的网站上使用mqtt作为消息传递系统 . 在我的本地机器上一切正常但在我的网站（ 生产环境 ）上我收到一个错误： vendor.bbaf8c4 ... .bundle.js：1与'ws：// localhost：1884 / mqtt'的WebSocket连接失败：连接 Build 错误：net :: ERR_CONNECTION_REFUSED 我在我的Web服务器中使用Ubuntu，... -
0 votesanswersviews
如何将springxd源mqtt注册到mqtt broker
我用spring-Xd创建了一些流，例如 - stream create mqtttestfile --definition "mqtt --url='tcp://localhost:1883' --topics='helloTopic' | file" --deploy 创建并部署了新的流'mqtttestfile' . 我还检查了localhost：9393 / admi... -
-2 votesanswersviews
可以将MQTT Paho客户端断开连接吗？
我有一个 MQTT 客户端（让我们称之为Client-1）使用java PAHO，这是pub并且没有问题的子主题，在地球的另一边我有另一个客户端（让我们称之为SuperClient），可以公共主题作为命令为我的客户...... 其中一个命令是"DISCONNECT-NOW"，在我的 Client-1 中我已经实现了回调，我正确地接收到了msg，但是，当我尝试根据该命令断开连接时... -
2 votesanswersviews
如何订阅MQTT主题并在Eclipse（Java）上打印收到的消息
我有一个带恒温器的微控制器，它使用MQTT协议通过Raspberry Pi将数据发送到我的计算机 . Kura已经安装并在Raspberry上工作 . 我在Putty上接收数据没有问题，但现在我需要在Eclipse上接收它，所以我可以开发一个程序 . 我设法使用Paho使用以下代码通过eclipse发布主题（这是对其他主题的改编Subscribe and Read MQTT Message Us... -
0 votesanswersviews
在等待消息时发送消息
我使用mqtt协议将传感器数据的消息发送到mosquitto代理 . 我想做的是每隔t秒发送一次传感器数据，但如果我收到一条消息并行处理它 . 我很惊讶使用time.sleep（）但我认为这也会延迟“on_message”功能 . 我使用的是paho-mqtt和python 2.7 . 关于如何完成这样的事情的任何想法？ 客户No1 . （发送传感器数据） from mysignals impor... -
2 votesanswersviews
MQTT订阅客户端在连接后不会收到消息
我正在努力学习MQTT并一直在玩它 . 我写了一个发布客户端和一个订阅客户端（见下文） . 如果我运行订阅客户端然后运行发布客户端（当订阅正在运行时），那么一切正常 . 我的订阅客户端正确接收发布到该主题的消息 . 但是，如果我首先运行发布客户端（即我向主题发布消息）然后运行订阅客户端，则不会收到任何消息 . 换句话说，如果我先连接子客户端然后在连接子客户端时使用pub客户端发布消息，一切正常 .... -
2 votesanswersviews
在覆盆子pi中使用mqtt paho for Python
我正在尝试使用raspbian中的python 2.7连接到消息代理，如下所示： import paho.mqtt.client as paho host="messagesight.demos.ibm.com" port=1883 def on_connect(pahoClient, obj, rc): # Once connected, publish message... -
1 votesanswersviews
Paho Java - 文件持久性
我最近开始使用paho mqtt for java和mqtt，我坚持使用mqtt broker和paho client提供的持久性机制 . 也许我在mqtt的背景下误解了（很可能是）持久性的概念 . Use case which we have to support is following ：应该有可能我们的mqtt客户端断开了7天（我非常怀疑它会发生，但是没问题）甚至应用程序关闭而不会在这7天... -
0 votesanswersviews
PAHO MQTT Python客户端 - 确认丢失，保证用户交付
同事们， 我正在看Paho MQTT客户端（用于Python），我想我理解发布者的QoS设置，例如传感器或任何数据源确实有意义 - 您希望能够确保已经（通过代理/服务器）收到消息 . 我还认为从订阅者的角度来看，请求例如QoS "2"以确保MQTT服务器确实将每条消息发送给订户，但我正在努力解决这个问题：订户似乎没有办法表示收到消息的成功（或不）处理成功，换句话说，某种明确的确... -
0 votesanswersviews
MQTT Python QOS 0未交付
我使用paho-mqtt库与以下发布者代码： def on_publish(client, userdata, mid): print dir(userdata) print "published"+str(userdata ) client.disconnect() mqttc = mqtt.Client() # There's normally n... -
0 votesanswersviews
当另一个客户端连接到服务器时，Mqtt客户端断开连接
我是MQTT消息传递系统的新手，但我设法在运行AOSP kk-4.4.2的snapdragon板上实现了paho Android服务 . 我的服务将在启动时启动，它将通过端口1883连接到HiveMQ的公共代理 . 问题是将运行我的自定义AOSP的Android设备连接到服务器后，如果我尝试从手机上运行的Android应用程序连接另一个客户端 . snapdragon板中的客户端自动断开与服务器... -
0 votesanswersviews
MOsquitto意外断开连接
我正在使用python mosquitto（paho）库 . 我遇到了问题 Unexpected disconnection. 我发现不断丢弃并与服务器连接 . . 我无法找到问题所在 . 有时它显示[错误104]连接由同行重置 . 我在亚马逊网络服务上托管我的经纪人...我的错误是--- 连接到xx.xx.xx.xx:1883 意外断开连接 . 连接到xx.xx.xx.xx:1883 意外断... -
0 votesanswersviews
创建Android NativeScript插件
我正在尝试创建一个允许NativeScript应用程序连接到MQTT服务器的插件 . 当我尝试运行应用程序时，我的应用程序中出现以下错误： java.lang.RuntimeException：无法启动活动ComponentInfo {org.nativescript.testMQTT / com.tns.NativeScriptActivity}：com.tns.NativeScriptExc... -
0 votesanswersviews
Paho Mqtt Client一次发布所有消息而不是一个一个
我正在通过mqtt从我的传感器节点收集遥测数据到我的覆盆子pi . 有两个MQTT客户端连接到本地主机上的代理和我的VPS上的代理 . pi从传感器节点收集数据并将其发送到我的VPS服务器 . 如果pi离线，它将收集本地数据库中的所有值，然后，在重新连接之后，它应该将消息逐个发送到VPS . 通常情况下，消息会逐个发布 . 但是当它断开然后重新连接时，它会创建一个线程“redundancywor... -
0 votesanswersviews
使用外部ip连接到RabbitMQ服务器
我正在尝试使用RabbitMQ实现MQTT协议 . 我已经安装了RabbitMQ服务器并将MQTT端口从1883更改为80.我能够从网络发布和订阅服务器 . 但是当我尝试使用外部IP发布或订阅时，我收到“超时”错误 . 任何人都可以分享如何使用外部IP发布或订阅？