eternal-echo
commented
1 year ago 定位
问题出现在下面代码中的aiot_mqtt_setopt(ali_handle.mqtt, AIOT_MQTTOPT_HOST, (void *)mqtt_host);中，设置opt时，mqtt handle的接口函数都变0了
int32_t demo_mqtt_start(void **handle)
{
int32_t res = STATE_SUCCESS;
uint16_t port = 443; /* 无论设备是否使用TLS连接阿里云平台, 目的端口都是443 */
aiot_sysdep_network_cred_t cred; /* 安全凭据结构体, 如果要用TLS, 这个结构体中配置CA证书等参数 */
/* 创建SDK的安全凭据, 用于建立TLS连接 */
memset(&cred, 0, sizeof(aiot_sysdep_network_cred_t));
cred.option = AIOT_SYSDEP_NETWORK_CRED_SVRCERT_CA; /* 使用RSA证书校验MQTT服务端 */
cred.max_tls_fragment = 16384; /* 最大的分片长度为16K, 其它可选值还有4K, 2K, 1K, 0.5K */
cred.sni_enabled = 1; /* TLS建连时, 支持Server Name Indicator */
cred.x509_server_cert = ali_ca_cert; /* 用来验证MQTT服务端的RSA根证书 */
cred.x509_server_cert_len = strlen(ali_ca_cert); /* 用来验证MQTT服务端的RSA根证书长度 */
/* 创建1个MQTT客户端实例并内部初始化默认参数 */
ali_handle.mqtt = aiot_mqtt_init();
if (ali_handle.mqtt == NULL) {
LOG_E("aiot_mqtt_init failed");
return -1;
}
/* TODO: 如果以下代码不被注释, 则例程会用TCP而不是TLS连接云平台 */
{
memset(&cred, 0, sizeof(aiot_sysdep_network_cred_t));
cred.option = AIOT_SYSDEP_NETWORK_CRED_NONE;
}
/* 配置MQTT服务器地址 */
aiot_mqtt_setopt(ali_handle.mqtt, AIOT_MQTTOPT_HOST, (void *)mqtt_host);
/* 配置MQTT服务器端口 */
aiot_mqtt_setopt(ali_handle.mqtt, AIOT_MQTTOPT_PORT, (void *)&port);
/* 配置设备productKey */
aiot_mqtt_setopt(ali_handle.mqtt, AIOT_MQTTOPT_PRODUCT_KEY, (void *)product_key);
/* 配置设备deviceName */
aiot_mqtt_setopt(ali_handle.mqtt, AIOT_MQTTOPT_DEVICE_NAME, (void *)device_name);
/* 配置设备deviceSecret */
aiot_mqtt_setopt(ali_handle.mqtt, AIOT_MQTTOPT_DEVICE_SECRET, (void *)device_secret);
/* 配置网络连接的安全凭据, 上面已经创建好了 */
aiot_mqtt_setopt(ali_handle.mqtt, AIOT_MQTTOPT_NETWORK_CRED, (void *)&cred);
/* 配置MQTT默认消息接收回调函数 */
aiot_mqtt_setopt(ali_handle.mqtt, AIOT_MQTTOPT_RECV_HANDLER, (void *)demo_mqtt_default_recv_handler);
/* 配置MQTT事件回调函数 */
aiot_mqtt_setopt(ali_handle.mqtt, AIOT_MQTTOPT_EVENT_HANDLER, (void *)demo_mqtt_event_handler);
/* 与服务器建立MQTT连接 */
res = aiot_mqtt_connect(ali_handle.mqtt);
if (res < STATE_SUCCESS) {
/* 尝试建立连接失败, 销毁MQTT实例, 回收资源 */
aiot_mqtt_deinit(&ali_handle.mqtt);
LOG_E("aiot_mqtt_connect failed: -0x%04X", -res);
return -1;
}
/* 创建一个单独的线程, 专用于执行aiot_mqtt_process, 它会自动发送心跳保活, 以及重发QoS1的未应答报文 */
g_mqtt_process_thread_running = 1;
g_mqtt_process_thread = rt_thread_create("ali_mqtt_process", demo_mqtt_process_thread, ali_handle.mqtt, 1024, 25, 10);
if(g_mqtt_process_thread == NULL) {
LOG_E("rt_thread_create demo_mqtt_process_thread failed: %d", res);
g_mqtt_process_thread_running = 0;
aiot_mqtt_deinit(&ali_handle.mqtt);
return -1;
}
/* 创建一个单独的线程用于执行aiot_mqtt_recv, 它会循环收取服务器下发的MQTT消息, 并在断线时自动重连 */
g_mqtt_recv_thread_running = 1;
g_mqtt_recv_thread = rt_thread_create("ali_mqtt_recv", demo_mqtt_recv_thread, ali_handle.mqtt, 1024, 10, 10);
if(g_mqtt_recv_thread == NULL) {
LOG_E("rt_thread_create demo_mqtt_recv_thread failed: %d", res);
g_mqtt_recv_thread_running = 0;
rt_thread_delete(g_mqtt_process_thread);
aiot_mqtt_deinit(&ali_handle.mqtt);
return -1;
}
*handle = ali_handle.mqtt;
return RT_EOK;
}
记录