您好，我看您给出的test/emqx/test_ca.c当中有两个ca证书，为啥要使用两个ca证书连接呢？我使用您给的例程跑起来过大概一分钟报错0x0008，无法连接。我使用自己的账号加mqtt.fx连接，ca证书只有一份，其中配置用户名、密码、ca.crt，协议为SSLv3，即可连接。但是当在程序中使用这一份ca证书连接时却无法连接，大约1秒钟就报错network/nettype_tls.c:30 返回错误0x0004。

在服务器使用mosquitto做broker,
本地开发板pub 一个主题, 有client id, 无用户和密码
mosquitto 显示 socket error on client (null), disconnecting
对比是，我iPhone下载了一个mqtt软件，发布消息能被接受到

1、platform_thread_init函数中，xTaskCreate的最后一个参数应该是&thread->thread，而不是V1.1.0版本中的thread->thread。
platform_thread_init函数的自测代码修改为：

err =  xTaskCreate(entry, name, stack_size, param, priority, &thread->thread);

2、platform_thread_destroy函数中，先将任务删除，然后再释放内存的逻辑无法顺利运行。当任务删除后，无法运行到vTaskDelete的后一条释放语句。
platform_thread_destroy函数的自测代码修改为：

TaskHandle_t threadToBeDeleted;

threadToBeDeleted = thread->thread;
platform_memory_free(thread);

if (NULL != threadToBeDeleted)
    vTaskDelete(threadToBeDeleted);

3、我现在使用DTU在建立TCP连接、断开TCP连接都会给用户任务发送事件，用户任务超时5秒等到事件发生，当收到“离线到在线”事件连接 MQTT Server，收到"在线到离线事件" Disconnect， 什么都没有收到的情况下就超时了，即每5秒向MQTT Server发送一次Qos2消息。

在Qos2服务质量下，假设Socket无需用户维护，远程Socket首先断开连接，用户任务检测到掉线，在用户任务中调用mqtt_disconnect函数，会使得内部state变成CLIENT_STATE_CLEAN_SESSION，mqtt_yield返回MQTT_CLEAN_SESSION_ERROR，从而调用mqtt_clean_session，state变成CLIENT_STATE_INVALID状态，最终跳转到platform_thread_destroy函数。platform_thread_destroy函数删除了yield任务，但是c->mqtt_thread没有清零，当Socket再次连接成功后，调用的yield进程没有被重新创建，无法正常运行。

mqtt_yield_thread函数的exit部分自测代码修改为：

threadToBeDestoried = c->mqtt_thread;
c->mqtt_thread = (platform_thread_t *)0;
platform_thread_destroy(threadToBeDestoried);

目前运行较好，向大神请教，不知道我上述理解和修改可对。感谢指点， ^_^

建议修改Linux平台的platform_timer_usleep实现，usleep是非可重入的，也是非线程安全的，而且延迟时间不精确，延时超过1秒时,也是不符合函数的使用规定的。建议使用信号量实现，或者使用select。

/*sleep in us*/
void usSleep(unsigned int nusecs)
{
	struct timeval	tval;

	tval.tv_sec = nusecs / 1000000;
	tval.tv_usec = nusecs % 1000000;
	select(0, NULL, NULL, NULL, &tval);
}

error: types may not be defined in ‘sizeof’ expressions

define PLOOC_SIZEOF_STRUCT(...) sizeof(struct {VA_ARGS})

  I have build and test this sample,when run the ~/mqtt/mqttclient/build/bin/mqtt-client,
 only print  "welcome to mqttclient test...".
 I found that the code run in function platform_nettype_tls_connect(),
      if (0 != (rc = mbedtls_net_connect(&(nettype_tls_params->socket_fd),      n->network_params.addr,n->network_params.port, MBEDTLS_NET_PROTO_TCP))) 
goto exit;

It can't run to next line,and tcpdump found TCP has Retransmission.
 I want to run this demo to confirm it ,and then I can transported to out platform.
 Would help to check how to run this demo normally?

 Thanks!

Regards,
Ellen

int mqtt_keep_alive(mqtt_client_t* c)
{
int rc = MQTT_SUCCESS_ERROR;

rc = mqtt_is_connected(c);
if (MQTT_SUCCESS_ERROR != rc)
    RETURN_ERROR(rc);

if (platform_timer_is_expired(&c->mqtt_last_sent) || platform_timer_is_expired(&c->mqtt_last_received)) {
    if (c->mqtt_ping_outstanding) {
        MQTT_LOG_W("%s:%d %s()... ping outstanding", __FILE__, __LINE__, __FUNCTION__);
        /*must realse the socket file descriptor zhaoshimin 20200629*/
        network_release(c->mqtt_network);
        
        mqtt_set_client_state(c, CLIENT_STATE_DISCONNECTED);
        rc = MQTT_NOT_CONNECT_ERROR; /* PINGRESP not received in keepalive interval */
    } else {
        platform_timer_t timer;
        int len = MQTTSerialize_pingreq(c->mqtt_write_buf, c->mqtt_write_buf_size);
        if (len > 0 && (rc = mqtt_send_packet(c, len, &timer)) == MQTT_SUCCESS_ERROR) // send the ping packet
            c->mqtt_ping_outstanding++;
    }
}

以上函数中
if (len > 0 && (rc = mqtt_send_packet(c, len, &timer)) == MQTT_SUCCESS_ERROR) // send the ping packet
c->mqtt_ping_outstanding++;

这里如果mqtt_send_packet 返回失败， 则 c->mqtt_ping_outstanding就一直保持是0 所以就一直不会断线
全局设置网络状态的地方 好像还有一个 PUBLISH时候 但是如果一直不publish那 就是keep alive这里发送失败 也不会认为掉线

我的情况是，MQTT服务器是单向认证，不需要客户端带CA证书，只需要用户名和密码就能实现连接，我用MQTT.fx这个软件能连接上，软件配置如下：


如上图。使用这样的配置方式是能连接上服务器的，但是使用mqttclient不使用CA证书的情况下就不知道怎么连接了。

大神，首先非常感谢这么好的开源项目，我用代码生成器生成了pub和sub函数，断开网线测试重连没有问题，但是把服务手动停止后，客户端直接退出了，有没有方案处理下不直接退出一直去重连，客户端是在hi3559a下编译运行的，谢谢

你好。用的arm-poky-linux-gnueabi-gcc。

./build.sh arm-poky-linux-gnueabi-gcc
不成功。怎么做呢？

好棒棒啊；
谢谢大牛牛；
你这个库必须依赖paho mqtt啊？

想封装一个windows下的动态库

在mqttclient.h文件的151行需要将‘}’改为’)‘

please add libuv support and example

Variable header 如何进行参数设置。
OneNet 里的上传可自动图示化数据需要在Variable header里设置参数。

https://open.iot.10086.cn/doc/multiprotocol/book/doc/%E8%AE%BE%E5%A4%87%E7%BB%88%E7%AB%AF%E6%8E%A5%E5%85%A5%E5%8D%8F%E8%AE%AE-MQTT.docx

第17页 数据类型4

请大神抽空指导一下

RT

单独设置handle无效，设置全局的handle才能收到订阅的消息。
抓包看报文确实下发到了设备。请教一下代码哪里出了问题，谢谢！

void mqtt_message_handle(void* client, message_data_t* msg)
{
    //始终进不来
    printf("message comes...\n");
    char *buf = msg->message->payload;
    if (strstr(msg->topic_name, "command_resp")) {
        //
    }
}

static int get_token(mqtt_client_t *client){
    mqtt_set_host(client, server);
    mqtt_set_port(client, he_wu_port);
    mqtt_set_user_name(client, imei);
    mqtt_set_password(client, pid);
    mqtt_set_client_id(client, imei);
    mqtt_set_clean_session(client, true);

    mqtt_connect(client);

    char pub_topic[256] = {0};
    char sub_topic[256] = {0};
    //device/products/382381/devices/355750075160144/command
    //device/products/382381/devices/355750075160144/command_resp
    sprintf(pub_topic, "device/products/%s/devices/%s/command",pid, imei);
    sprintf(sub_topic, "device/products/%s/devices/%s/command_resp",pid, imei);
    printf("pub_topic:%s\n",pub_topic);
    printf("sub_topic:%s\n",sub_topic);
    //这里设置了handle
    mqtt_subscribe(client, sub_topic, QOS0, mqtt_message_handle);
    return he_wu_publish(client,pub_topic);
}

int main(void)
{
    mqtt_client_t *client = NULL;
    printf("welcome to mqtt client...\n");
    client = mqtt_lease();
//    mqtt_set_interceptor_handler(client,mqtt_message_handle);
    get_token(client);

    sprintf(creq_topic, "$sys/%s/%s/creq/+", pid, imei);
    sprintf(crsp_topic, "$sys/%s/%s/crsp/", pid, imei);
    sprintf(sqdata_topic, "$sys/%s/%s/sqdata", pid, imei);

    while (1) {}

}

int mqtt_disconnect(mqtt_client_t* c)
{
    int rc = MQTT_FAILED_ERROR;
    platform_timer_t timer;
    int len = 0;

如果传参是 null 就会导致 hard_fault

As a client developed in accordance with the standard MQTT protocol, you may need to add new features on some platforms or meet some more convenient needs. You can speak freely here. This project will continue to be maintained.

作为一个按照标准MQTT协议开发的客户端，可能在某些平台上需要添加新的特性，或者满足某些更方便的需求，可以在这里畅所欲言，本项目将持续维护。

调试发现,mqtt_publish 返回的是MQTT_SEND_PACKET_ERROR.

但是查看 mqtt_yield_thread 函数

rc = mqtt_yield(c, c->mqtt_cmd_timeout); if (MQTT_CLEAN_SESSION_ERROR == rc) { MQTT_LOG_W("%s:%d %s()..., mqtt clean session....", __FILE__, __LINE__, __FUNCTION__); network_disconnect(c->mqtt_network); mqtt_clean_session(c); goto exit; } else if (MQTT_RECONNECT_TIMEOUT_ERROR == rc) { MQTT_LOG_W("%s:%d %s()..., mqtt reconnect timeout....", __FILE__, __LINE__, __FUNCTION__); }

没看到有对应的错误处理部分.

对这种情况请大虾指导一下,系统有对应的处理部分么?

如果没有,能否建议一下如何能达到自动恢复发送的流程.

谢谢

arm-linux-gnueabihf-下编译报错：plooc_class.h:173:58: 错误： types may not be defined in ‘sizeof’ expressions # define PLOOC_SIZEOF_STRUCT(...) sizeof(struct {VA_ARGS})

步骤
1.克隆代码，./make-libmqttclient.sh编译库
2.进入libmqttclient目录，sudo cp -r include/* /usr/include/，复制头文件
3.编写cmakelist.txt代码

cmake_minimum_required(VERSION 3.10)
project(linux_c C)
set(CMAKE_C_STANDARD 11)
link_libraries(mqttclient)
add_executable(app test.c)

4.复制test.c
5.编译
出现错误

In file included from /usr/include/mqttclient.h:20:0,
from /mnt/e/linux_c/test.c:13:
/usr/include/mqtt_defconfig.h:12:10: fatal error: mqtt_config.h: No such file or directory
#include "mqtt_config.h"
^~~~~~~~~~~~~~~
compilation terminated.

请教这是什么原因？

我在./test/mqtt_config.h中，将#define MQTT_NETWORK_TYPE_NO_TLS 打开，相当于配置了不带tls的通信方式，那么我编译库文件的时候，是不是应该比我打开tls通信方式编译得到的库文件要小很多呢？ 我目前编译后发现两者是几乎一样大的，请问我的理解是有错误么？

请教下 Jie哥，系统如果睡眠后，且睡眠时间超过了mqtt_keep_alive_interval时间，那么mqtt connection是否就断开了，需要重新走一遍初始化流程？ 或是在系统睡前之前设置一个定时器，时间到了初始化后再publish?

client = mqtt_lease();
KAWAII_MQTT_LOG_D("After mqtt_lease().");
mqtt_set_port(client, g_mqtt_port);
mqtt_set_host(client, g_mqtt_host);
mqtt_set_client_id(client, g_mqtt_client_id);
mqtt_set_user_name(client, g_mqtt_user_name);
mqtt_set_password(client, g_mqtt_password);
mqtt_set_clean_session(client, 1);
KAWAII_MQTT_LOG_D("\nbefore mqtt_connect\n");
mqtt_connect(client);

mqttclient.h 头文件引入之后之后，编译项目，出现plooc_class.h头文件中， error: types may not be defined in ‘sizeof’ expressions
173 | # define PLOOC_SIZEOF_STRUCT(...) sizeof(struct {VA_ARGS}) 错误，如何处理
| ^

杰神，我在写测试用例的时候需要在最终程序退出时调用mqtt_release来释放已经分配的内存，当我调用这句话的时候，走到了这个分支里：

    /* wait for the clean session to complete */
    while ((CLIENT_STATE_INVALID != mqtt_get_client_state(c))) {
        // platform_timer_usleep(1000);            // 1ms avoid compiler optimization.
        if (platform_timer_is_expired(&timer)) {
            MQTT_LOG_E("%s:%d %s()... mqtt release failed...", __FILE__, __LINE__, __FUNCTION__);
            RETURN_ERROR(MQTT_FAILED_ERROR)
        }    
    }

这也就意味着我的测试用例在之前调用mqtt_lease等接口所申请的内存并没有被释放。我在你提供的example样例里没有看到有关于它的使用方法，这里如果正确使用的话该怎么调用它才能成功呢？

遇到个问题, 公网出现问题的时候, 无法正常连接到服务器上, 调试信息打印四次连接成功, 打印 rc 返回值, -4

屏蔽 exit: 后面的 if(rc == KAWAII_MQTT_SUCCESS_ERR) 可以正常创建线程, 通信正常

想问下屏蔽这句判断, 会对程序稳定性有影响吗?

[I] >> ../mqttclient/mqttclient.c:985 mqtt_connect_with_results()... mqtt connect success...[INFO ][2022-03-18 21:13:04][/home/yuanmajun/develop.proj/htao/HT-RMT-LINUX-RAM/src/transfer/mqtt/MqttCliMng.cpp:162] mqtt conn ali info :
host : iot-060a06ph.mqtt.iothub.aliyuncs.com
clientid : 860723956940406|securemode=3,signmethod=hmacsha256,timestamp=1647637983000|
username : 860723956940406&g8n5Ybke7Pe
pwd : 58D8D06B7C929A0D1E9B8DC06D1A22F1A63A178EEC5B64B5D04326AE60B1D730
ret : -4

我的项目需要使用curl、mqtt、mbed，若单独使用curl+mbedtls-mbedtls-2.16.6，curl请求OK；若是加入libmqttclient.so的链接，curl请求会失败“curl_easy_perform() failed: SSL connect error 35”；请问本项目，是否可以将mbed的功能独立出来，动态依赖标准的mbed库呢？

你好，
我是libhv的作者，简单介绍下，libhv是一个跨平台的类似libevent的网络库。
最近在寻找跨平台的mqtt客户端实现，看到你这个库，感觉非常的优秀，不亚于mosquitto。

计划适配到libhv来提供异步的mqtt客户端库，以完善libhv的网络协议生态，计划见PLAN.md
目前已实现http client/server，适配了hiredis(见redis/hiredis#904)
websocket在开发中，mqtt不知道你是否有兴趣贡献或提供帮助。

I'm using one of the examples in test, running one version on a Linux desktop and the other on a Raspberry Pi and the mqtt_publish in the Rpi sends a selected file to the mqtt_subscribe on the Linux desktop. If I select a text file, it works just fine. If I select a binary file, like a jpg, it comes over as all zeros. I'm going to post a boiled-down version of the code soon.

有一个改善C++支持的改动：

GorgonMeducer/PLOOC@f057e72#diff-d25954aa0a7449205867a7880bf37e59c2134a6b0dd579263fa1cdd746b7a6d5

请问如何在连接失败时获取connack_return_codes失败原因？

int rc = mqtt_connect(client);
while (rc != MQTT_SUCCESS_ERROR) {
slog_error("mqtt connect %s:%s failed", HEWU_SERVER, HEWU_PORT);
sleep(5);
rc = mqtt_connect(client);
}

network.c中

int network_connect(network_t *n)
{
#ifndef MQTT_NETWORK_TYPE_NO_TLS
if (n->channel)
return nettype_tls_connect(n);
#endif
return nettype_tcp_connect(n);

}
n->channel要大于0才能进入tls

network_init中
#ifndef MQTT_NETWORK_TYPE_NO_TLS
n->channel = 0;

if (NULL != ca) {
    network_set_ca(n, ca);
}

#endif

请确认一下，这里是不是有问题，如果设置为0后边就无法调用tls了

中途把mqtt服务关掉，程序异常退出

大佬，你好。我在测试重连时发现了一个小问题。在建立连接和线程的重连都会使mqtt_connect函数，此函数会调用mqtt_connect_with_results函数。在mqtt_connect_with_results中，含有内存被free 2次和多次申请内存的现象。

文件plooc_class.h第43行
#if (!defined(STDC_VERSION) || STDC_VERSION < 199901L) && !defined(__cplusplus)
多了！，应该为
#if (defined(STDC_VERSION) || STDC_VERSION < 199901L) && !defined(__cplusplus)

大佬你好，我在ubuntu上测试MQTT+TLS时，连接emqx平台一直失败，提示如下证书校验失败，地址、port、ca证书已经设置了。您有遇到过么？
（关闭掉tls，mqtt是好用的）
（main.c代码我是用mqtt生成工具生成的）

运行时的错误提示：

alinx@ubuntu:~/work/ppp_sdk/mqtt/mqttclient-master/build/bin$ ./emqx
�
[31m[E] >> /home/alinx/work/ppp_sdk/mqtt/mqttclient-master/network/nettype_tls.c:30 server_certificate_verify()... server_certificate_verify failed returned 0x0004
�
[31m[E] >> /home/alinx/work/ppp_sdk/mqtt/mqttclient-master/network/nettype_tls.c:149 nettype_tls_connect()...mbedtls handshake failed returned 0x0004

mqtt_client_t write_buf is mem leak

老哥遇到过吗，有解决思路没

c->mqtt_network在network_release里面被清零了，所以不用释放，直接屏蔽 platform_memory_free(c->mqtt_network)，添加c->mqtt_write_buf和c->mqtt_read_buf内存释放，就可以了

Originally posted by @Torchwoods in #13 (comment)

库中不少使用宏来声明的函数体，比如KAWAII_MQTT_CLIENT_SET_STATEMENT(user_name, char*)。部分编辑器比如SourceInsight并不会将这些宏展开，会有下面这些不便：

1. 不展开宏用户并不清楚有哪些接口可用
2. 接口上的参数类型也需要根据宏来确认
3. 智能提示功能也不可用

上述问题换编辑器可以解决，但还是希望楼主可以照顾一下其他编辑器

调用vTaskDelete(NULL)之后任务就在当前语句停止了，其后面的代码不会再被执行

在实际开发过程中，
vTaskDelete(NULL);
iccid_return_num = 3;
错误原因分析，在任务删除之后（调用vTaskDelete(NULL)之后），这个任务就在这个函数停止了，这行代码后面的代码不再执行，所以iccid_return_num无法赋值为3，正确的做法是

iccid_return_num = 3;
vTaskDelete(NULL);
@jiejieTop 大神麻烦看一下，是不是正确

您好，请教一下怎样能动态配置发送缓存，就是在我发数据前配置个大的缓存（比如10MB），发完后恢复到默认1K缓存。

运行的环境：STM32F429 + 32MB SDRAM + RTThread 4.0.3
应用的场景：定时使用MQTT发送 8MB 数据包，同时MQTT保持在线，等待订阅消息；
遇到的问题：如果初始化时就设定了10MB缓存空间，那这10MB内存一直被占用着，怎样能实现在我发消息前临时提高缓存，发完消息后释放或改为默认的1K缓存？
谢谢！

服务端代理的tls主版本号是1，使用mqttclient时发现版本不可设置，连接服务端失败。
SSL routines:ssl3_read_bytes:tlsv1 alert access denied
是否可以使用mbedtls的相关API增加一个接口mqtt_set_ssl_version(client,版本号)

大咖你好， 我利用Linux最新版本mqttclient源码交叉编译的库，在此基础上做应用开发（主要功能是定时发布消息，订阅消息），做了两个测试(启动应用程序的同时，一直另开一个窗口ping服务器)：1.mqtt服务器部署在局域网，网络很稳定（ping延时<1ms）,应用程序运行很稳定； 2.mqtt服务器部署在云端，网络不稳定(ping延时在40ms左右，有时会超时连接)，遇到两个问题：a.当应用程序启动时，有时候会出现构建mqtt_yield_thread失败的情况；b.程序正常启动，mqtt_yield_thread构建成功，当网络稳定时，可以正常发布消息，但当网络不稳定时，特别是当ping服务器超时情况出现时，如果此时要发布消息，那么应用程序就会挂掉；
我看mqttclient程序readme，有掉线重连机制，但为什么会出现程序运行时挂掉的情况呢？
刚接触mqttclient，请多指教！问题大致出在哪？修改大致思路是？
我想达到的效果是：1.程序初启动时，即使mqtt服务器连接不上，mqtt_yield_thread内部线程也要正常启动，然后通过掉线重连机制，定时重连服务器，直到连上为止； 2.在复杂不稳定网络环境下，不会导致程序异常退出。

/mqtt/mqttclient-master/libmqttclient/include/mqttclient.h:79: error: types may not be defined in 'sizeof' expressions
/mqtt/mqttclient-master/libmqttclient/include/mqttclient.h:79: error: types may not be defined in 'alignof' expressions
/mqtt/mqttclient-master/libmqttclient/include/mqttclient.h:88: error: types may not be defined in 'sizeof' expressions
/mqtt/mqttclient-master/libmqttclient/include/mqttclient.h:88: error: types may not be defined in 'alignof' expressions
/mqtt/mqttclient-master/libmqttclient/include/mqttclient.h:97: error: types may not be defined in 'sizeof' expressions
/mqtt/mqttclient-master/libmqttclient/include/mqttclient.h:97: error: types may not be defined in 'alignof' expressions
/mqtt/mqttclient-master/libmqttclient/include/mqttclient.h:110: error: types may not be defined in 'sizeof' expressions
/mqtt/mqttclient-master/libmqttclient/include/mqttclient.h:110: error: types may not be defined in 'alignof' expressions
/mqtt/mqttclient-master/libmqttclient/include/mqttclient.h:120: error: types may not be defined in 'sizeof' expressions
/mqtt/mqttclient-master/libmqttclient/include/mqttclient.h:120: error: types may not be defined in 'alignof' expressions

公司项目是使用 VS Studio C++开发，需要增加 mqtt 通信功能，看软件介绍可以支持windows，但在 platform 目录下却找不到适配 windows 的文件。是要自己来写windows平台的适配函数，还是有什么方法？