paho

1热度

1回答

我有一个AndroidService来侦听MQTT消息。以下是代码。出于某种原因，服务能够连接和订阅频道，但无法读取消息。 messageArrived永远不会被调用。 public class FollowService extends Service implements MqttCallback{ private final IBinder localBinder = new F

0热度

1回答

订阅Carriots流

我正在尝试使用paho mqtt客户端来订阅carriots数据流。但我无法从卡车上读取任何数据。这里是我用来订购carriots的源代码。 #!/usr/bin/env python # -*- coding: utf-8 -*- # Client paho-mqtt CarriotsMqttServer # sub_carriot.py import paho.mqtt.subsc

3热度

2回答

主机网络的Docker容器网络性能非常慢

我遇到了Docker容器和主机网络之间网络性能不佳的问题。我在Docker的论坛上问了这个问题，但到目前为止还没有收到答案。问题设置：在同一本地网络上的两台Mac;第一个运行MQTT经纪人（mosquitto）;第二个运行Mac的Docker。两台C++程序在第二台Mac上运行，并使用Paho MQTT C库通过MQTT代理（第一台Mac）多次交换数据。本机运行：当我原生运行两个C++程序时，

0热度

1回答

无法订阅paho mqtt java

我是mqtt新手。入门我尝试向蚊子经纪人发布和订阅主题。我能够发布消息。但是我的用户并没有听到这个话题，它会在没有等待/查询消息的情况下开始和停止。下面是用户代码， public class MqttSubscriber implements MqttCallback { private static final String TOPIC = "iot/endpoint"; public

0热度

1回答

当新客户端连接到代理时，java paho提供任何回调

当新客户端连接到代理时，java paho是否提供任何回调。我想用这个回调做自定义验证。每次客户端连接时，我都会读取用户名&密码和一些其他信息进行身份验证。如果一切顺利，那么它应该被连接，否则拒绝。

1热度

1回答

Paho Android客户端在显示消息时断开连接

我试图使用基本的Eclipse Paho MQTT客户端1.1.0版连接到CloudAMQP RabbitMQ实例，订阅主题并接收消息（我通过网络发送消息管理控制台）。如果应用程序将所有消息载荷发送到日志输出，它会很好地工作。如果应用程序将消息添加到TextView中，则会显示该消息，但该连接会立即丢弃，并且不会收到更多消息。完整的项目可在GitHub。下面是一个简单的例子。有一个基于服务

-3热度

1回答

Mqtt服务与MqttAndroidClient联合

我有一个应用程序使用Mqtt服务来设置通知。但是，当应用程序强制关闭时，客户端没有收到消息。我注意到有MqttServce。我如何将它与Android客户端结合使用？

1热度

1回答

在AWS EC2上设置带有mosquitto的Paho Javascript客户端（MQTT）Ubuntu + Ruby on Rails

我一直试图在我的AWS EC2服务器上使用端口1883设置MQTT代理。到目前为止，它与ruby-mqtt gem一起工作，但我在使用Paho Javascript Client进行网站设置时遇到了麻烦。我迄今所做的： Mosquitto 我的AWS EC2实例安装mosquitto，并在运行并监听端口1883我订阅的话题在本地使用命令 mosquitto_sub -h localhost -

4热度

1回答

Paho（MQTT）客户端无法连接

我正在使用此python脚本来实现基本的Paho（MQTT）订阅者，但在某些情况下它不会调用on_connect。我尝试以下，都具有完全相同的代码：在Raspbery PI运行，在台式电脑（Ubuntu的）经纪人。作品。在Pc（Ubuntu）中运行，经纪人在同一台PC上。不起作用。在Pc（Ubuntu）中运行，在其他Pc（Ubuntu）上运行。不起作用。在Pc（Ubuntu）中运行

1热度

1回答

Paho MQTT Golang协议

我是Golang和mqtt的新成员。我试图连接到一个经纪人。它适用于我使用MQTT.fx或我的终端与蚊子。但在我的计划，我创造我OPTS与地址& clientID的，当我尝试连接有错误“不明协议” 恐慌：网络错误：未知的协议够程1 [运行]：恐慌（0x347b20，0xc820072fe0） /usr/local/go/src/runtime/panic.go:481 + 0x3e6 ma