RT-Thread-【LwIP学习营】第三周小作业RT-Thread问答社区

【LwIP学习营】第三周小作业

发布于 2018-06-04 10:37:38 浏览：2072 订阅该版

* 本帖最后由 hcb900330 于 2018-6-4 11:30 编辑 *

1.bsp使用的3.03版本，出现了不知道的错误，要使用最新的bsp包，重新更新bsp要使用git，抽时间要好好学习下。另外缺少select.c需要手动添加。
2。刚开始弄不明白，为啥搞两种协议，mqtt跟http，后来知道硬件传送给平台的数据都是通过http，而下发命令都是通过mqtt。
![1.png](/uploads/201806/04/111228m06rjrgdrslrvszs.png)
![2.png](/uploads/201806/04/111453on6nycz8rnzy6by1.png)

3.之前用过rtt2.0的mqtt，mqtt经常断线，mqttclient用好多地方要修改，新版本的mqtt用了两三天都没有断线，还不错，小伙伴们有福了。

当时2.0的mqtt主要问题是一个socket只能在一个线程里面，还有ping超时以后必须要重新连接，另外还有卡在某个地方，这些坑当时弄了好久才搞定，新版本的rtt都做了处理。
还有ping，mqttpub，mqttsub 都在同一个线程里面，当时pub自己加了一个环形数组，新版本的rtt也做了很好的封装。  res = select(((c->pub_pipe[0] > c->sock) ? c->pub_pipe[0] : c->sock) + 1,&readset, RT_NULL, RT_NULL, &timeout);

while (1)
    {
        int res;
        rt_tick_t tick_now;
        fd_set readset;
        struct timeval timeout;

tick_now = rt_tick_get();
        if (((tick_now - c->tick_ping) / RT_TICK_PER_SECOND) > (c->keepAliveInterval - 5))
        {
            timeout.tv_sec = 1;
            //LOG_D("tick close to ping.");
        }
        else
        {
            timeout.tv_sec = c->keepAliveInterval - 10 - (tick_now - c->tick_ping) / RT_TICK_PER_SECOND;
            //LOG_D("timeount for ping: %d", timeout.tv_sec);
        }
        timeout.tv_usec = 0;

FD_ZERO(&readset);
        FD_SET(c->sock, &readset);
        FD_SET(c->pub_pipe[0], &readset);

/* int select(maxfdp1, readset, writeset, exceptset, timeout); */
        res = select(((c->pub_pipe[0] > c->sock) ? c->pub_pipe[0] : c->sock) + 1,
                     &readset, RT_NULL, RT_NULL, &timeout);
        if (res == 0)
        {
            len = MQTTSerialize_pingreq(c->buf, c->buf_size);
            rc = sendPacket(c, len);
            if (rc != 0)
            {
                LOG_E("[%d] send ping rc: %d ", rt_tick_get(), rc);
                goto _mqtt_disconnect;
            }

/* wait Ping Response. */
            timeout.tv_sec = 5;
            timeout.tv_usec = 0;

FD_ZERO(&readset);
            FD_SET(c->sock, &readset);

res = select(c->sock + 1, &readset, RT_NULL, RT_NULL, &timeout);
            if (res <= 0)
            {
                LOG_E("[%d] wait Ping Response res: %d", rt_tick_get(), res);
                goto _mqtt_disconnect;
            }
        } /* res == 0: timeount for ping. */

if (res < 0)
        {
            LOG_E("select res: %d", res);
            goto _mqtt_disconnect;
        }

if (FD_ISSET(c->sock, &readset))
        {
            //LOG_D("sock FD_ISSET");
            rc_t = MQTT_cycle(c);
            //LOG_D("sock FD_ISSET rc_t : %d", rc_t);
            if (rc_t < 0)    goto _mqtt_disconnect;

continue;
        }

if (FD_ISSET(c->pub_pipe[0], &readset))
        {
            MQTTMessage *message;
            MQTTString topic = MQTTString_initializer;

//LOG_D("pub_sock FD_ISSET");

len = read(c->pub_pipe[0], c->readbuf, c->readbuf_size);

if (len < sizeof(MQTTMessage))
            {
                c->readbuf[len] = '\0';
                LOG_D("pub_sock recv %d byte: %s", len, c->readbuf);

if (strcmp((const char *)c->readbuf, "DISCONNECT") == 0)
                {
                    LOG_D("DISCONNECT");
                    goto _mqtt_disconnect_exit;
                }

continue;
            }

message = (MQTTMessage *)c->readbuf;
            message->payload = c->readbuf + sizeof(MQTTMessage);
            topic.cstring = (char *)c->readbuf + sizeof(MQTTMessage) + message->payloadlen;
            //LOG_D("pub_sock topic:%s, payloadlen:%d", topic.cstring, message->payloadlen);

len = MQTTSerialize_publish(c->buf, c->buf_size, 0, message->qos, message->retained, message->id,
                                        topic, (unsigned char *)message->payload, message->payloadlen);
            if (len <= 0)
            {
                LOG_D("MQTTSerialize_publish len: %d", len);
                goto _mqtt_disconnect;
            }

if ((rc = sendPacket(c, len)) != PAHO_SUCCESS) // send the subscribe packet
            {
                LOG_D("MQTTSerialize_publish sendPacket rc: %d", rc);
                goto _mqtt_disconnect;
            }
        } /* pbulish sock handler. */
    } /* while (1) */