c++ - 使用 Paho MQTT C++ 连接到 AdafruitIO-6ren

c++ - 使用 Paho MQTT C++ 连接到 AdafruitIO

转载作者：行者123 更新时间：2023-12-03 07:23:29

我正在尝试使用 paho C++ 创建到 AdafruitIO 的 TLS 连接。我可以使用 1883 非 TLS 连接并与之交互，但是当尝试让 TLS 继续使用 8883 时，它无法连接。我可以使用 mosquitto C++ 库在 C++ 中执行此操作，但这已被弃用，所以我试图将我的代码移过来。我怀疑我只是没有告诉 Paho 库关于缺乏证书的足够多的信息，但是除了下面的 API 之外，我找不到可能会这样做的 API。或者，我可以使用证书或存储在标准 RPi 镜像上进行连接吗？ mosquitto 库不需要我使用证书，它只是愚蠢地工作。下面是适用于 1883 的代码，但不适用于 8883。这是一个使用回调类尝试更好地模仿最终设计的小型测试应用程序。我知道我在这里并没有真正正确地使用它，但大多数情况下，我只是想修复连接以便我可以发布，然后我可以回去清理设计。

我可以以某种方式使用系统证书文件吗？我承认我对 TLS/SSL 的工作原理不是很熟悉，所以如果可能的话，我不确定如何使用该系统来帮助我解决这个问题。老实说，根据 PAHO 调试日志，它可以连接，但在服务器端某处失败，看起来像，虽然我不知道在哪里或为什么。也许只是无缘无故的拒绝？

对最好的方法有什么想法吗？我计划在我正在构建的 RPi 项目上运行它，但目前正在 Ubuntu 19.04 桌面上进行测试。我也使用 cmake 和 C++17。怀疑这会有所不同，但我会添加它。

主.cpp

#define AIO_USERNAME    "yyy"
#define AIO_KEY         "xxx"
#define AIO_PORT        "8883"
#define TEST_FEED       "default/feeds/test"

void connected()
{
    std::cout << __FUNCTION__ << ": successful connection established" << std::endl;
}

void connectionLost(const std::string &cause)
{
    std::cout << __FUNCTION__ << ": Lost connection: " << cause << std::endl;
}

int main(int argc, char **argv) {
    mqtt::async_client client("tcp://io.adafruit.com:8883", "tls_test_client");
    mqtt::connect_options connopts(AIO_USERNAME, AIO_KEY);
    mqtt::ssl_options sslopts;
    LocalMQTTCallback callback(client, connopts);
    nlohmann::json json;

    json["value"] = 199;

    callback.setConnectedCallback(connected);
    callback.setConnectionLostCallback(connectionLost);
    sslopts.set_verify(false);
    sslopts.set_enable_server_cert_auth(false);
    client.set_callback(callback);
    connopts.set_ssl(sslopts);
    mqtt::token_ptr conntok;

    std::cout << __FUNCTION__ << "Connecting..." << std::endl;
    try {
        conntok = client.connect(connopts);
        conntok->wait();
        std::cout << __FUNCTION__ << ": connected..." << std::endl;
    }
    catch (const mqtt::exception& exc) {
        std::cerr << __FUNCTION__ << ": " << exc.what() << std::endl;
        return 1;
    }

    auto msg = mqtt::make_message(TEST_FEED, json.dump().c_str(), 0);
    client.publish(msg)->wait_for(std::chrono::seconds(10));
    std::cout << __FUNCTION__ << ": published message to AIO" << std::endl;

    while (1)
        std::this_thread::sleep_for(std::chrono::seconds(1));

    return 0;
}

localmqttcallback.h

#ifndef MQTTCLIENT_H
#define MQTTCLIENT_H

#include <iostream>
#include <fstream>
#include <cstdlib>
#include <string>
#include <chrono>
#include <cstring>
#include <functional>
#include <mqtt/async_client.h>

class LocalMQTTCallback : public virtual mqtt::callback, public virtual mqtt::iaction_listener
{
public:
    LocalMQTTCallback(mqtt::async_client& cli, mqtt::connect_options& connOpts);

    void setMessageCallback(std::function<void(std::string, std::string)> cbk) { m_messageCallback = cbk; }
    void setConnectionLostCallback(std::function<void(const std::string&)> cbk) { m_connectionLostCallback = cbk; }
    void setConnectedCallback(std::function<void()> cbk) { m_connectedCallback = cbk; }

private:
    void connection_lost(const std::string& cause) override;
    void message_arrived(mqtt::const_message_ptr msg) override;
    void delivery_complete(mqtt::delivery_token_ptr tok) override;
    void connected(const std::string &cause) override;

    void on_failure(const mqtt::token& tok) override {
        std::cout << "Connection attempt failed: " << tok.get_reason_code() << std::endl;
    }

    // (Re)connection success
    // Either this or connected() can be used for callbacks.
    void on_success(const mqtt::token& tok) override {
        std::cout << "Connection attempt suceeded: " << tok.get_reason_code() << std::endl;
    }

    std::function<void(std::string, std::string)> m_messageCallback;
    std::function<void(const std::string&)> m_connectionLostCallback;
    std::function<void()> m_connectedCallback;

    // Counter for the number of connection retries
    int m_retries;
    // The MQTT client
    mqtt::async_client& m_client;
    // Options to use if we need to reconnect
    mqtt::connect_options& m_clientConnOpts;
};

localmqttcallback.cpp

#include "localmqttcallback.h"

LocalMQTTCallback::LocalMQTTCallback(mqtt::async_client& cli, mqtt::connect_options& connOpts) : 
    m_retries(0), m_client(cli), m_clientConnOpts(connOpts)
{
}

void LocalMQTTCallback::connection_lost(const std::string &cause)
{
    try {
        m_connectionLostCallback(cause);
    }
    catch (std::exception &e) {
        std::cout << __FUNCTION__ << ": Error trying to call the lost connection callback: " << e.what();
    }
}

void LocalMQTTCallback::connected(const std::string &cause)
{
    try {
        m_connectedCallback();
    }
    catch (std::exception &e) {
        std::cout << __FUNCTION__ << ": Error trying to call the connected callback: " << e.what();
    }
}

void LocalMQTTCallback::delivery_complete(mqtt::delivery_token_ptr tok)
{
}

void LocalMQTTCallback::message_arrived(mqtt::const_message_ptr msg)
{
    std::cout << __FUNCTION__ << ": Incoming message for topic " << msg->get_topic() << std::endl;
    try {
        m_messageCallback(msg->get_topic(), msg->get_payload_str());
    }
    catch (std::exception &e) {
        std::cout << __FUNCTION__ << ": Error trying to call the lost connection callback: " << e.what();
    }
}

成功看到以下

mainConnecting...
connected: successful connection established
main: connected...
main: published message to AIO

失败看到这个

mainConnecting...
main: MQTT error [-1]: TCP connect completion failure

以及 MQTT 控制台调试输出的片段

=========================================================
                   Trace Output
Product name: Eclipse Paho Asynchronous MQTT C Client Library
Version: 1.3.1
Build level: 2020-03-21T13:29:16Z
OpenSSL version: OpenSSL 1.1.1c  28 May 2019
OpenSSL flags: compiler: gcc -fPIC -pthread -m64 -Wa,--noexecstack -Wall -Wa,--noexecstack -g -O2 -fdebug-prefix-map=/build/openssl-D7S1fy/openssl-1.1.1c=. -fstack-protector-strong -Wformat -Werror=format-security -DOPENSSL_USE_NODELETE -DL_ENDIAN -DOPENSSL_PIC -DOPENSSL_CPUID_OBJ -DOPENSSL_IA32_SSE2 -DOPENSSL_BN_ASM_MONT -DOPENSSL_BN_ASM_MONT5 -DOPENSSL_BN_ASM_GF2m -DSHA1_ASM -DSHA256_ASM -DSHA512_ASM -DKECCAK1600_ASM -DRC4_ASM -DMD5_ASM -DAES_ASM -DVPAES_ASM -DBSAES_ASM -DGHASH_ASM -DECP_NISTZ256_ASM -DX
OpenSSL build timestamp: built on: Tue Aug 20 11:46:33 2019 UTC
OpenSSL platform: platform: debian-amd64
OpenSSL directory: OPENSSLDIR: "/usr/lib/ssl"
/proc/version: Linux version 5.3.0-7629-generic (buildd@lgw01-amd64-033) (gcc version 9.2.1 20191008 (Ubuntu 9.2.1-9ubuntu2)) #31~1581628825~19.10~f90b7d5-Ubuntu SMP Fri Feb 14 19:56:45 UTC 

=========================================================
19691231 180000.000 (2241132352)  (1)> Socket_outInitialize:131
19691231 180000.000 (2241132352)   (2)> SocketBuffer_initialize:94
19691231 180000.000 (2241132352)   (2)< SocketBuffer_initialize:98
19691231 180000.000 (2241132352)  (1)< Socket_outInitialize:144
19691231 180000.000 (2241132352)  (1)> SSLSocket_initialize:446
19691231 180000.000 (2241132352)   (2)> SSL_create_mutex:346
19691231 180000.000 (2241132352)   (2)< SSL_create_mutex:352 (0)
19691231 180000.000 (2241132352)   (2)> SSL_create_mutex:346
19691231 180000.000 (2241132352)   (2)< SSL_create_mutex:352 (0)
19691231 180000.000 (2241132352)  (1)< SSLSocket_initialize:492 (1)
19691231 180000.000 (2241132352)  (1)> MQTTStrncpy:851
19691231 180000.000 (2241132352)  (1)< MQTTStrncpy:861
19691231 180000.000 (2241132352)  (1)> MQTTStrncpy:851
19691231 180000.000 (2241132352)  (1)< MQTTStrncpy:861
19691231 180000.000 (2241132352)  (1)> MQTTPersistence_create:52
19691231 180000.000 (2241132352)  (1)< MQTTPersistence_create:98 (0)
19691231 180000.000 (2241132352)  (1)> MQTTPersistence_initialize:113
19691231 180000.000 (2241132352)  (1)< MQTTPersistence_initialize:121 (0)
19691231 180000.000 (2241132352)  (1)> MQTTAsync_restoreCommands:1002
20200321 094455.202 0 commands restored for client pbuelow-tls_test_client
20200321 094455.202 (2241132352)  (1)< MQTTAsync_restoreCommands:1040 (0)
20200321 094455.202 (2241132352)  (1)> MQTTPersistence_restoreMessageQueue:719
20200321 094455.202 0 queued messages restored for client pbuelow-tls_test_client
20200321 094455.202 (2241132352)  (1)< MQTTPersistence_restoreMessageQueue:758 (0)
20200321 094455.202 (2241132352) (0)< MQTTAsync_createWithOptions:654 (0)
20200321 094455.202 (2241132352) (0)> MQTTAsync_setConnected:2614
20200321 094455.202 (2241132352) (0)< MQTTAsync_setConnected:2626 (0)
20200321 094455.202 (2241132352) (0)> MQTTAsync_setCallbacks:2500
20200321 094455.202 (2241132352) (0)< MQTTAsync_setCallbacks:2514 (0)
mainConnecting...
20200321 094455.202 (2241132352) (0)> MQTTAsync_connect:2812
20200321 094455.202 (2241132352)  (1)> UTF8_validateString:157
20200321 094455.202 (2241132352)   (2)> UTF8_validate:131
20200321 094455.202 (2241132352)   (2)< UTF8_validate:143 (1)
20200321 094455.202 (2241132352)  (1)< UTF8_validateString:159 (1)
20200321 094455.202 (2241132352)  (1)> Thread_start:69
20200321 094455.202 (2241132352)  (1)< Thread_start:79
20200321 094455.202 (2241132352)  (1)> Thread_start:69
20200321 094455.202 (2241132352)  (1)< Thread_start:79
20200321 094455.202 (2232735488) (0)> MQTTAsync_receiveThread:2138
20200321 094455.203 (2232735488)  (1)> MQTTAsync_cycle:3742
20200321 094455.203 (2232735488)   (2)> Socket_getReadySocket:237
20200321 094455.203 (2232735488)   (2)< Socket_getReadySocket:309 (0)
20200321 094455.203 (2232735488)   (2)> MQTTAsync_sleep:440
20200321 094455.203 (2241128192) (0)> MQTTAsync_sendThread:1858
20200321 094455.203 (2241128192)  (1)> Thread_wait_cond:413
20200321 094455.203 (2241132352)  (1)> MQTTStrncpy:851
20200321 094455.203 (2241132352)  (1)< MQTTStrncpy:861
20200321 094455.203 (2241132352)  (1)> MQTTAsync_addCommand:1050
20200321 094455.203 (2241132352)   (2)> Thread_signal_cond:395
20200321 094455.203 (2241132352)   (2)< Thread_signal_cond:400 (0)
20200321 094455.203 (2241132352)  (1)< MQTTAsync_addCommand:1084 (0)
20200321 094455.203 (2241132352) (0)< MQTTAsync_connect:3119 (0)
20200321 094455.203 (2241132352) (0)> MQTTProperties_free:366
20200321 094455.203 (2241132352) (0)< MQTTProperties_free:389
20200321 094455.203 (2241132352) (0)> MQTTProperties_free:366
20200321 094455.203 (2241132352) (0)< MQTTProperties_free:389
20200321 094455.203 (2241128192)  (1)< Thread_wait_cond:421 (0)
20200321 094455.203 (2241128192)  (1)> MQTTAsync_checkTimeouts:1804
20200321 094455.203 (2241128192)  (1)< MQTTAsync_checkTimeouts:1852
20200321 094455.203 (2241128192)  (1)> MQTTAsync_processCommand:1398
20200321 094455.203 Connecting to serverURI io.adafruit.com:8883 with MQTT version 4
20200321 094455.203 (2241128192)   (2)> MQTTProtocol_connect:114
20200321 094455.203 (2241128192)    (3)> MQTTProtocol_addressPort:58
20200321 094455.203 (2241128192)    (3)< MQTTProtocol_addressPort:90
20200321 094455.203 (2241128192)    (3)> Socket_new:668
20200321 094455.203 New socket 3 for io.adafruit.com:8883, port 8883
20200321 094455.203 (2241128192)     (4)> Socket_addSocket:173
20200321 094455.203 (2241128192)      (5)> Socket_setnonblocking:85
20200321 094455.203 (2241128192)      (5)< Socket_setnonblocking:90 (0)
20200321 094455.203 (2241128192)     (4)< Socket_addSocket:196 (0)
20200321 094455.203 Connect pending
20200321 094455.203 (2241128192)    (3)< Socket_new:785 (115)
20200321 094455.203 (2241128192)   (2)< MQTTProtocol_connect:156 (115)
20200321 094455.203 (2241128192)   (2)> MQTTProperties_free:366
20200321 094455.203 (2241128192)   (2)< MQTTProperties_free:389
20200321 094455.203 (2241128192)  (1)< MQTTAsync_processCommand:1734 (1)
20200321 094455.203 (2241128192)  (1)> Thread_wait_cond:413
20200321 094455.203 (2232735488)   (2)< MQTTAsync_sleep:446
20200321 094455.203 (2232735488)   (2)> MQTTAsync_retry:3575
20200321 094455.303 (2232735488)    (3)> MQTTProtocol_keepalive:608
20200321 094455.303 (2232735488)    (3)< MQTTProtocol_keepalive:644
20200321 094455.303 (2232735488)    (3)> MQTTProtocol_retry:730
20200321 094455.303 (2232735488)    (3)< MQTTProtocol_retry:749
20200321 094455.303 (2232735488)   (2)< MQTTAsync_retry:3585
20200321 094455.303 (2232735488)  (1)< MQTTAsync_cycle:3893 (-1)
20200321 094455.303 (2232735488)  (1)> MQTTAsync_cycle:3742
20200321 094455.303 (2232735488)   (2)> Socket_getReadySocket:237
20200321 094455.303 (2232735488)    (3)> Socket_continueWrites:928
20200321 094455.303 (2232735488)    (3)< Socket_continueWrites:952 (0)
20200321 094455.303 (2232735488)    (3)> isReady:213
20200321 094455.303 (2232735488)    (3)< isReady:218 (1)
20200321 094455.303 (2232735488)   (2)< Socket_getReadySocket:309 (3)
20200321 094455.303 m->c->connect_state = 1
20200321 094455.303 (2232735488)   (2)> MQTTAsync_connecting:3593
20200321 094455.303 (2232735488)    (3)> MQTTPacket_send_connect:55
20200321 094455.303 (2232735488)     (4)> MQTTPacket_send:187
20200321 094455.303 (2232735488)      (5)> MQTTPacket_encode:281
20200321 094455.303 (2232735488)      (5)< MQTTPacket_encode:291 (1)
20200321 094455.303 (2232735488)      (5)> WebSocket_putdatas:782
20200321 094455.304 (2232735488)       (6)> Socket_putdatas:502
20200321 094455.304 (2232735488)        (7)> Socket_writev:426
20200321 094455.304 (2232735488)        (7)< Socket_writev:478 (80)
20200321 094455.304 (2232735488)       (6)< Socket_putdatas:550 (0)
20200321 094455.304 (2232735488)      (5)< WebSocket_putdatas:814 (0)
20200321 094455.304 (2232735488)     (4)< MQTTPacket_send:216 (0)
20200321 094455.304 3 pbuelow-tls_test_client -> CONNECT version 4 clean: 1 (0)
20200321 094455.304 (2232735488)    (3)< MQTTPacket_send_connect:126 (0)
20200321 094455.304 (2232735488)   (2)< MQTTAsync_connecting:3732 (0)
20200321 094455.304 (2232735488)   (2)> MQTTAsync_retry:3575
20200321 094455.304 (2232735488)    (3)> MQTTProtocol_retry:730
20200321 094455.304 (2232735488)    (3)< MQTTProtocol_retry:749
20200321 094455.304 (2232735488)   (2)< MQTTAsync_retry:3585
20200321 094455.304 (2232735488)  (1)< MQTTAsync_cycle:3893 (0)
20200321 094455.304 (2232735488)  (1)> MQTTAsync_cycle:3742
20200321 094455.304 (2232735488)   (2)> Socket_getReadySocket:237
20200321 094455.304 (2232735488)    (3)> Socket_continueWrites:928
20200321 094455.304 (2232735488)    (3)< Socket_continueWrites:952 (0)
20200321 094455.304 (2232735488)    (3)> isReady:213
20200321 094455.304 (2232735488)    (3)< isReady:218 (1)
20200321 094455.340 (2232735488)   (2)< Socket_getReadySocket:309 (3)
20200321 094455.340 m->c->connect_state = 4
20200321 094455.340 (2232735488)   (2)> MQTTPacket_Factory:111
20200321 094455.340 (2232735488)    (3)> WebSocket_getch:476
20200321 094455.340 (2232735488)     (4)> Socket_getch:324
20200321 094455.340 (2232735488)      (5)> SocketBuffer_getQueuedChar:203
20200321 094455.340 (2232735488)      (5)< SocketBuffer_getQueuedChar:222 (-22)
20200321 094455.340 (2232735488)     (4)< Socket_getch:345 (-1)
20200321 094455.340 (2232735488)    (3)< WebSocket_getch:513 (-1)
20200321 094455.340 (2232735488)   (2)< MQTTPacket_Factory:164 (-1)
20200321 094455.340 CONNECT sent but MQTTPacket_Factory has returned SOCKET_ERROR

最佳答案

我遇到了类似的问题。问题似乎是客户端没有尝试尝试 TLS 握手。就我而言，在 URL 前加上 ssl://似乎会强制客户端这样做。
在您的 main.cpp 中，尝试从 mqtt::async_client client("tcp://io.adafruit.com:8883", "tls_test_client"); 更改至mqtt::async_client client("ssl://io.adafruit.com:8883", "tls_test_client"); .

关于c++ - 使用 Paho MQTT C++ 连接到 AdafruitIO，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/60789491/

文章推荐： android - 从多平台 kotlin 项目访问 C/C++ 库

文章推荐： c++ - 在计算所有可能路径问题时计算 nCr

文章推荐： c++ - 如何使用 Cmake 构建基于 Qt 远程对象的项目

文章推荐： c++ - 在 Qt 代码上使用 Fortify SCA(未过时 "HP Fortify")

mqtt - MQTT 连接消耗了多少数据
我想知道如果我只连接到 MQTT 服务器(不发送或接收任何消息)，一个月内(大约)会消耗多少数据。我需要计算它来衡量我应该为物联网应用程序中使用的 sim 卡充值什么数据计划。谢谢最佳答案编辑
mqtt - MQTT 单条消息可以容纳多少数据？
对于单个消息，在 mqtt 中向主题(代理或接收器)发送(发布)数据是否有任何限制？提前致谢.. 最佳答案 IBM 写了一个 article关于 MQTT。 A payload up to 256
mqtt - MQTT 如何节省电池并支持有限的网络连接？
我一直在阅读有关 MQTT 的资料，我知道它使用 TCP 进行网络传输。因此，如果我有一个将发送订阅请求的移动应用程序，我假设这将是一个全双工连接，以便客户端可以收到传入推送数据的通知。那么如何提高
mqtt - mqtt 支持一对多和多对一吗？
最近看了一篇物联网文章 http://www.eclipse.org/community/eclipse_newsletter/2014/february/article2.php 在这里他说，通过
mqtt - MQTT 的最佳用例是什么？
我有一个项目涉及与众多客户进行后端通信。我正在寻找要使用的最佳协议(protocol)。 MQTT 适合我的项目吗？最佳答案 Mqtt 最适合涉及大量用户的项目。目标是提供一个围绕发布/订阅模型优化
mqtt - MQTT 主题中是否允许多个#？
是否允许在 MQTT 主题中使用多个 #？例如: sensors/data/#/something/else/# 最佳答案没有 MQTT 规范(v3 和 v5)规定主题只能在主题中使用一次“#”，
mqtt - 什么时候应该使用 MQTT-SN？它与 MQTT 有何不同？
如果 MQTT 已经是一个轻量级协议(protocol)，而且它使用的功率和带宽很少，那么为什么我们有 MQTT-SN？什么时候适合使用 MQTT，什么时候适合使用 MQTT-SN？最佳答案与 M
mqtt - MQTT 中的内容类型替代方案
我正在使用 Paho 和 Mosqitto 进行 MQTT 通信。我们必须支持两种序列化模型——xml 和 json。所以我正在寻找如何识别 MQTT 中的内容类型或有效负载类型。 MQTT 中是否有
mqtt - MQTT 消息中是否保留消息顺序？
我想知道消息发送顺序是否被保留。也就是说，当发布者发送消息序列时，是否保证每个订阅者收到与发布者发送的序列相同的序列？对于干净和持久的 session ？最佳答案 MQTT 3.1.1 中消息排序功
mqtt - MQTT 中的内容类型替代方案
我正在使用 Paho 和 Mosqitto 进行 MQTT 通信。我们必须支持两种序列化模型——xml 和 json。所以我正在寻找如何识别 MQTT 中的内容类型或有效负载类型。 MQTT 中是否有
mqtt - MQTT 中端口和监听器的区别
我已经在我的本地机器上安装了 MQTT 的 mosquitto 客户端。我有以下配置: listener 1883 protocol mqtt listener 9001 protocol webs
MQTT:MQTT 客户端每分钟轮询服务器多少次？
MQTT 客户端每分钟轮询服务器多少次？是不是大数据流量？我知道数据包的大小可以很小，但是客户端 ping 代理多少次才能使自己在代理中“在线”。如果我不清楚，请评论这个问题，我会尝试更好地解释我的
mqtt - 将一个 MQTT 代理同时桥接到 2 个远程 MQTT 代理
我们在不同的场所安装了许多本地网关。这些网关将托管一个 MQTT 代理，用于连接所有本地服务。然后需要本地 MQTT 代理将此数据发送到两个远程 MQTT 代理(每个托管于不同的一方)。我已阅读有关
mqtt - 无法通过 angular8 中的 ngx-mqtt 连接到 MQTT 代理
无论我做什么，我都无法在我的 angular 应用程序中通过 websocket 连接到 mqtt 代理(在 chrome 和 firefox 中尝试)。为简单起见，我使用 HiveMQ broke
mqtt - 使用通配符订阅 MQTT 主题
我有一个 MQTT 客户端想要订阅以下主题 node1/数据/更新节点1/数据/增量节点1/数据当然我有多个节点，所以我必须使用通配符，如下所述:https://www.hivemq.com/b
mqtt - 将 MQTT 与多个订阅者一起使用
我正在使用 mosquitto (http://mosquitto.org/) 作为 MQTT 代理，并正在寻找有关负载平衡订阅者的建议(针对同一主题)。这是如何实现的？我读到的关于协议(protoc
mqtt - 有什么方法可以区分新的和保留的 MQTT 消息吗？
如题，我可以区分新的和保留的MQTT消息吗？以及如何知道客户端何时发布消息？所有这些没有在主题或消息中指定时间戳字符串。最佳答案客户端使用保留标志向代理指示代理应将消息保留为要发布到的主题的“最后
mqtt - 如何查找已连接的 MQTT 客户端详细信息
有什么方法可以从另一个客户端找到所有连接的客户端详细信息(IP 和名称)？我知道有一个主题“$SYS/broker/clients/active”给出了当前连接的客户端的数量，但是如果我想了解更多关于
mqtt - 获取整个过去的 mqtt 消息队列？
当处于 QOS 1 和 2 时，它会重播所有过去的消息。标准实现中是否有一种方法可以在再次生效时接收整个过去的队列(作为数组)？ (当然仅限订阅的) 最佳答案当客户端以 QOS 1 或 2 订阅主题
mqtt - 如何订阅 MQTT 代理的所有主题
我想连接一个客户端，该客户端将监视代理的所有主题，以便在我不知道主题名称是什么时响应事件。最佳答案订阅 # 可以让您订阅除以 $ 开头的主题之外的所有内容(无论如何，这些主题通常都是控制主题)。

行者123

个人简介

我是一名优秀的程序员,十分优秀！

作者热门文章

滴滴打车优惠券免费领取

全站热门文章

首页

博学

6Ren·AI

商城

c++ - 使用 Paho MQTT C++ 连接到 AdafruitIO