与tokio的MQTT连接

文章/答案/技术大牛

发布

1回答

rust、rust-tokio

我正在尝试使用tokio和mqtt_v5机箱中提供的编解码器创建一个MQTT连接。我的代码不能编译，我不明白为什么。这是我到目前为止所写的代码，发送代码可能不正确。::SocketAddrV4;use mqtt_v5::codec::MqttCodec; warning: unused import: `

浏览 35提问于2021-01-15得票数 0

回答已采纳

1回答

我正在尝试使用Tokio包装一个同步的MQTT客户端library。代码需要通过std::sync::mpsc通道连续接收消息，并将消息发送到异步代码中。我知道如何使用spawn_blocking包装返回单个值的代码。但是如何将其应用于包装不断从std::sync::mpsc通道接收消息的循环呢？下面是我用来向通道发送消息的代码。let (mut tx, mut rx) = std::sync::mpsc::channel(); tokio::spawn(async

浏览 37提问于2020-04-12得票数 1

回答已采纳

2回答

使用mqtt用户名与密码的方式连接腾讯云mqtt服务器问题？

云服务器、物联网通信、物联网、mqtt

为什么用mqtt用户名与密码的方法连接腾讯云mqtt服务器后，一段时间(几天)不连接后会自动断开？然后在使用相同的用户名与密码再次连接时就再也连接不上了。1.使用了腾讯给的腾讯云物联网平台生成小工具自动生成用户名与密码结果：使

浏览 1654提问于2021-02-17

1回答

Android Paho Mqtt在wifi重新连接后不重新配置网络。

android、android-service、alarmmanager、mqtt、paho

我正在使用mqtt android客户端来流位置。这可以正常工作，直到互联网连接丢失。mqtt客户端不像预期的那样重新连接。我应该如何确保paho mqtt重新连接到代理。我希望强制mqtt客户端重新连接到代理，并在连接返回时继续发布位置。 private final String CLIENT_ID = "client_id&quo

浏览 2提问于2019-09-02得票数 2

1回答

使用nodejs lib断开与另一个代理的连接后，连接到mqtt代理

node.js、mqtt

我想要实现的场景是，首先我的服务将连接到一个mqtt代理，当我从一个will主题收到一条消息时，我想断开它与我的mqtt客户端所连接的代理的连接，并连接到一些其他的broker.is。var client = mqtt.connect('<

浏览 16提问于2017-12-08得票数 1

2回答

无法从Python Docker连接到mqtt* Docker*

docker、docker-compose、mqtt、mosquitto、docker-network

因此，我有一个托克/蚊子码头集装箱运行，我可以连接从外部码头。import paho.mqtt.client as pahoimport random port = 1883代码的工作原理是连接到没有在docker中运行的mqtt代理。但我想不出怎么让这两个人都跟

浏览 6提问于2020-04-05得票数 5

回答已采纳

2回答

MQTT WebSocket连接失败

websocket、mqtt

每当我在Chrome浏览器的控制台中运行我的代码和视图时，我总是得到与'ws://192.168.0.156:1883/‘WebSocket的连接失败：“。有什么专业人士可以帮助我吗？ /dist/mqtt.min.js"></script> if(window.screen.width > 600){ var width =

浏览 501提问于2021-10-25得票数 0

回答已采纳

3回答

flutter、mqtt

我正在尝试将我的颤振应用程序与mqtt代理连接起来，但不幸的是，这种情况发生了。我能知道为什么会这样吗？日志mqtt-client::NoConnectionException:超过了允许的最大连接尝试({3})。代理没有正确地响应连接请求消息，返回代码是MqttConnectReturnCode.notAuthorized

浏览 7提问于2022-10-14得票数 0

1回答

在MQTT中持久性会话是如何工作的？

mqtt、broker、hivemq、mom、mqtt-vernemq

我在QOS 1中使用MQTT。我有一个消费者和一个制片人。它们彼此通信(HiveMQ作为客户端)。他们使用VerneMQ作为broker。我使用持久性会话。因此，订阅并不是消费者没有收到消息的原因。

浏览 3提问于2019-10-31得票数 0

回答已采纳

1回答

MQTT应用程序使用单个客户端应用程序/库与两个代理连接

java、mqtt、paho

我使用 Java (JAR)连接到MQTT。<

浏览 0提问于2017-07-21得票数 1

1回答

ActiveMQ作为MQTT代理，直接从其中读取消息，而无需客户端

activemq、mqtt

所以我使用ActiveMQ作为MQTT代理，如下所示： TransportConnector mqtt = new TransportConnector();URI uri = new URI("mqtt://some ip");final BrokerService broker = new BrokerService); 我需要

浏览 28提问于2020-10-02得票数 0

回答已采纳

2回答

高效的MQTT代理到Kafka代理的桥接

apache-kafka、mqtt

我需要将传入的传感器数据从Mqtt代理传输到Kafka代理。做这件事最有效的工具是什么？有没有能高效提供Kafka桥插件的中介？

浏览 31提问于2017-08-16得票数 2

1回答

用于AWS EC2实例上的Apache ActiveMQ的SSL

amazon-web-services、ssl、activemq

我有一个配置了一些自签名证书的Java应用程序，它通过ActiveMQ /TLS1.2版与SSL5.13.0版通信。相关的自签名证书驻留在各自的密钥库和信任库中。这种通过TLS的连接在我的本地Windows计算机上工作得很好，没有正确证书的客户端无法与代理通信，而具有正确证书的客户端可以与代理通信。未配置任何证书的客户端能够连接到代理并进行通信。我想知

浏览 19提问于2020-06-16得票数 0

1回答

代理连接失败: mqtt://localhost:1883

mqtt、raspberry-pi3、node-red

我面临的问题是树莓π3与节点红色MQTT之间的连接。mqtt://localhost:1883 8 9月03:27:45 - info连接失败：有人能帮我解决这个错误吗

浏览 2提问于2018-01-17得票数 0

1回答

角CLI代理:将不安全的本地websocket重定向到安全的远程websocket

webpack、websocket、angular-cli、mqtt、reverse-proxy

我试图通过一个反向代理通过Websockets建立一个MQTT连接。如果我能够看到代理向远程服务器发出的确切请求，那么调试它将是非常有帮助的。在目标中包含/mqtt是绝对不必要的，因为在代理发出的最终请求中，我最终得到了/mqtt/mqtt。通过进一步调试，我在我的Kubernetes侵入控制器中发现了以下错误消息：但是，当我使

浏览 16提问于2020-02-14得票数 2

回答已采纳

点击加载更多