ssl - 如何在 tls 中使用 STM32 lwip/mqtt api？

Question

我制作了 stm32 + rtos + lwip/mqtt 解决方案，效果很好。现在我想将它与嵌入 tls 安全连接一起使用。我没有找到任何例子。

lwip mqtt api 支持 tls 通信。但是没有这样的例子，只是简单的mqtt客户端使用代码LWIP MQTT Client我用了。

我尝试在 cubemx、LWIP_ALTCP 和 LWIP_ALTCP_TLS 中启用 embedtls 和一些选项，将 LWIP_ALTCP_TLS_MBEDTLS 添加到 Path。它编译。
如何初始化 mbedtls 并添加 tls 证书。这个链接需要一点信息altcp tls

有人对 stm32 lwip/mqtt + tls (mbedtls) 的 stm32 lwip 堆栈有一些经验或工作示例吗？

UPD。
这是我的 mqtt 客户端设置代码:

struct mqtt_connect_client_info_t ci;
memset(&ci, 0, sizeof(ci));
ci.client_id = "lwip_test";
ci.client_user = "";
ci.client_pass = "";
ci.keep_alive = 0;
ci.tls_config = altcp_tls_create_config_client((const u8_t*)test_cert, sizeof(test_cert));
// create client
client = mqtt_client_new();
// connect client   
mqtt_client_connect(client, &resolved, port, mqtt_on_connect, (void *)0, &ci);

我给 mqtt 客户端 ca 证书和长度。我有一个错误
altcp_tls_create_config_client_common 函数 (altcp_tls_mbedtls.c)，代码为 -4480(分配内存失败)。

ret = mbedtls_x509_crt_parse(conf->ca, ca, ca_len);
if (ret != 0) {
  LWIP_DEBUGF(ALTCP_MBEDTLS_DEBUG, ("mbedtls_x509_crt_parse ca failed: %d 0x%x", ret, -1*ret));
  altcp_mbedtls_free_config(conf);
  return NULL;
}

我做错了什么，我应该在 mbedtls 模块中设置哪些选项？
我使用默认值是由 CubeMX 生成的

Answer 1

该线程与 https://www.nongnu.org/lwip/2_0_x/group__mqtt.html 中的其他示例一起帮助了我使 MQTT 客户端使用 MbedTLS 2 方式身份验证。我现在可以订阅/发布到亚马逊 AWS 云。
因此，如果有人感兴趣，这就是我所做的。

在启用 LwIP 和 MbedTLS 的情况下从 CubeMX 生成代码。重要的是启用 MBEDTLS_PLATFORM_MEMORY、MEMP_MEM_MALLOC 和 LWIP_ALTCP_TLS_MBEDTLS，以便库使用来自 LwIP 的替代 calloc/free 函数(它们在 altcp_mbedtls_mem_init() 函数中设置)。

我还启用了 MBEDTLS_ENTROPY_HARDWARE_ALT、MBEDTLS_NO_PLATFORM_ENTROPY 和 MBEDTLS_CTR_DRBG_C，因此 MbedTLS 库可以使用 ctr drbg 随机数生成器(在 altcp_tls_create_config() 函数中初始化)。

如果您像我一样将 FreeRTOS 与您的 LwIP 一起使用，则必须启用 MBEDTLS_THREADING_ALT，然后在您的代码中调用 mbedtls_threading_set_alt()在 MbedTLS 库中启用互斥锁处理的函数。

这就是我在代码中所做的事情:

mqtt_client_t *client;
struct mqtt_connect_client_info_t client_info;
ip_addr_t server_ip;

/* Somewhere in the code call this to get IP address of the host */
ip_addr_t ipaddr;
err = dns_gethostbyname("host_name", &ipaddr, mqtt_resolved_cb, NULL);

/* Wait until this callback gets the IP */
static void mqtt_resolved_cb(const char *host, const ip_addr_t *ipaddr,
                             void *callback_arg)
{
  /* If resolved IP is known -> set it */
  if (ipaddr->addr != 0)
  {
    server_ip.addr = ipaddr->addr;
  }
}

/* Then call this to start MQTT client */
void mqtt_test(const ip_addr_t *ipaddr, uint16_t port,
               const uint8_t *ca_cert_str, size_t ca_cert_len,
               const uint8_t *dev_cert_str, size_t dev_cert_len,
               const uint8_t *dev_key_str, size_t dev_key_len,
               const uint8_t *dev_key_pass_str, size_t dev_key_pass_len)
{
  /* Setup an empty client info structure */
  memset(&mqtt.client_info, 0, sizeof(mqtt.client_info));

  /* Set client information */
  mqtt.client_info.client_id = "lwip_test";
  mqtt.client_info.client_user = NULL;
  mqtt.client_info.client_pass = NULL;
  mqtt.client_info.keep_alive = 0;
  mqtt.client_info.will_topic = NULL;
  mqtt.client_info.will_msg = NULL;
  mqtt.client_info.will_retain = 0;
  mqtt.client_info.will_qos = 0;

  /* Set TLS configuration */
  mqtt.client_info.tls_config = altcp_tls_create_config_client_2wayauth(
    ca_cert_str, ca_cert_len,
    dev_key_str, dev_key_len, dev_key_pass_str, dev_key_pass_len,
    dev_cert_str, dev_cert_len);

  /* Allocate memory for MQTT client */
  mqtt.client = mqtt_client_new();

  /* Connect to the server */
  if (mqtt.client != NULL)
  {
    err = mqtt_client_connect(
      mqtt.client, ipaddr, port,
      mqtt_connection_cb, 0, &mqtt.client_info);
  }
}

然后代码在上面示例链接中的标准 mqtt 回调中继续。
谢谢，我希望这也可以帮助其他人。