EC20 ESP8266

AT_DEVICE 2.0.3 rtthread 4.0.2链接不了多台设备

发布于 2021-04-16 11:39:39 浏览：1216 订阅该版

3 个回答

flashman2002 2021-04-16

这家伙很懒，什么也没写！

繁星点点 2021-04-16

这家伙很懒，什么也没写！

请登录后再发布评论，点击登录

追加回复

Jone 2021-04-16

写了还是懒

lchnu 2021-08-19

Witness, Understand, Skill

我尝试过用ESP32和Sim7600ce连接同一个MQTT服务器，通过切换默认网卡解决。用了kawaii-mqtt 1.1.0，at_device 2.0.4。

我的测试代码如下。但是，kawaii-mqtt有断线重连机制，建议在kawaii_mqtt_demo函数中，增加一个断线重连的回调函数，在回调函数中，根据任务的info再次进行默认网卡切换；否则，在断线重连后，依然只有一张网卡起作用。

```c
typedef struct _client_info{
    char netdev_name[64];
    struct netdev *netdev;
    char cid[64];
    char sub_topic[128];
    char pub_topic[128];

}client_info;

static client_info esp32_demo_topics = {0};
static client_info sim7600ce_demo_topics = {0};

static int demo_mqtt(int argc, char *argv[])
{
    rt_thread_t tid_mqtt;
    client_info *info;
    struct netdev *netdev = RT_NULL;

if (argc != 2)
    {
        rt_kprintf("demo_mqtt [default_netdev_name]   --expected default network interface device.\n");
        return -1;
    }

rt_kprintf("input parameters are: %s %s \n", argv[0], argv[1]);

netdev = netdev_get_by_name(argv[1]);
    if (netdev == RT_NULL)
    {
        rt_kprintf("not find network interface device name(%s).\n", argv[1]);
        return -1;
    }
    /* 设置线程名称 */
    rt_snprintf(tid_name, sizeof(tid_name), "mqtt_%s", argv[1]);
    /* 设置默认网卡对象 */
    netdev_set_default(netdev);
    rt_kprintf("demo_mqtt set default network interface device(%s) success.\n", argv[1]);

/* 根据输入的网卡名称 设置MQTT topics相关信息*/
    if (0 == strcmp(argv[1],"sim7600ce"))
    {
        info = &esp32_demo_topics;
    }
    else if (0 == strcmp(argv[1],"esp32"))
    {
        info = &sim7600ce_demo_topics;
    }

rt_snprintf(info->netdev_name, sizeof(info->netdev_name), "%s", argv[1]);
    info->netdev = netdev;

rt_snprintf(info->cid, sizeof(info->cid), "rtthread_%s", argv[1]);
    rt_snprintf(info->sub_topic, sizeof(info->sub_topic), "server/%s", info->cid);
    rt_snprintf(info->pub_topic, sizeof(info->pub_topic), "client/%s", info->cid);

tid_mqtt = rt_thread_create(tid_name, kawaii_mqtt_demo, (void *)info, 2048, 17, 10);
    if (tid_mqtt == RT_NULL) {
        return -RT_ERROR;
    }

/* only for test */
    if (RT_FALSE == is_salof_init)
    {
        mqtt_log_init();
        is_salof_init = RT_TRUE;
    }

rt_thread_startup(tid_mqtt);

return RT_EOK;
}
MSH_CMD_EXPORT(demo_mqtt, Kawaii MQTT client test program);
```