kawayi mqtt连接mosquitto

发布于 2022-05-05 14:11:42 浏览：881 订阅该版

2 个回答

lchnu 2022-05-05

Witness, Understand, Skill

Tim_PC 2022-05-05

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

lchnu 2022-05-05

Witness, Understand, Skill

Tim_PC 2022-05-05

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

lchnu 2022-05-05

Witness, Understand, Skill

Tim_PC 2022-05-06

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

lchnu 2022-05-06

Witness, Understand, Skill

lchnu 2022-05-06

Witness, Understand, Skill

@Tim_PC 
我这边成功了的，祝顺利！

1.我在基本ART-PI + Ethernet工程的基础上，添加了Kawaii MQTT包，配置如下：

![image.png](https://oss-club.rt-thread.org/uploads/20220506/78b88520f5a0e6f519fb4358f8cfc204.png.webp)

2.使用EMQX搭建了一个MQTT Broker，通过http://127.0.0.1:18083/ 访问管理页面。

3.简单修改test.c中的代码：
```c

int mqtt_demo(void)
{
    mqtt_client_t *client = NULL;
    
    int rc;
    
    mqtt_log_init();

client = mqtt_lease();

mqtt_set_host(client, "192.168.1.107");
    mqtt_set_port(client, "1883");
    mqtt_set_user_name(client, "rt-thread");
    mqtt_set_password(client, "rt-thread");
    mqtt_set_client_id(client, "rt-thread");
    mqtt_set_clean_session(client, 1);

rc = mqtt_connect(client);
    KAWAII_MQTT_LOG_D("connect result is %d", rc);
    
    rc = mqtt_subscribe(client, "rtt-subtopic", QOS0, sub_topic_handle1);
    KAWAII_MQTT_LOG_D("subscribe result is %d", rc);
    
    while (1) {
        mqtt_publish_handle1(client);
                               
        mqtt_sleep_ms(4 * 1000);
    }
}

MSH_CMD_EXPORT(mqtt_demo, kawaii mqtt demo)
```

4.下载，通过命令行启动mqtt

![image.png](https://oss-club.rt-thread.org/uploads/20220506/07f8389930e44a0fc5b378956ff91d88.png)

5.WireShark抓包

![image.png](https://oss-club.rt-thread.org/uploads/20220506/b8435e852754adfe24eab984967e10d2.png)

6.管理控制台查看MQTT信息交互

![image.png](https://oss-club.rt-thread.org/uploads/20220506/3974bead5b646426445d2d22d547cdf9.png.webp)

这里Subscribe没有失败。我在05-29的大会上，会做一个简单的demo演示，说明subscribe失败原因。