- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
我正在尝试使用 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;
}
#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;
};
#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
=========================================================
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/
我在网上搜索但没有找到任何合适的文章解释如何使用 javascript 使用 WCF 服务,尤其是 WebScriptEndpoint。 任何人都可以对此给出任何指导吗? 谢谢 最佳答案 这是一篇关于
我正在编写一个将运行 Linux 命令的 C 程序,例如: cat/etc/passwd | grep 列表 |剪切-c 1-5 我没有任何结果 *这里 parent 等待第一个 child (chi
所以我正在尝试处理文件上传,然后将该文件作为二进制文件存储到数据库中。在我存储它之后,我尝试在给定的 URL 上提供文件。我似乎找不到适合这里的方法。我需要使用数据库,因为我使用 Google 应用引
我正在尝试制作一个宏,将下面的公式添加到单元格中,然后将其拖到整个列中并在 H 列中复制相同的公式 我想在 F 和 H 列中输入公式的数据 Range("F1").formula = "=IF(ISE
问题类似于this one ,但我想使用 OperatorPrecedenceParser 解析带有函数应用程序的表达式在 FParsec . 这是我的 AST: type Expression =
我想通过使用 sequelize 和 node.js 将这个查询更改为代码取决于在哪里 select COUNT(gender) as genderCount from customers where
我正在使用GNU bash,版本5.0.3(1)-发行版(x86_64-pc-linux-gnu),我想知道为什么简单的赋值语句会出现语法错误: #/bin/bash var1=/tmp
这里,为什么我的代码在 IE 中不起作用。我的代码适用于所有浏览器。没有问题。但是当我在 IE 上运行我的项目时,它发现错误。 而且我的 jquery 类和 insertadjacentHTMl 也不
我正在尝试更改标签的innerHTML。我无权访问该表单,因此无法编辑 HTML。标签具有的唯一标识符是“for”属性。 这是输入和标签的结构:
我有一个页面,我可以在其中返回用户帖子,可以使用一些 jquery 代码对这些帖子进行即时评论,在发布新评论后,我在帖子下插入新评论以及删除 按钮。问题是 Delete 按钮在新插入的元素上不起作用,
我有一个大约有 20 列的“管道分隔”文件。我只想使用 sha1sum 散列第一列,它是一个数字,如帐号,并按原样返回其余列。 使用 awk 或 sed 执行此操作的最佳方法是什么? Accounti
我需要将以下内容插入到我的表中...我的用户表有五列 id、用户名、密码、名称、条目。 (我还没有提交任何东西到条目中,我稍后会使用 php 来做)但由于某种原因我不断收到这个错误:#1054 - U
所以我试图有一个输入字段,我可以在其中输入任何字符,但然后将输入的值小写,删除任何非字母数字字符,留下“。”而不是空格。 例如,如果我输入: 地球的 70% 是水,-!*#$^^ & 30% 土地 输
我正在尝试做一些我认为非常简单的事情,但出于某种原因我没有得到想要的结果?我是 javascript 的新手,但对 java 有经验,所以我相信我没有使用某种正确的规则。 这是一个获取输入值、检查选择
我想使用 angularjs 从 mysql 数据库加载数据。 这就是应用程序的工作原理;用户登录,他们的用户名存储在 cookie 中。该用户名显示在主页上 我想获取这个值并通过 angularjs
我正在使用 autoLayout,我想在 UITableViewCell 上放置一个 UIlabel,它应该始终位于单元格的右侧和右侧的中心。 这就是我想要实现的目标 所以在这里你可以看到我正在谈论的
我需要与 MySql 等效的 elasticsearch 查询。我的 sql 查询: SELECT DISTINCT t.product_id AS id FROM tbl_sup_price t
我正在实现代码以使用 JSON。 func setup() { if let flickrURL = NSURL(string: "https://api.flickr.com/
我尝试使用for循环声明变量,然后测试cols和rols是否相同。如果是,它将运行递归函数。但是,我在 javascript 中执行 do 时遇到问题。有人可以帮忙吗? 现在,在比较 col.1 和
我举了一个我正在处理的问题的简短示例。 HTML代码: 1 2 3 CSS 代码: .BB a:hover{ color: #000; } .BB > li:after {
我是一名优秀的程序员,十分优秀!