【LwIP学习营】【第四周学习总结】

发布于 2018-06-17 15:40:55 浏览：2393 订阅该版

3 个回答

whj467467222 认证专家 2018-06-17

开源，分享，交流，共同进步

题目一：连接到百度云
首先看到这个题目感觉很难，不像onenet一样有线程的软件包可以用（不知道RTT以后会不会加上阿里云的软件包），所以我先做了题目二，等我回过头的时候发现已经有两个人已经完成了，敬佩之心油然而生。看了别人分享的方法之后也尝试了一下，发现并不是那么难。

[https://www.rt-thread.org/qa/thread-7314-1-1.html](【LwIP学习营】【第四周】利用RT-Thread的MQTT连接阿里云)

[https://www.rt-thread.org/qa/thread-7309-1-1.html]([lwIP学习营]连接阿里云)

拿到这个题目之后首先想我该如何连接到阿里云：
  1，应该先注册一个账号，大家的淘宝支付宝账号可以直接扫码登录 [linkdevelop.aliyun.com](aliyun)
  [attach]4085[/attach]
  
  2，注册号了之后要看看阿里云平台的连接要求
      [https://linkdevelop.aliyun.com/developGuide#kgd6wp.html](阿里云开发指南)

3，按照上周学习onenet一样新建产品，新建设备
[attach]4086[/attach]

4，步骤3完成以后你会得到产品key  设备名字  设备秘钥
      [attach]4087[/attach]
    点击图中箭头所示就能看到这些信息。

5，这里使用alink协议格式，请认真阅读文档
      
  6，云平台设置完毕了，接下来就是修改本地的文件
      使用第三周连接onenet的工程的基础上修改，修改onenet_mqtt.c就可以连接上阿里云。

```
int aliyun_mqtt_init(void)
{
    int result = 0;
    
    if (init_ok)
    {
        return 0;
    }
    
    aliyun_get_info();
    
    if(aliyun_mqtt_entry() < 0)
    {
        result = -1;
    }

if(!result)
    {
        init_ok = RT_TRUE;
        rt_kprintf("aliyun MQTT initialize success.");
    }
    else
    {
        rt_kprintf("aliyun MQTT initialize failed(%d).", result);
    }

return result;
}
```

这里和onenet_mqtt_init一样，只是修改了名字

```
static void aliyun_get_info(void)
{
    strncpy(aliyun_info.deviceName, aliyun_INFO_deviceName, strlen(aliyun_INFO_deviceName));
    strncpy(aliyun_info.DEVICE_SECRET, aliyun_INFO_DEVICE_SECRET, strlen(aliyun_INFO_DEVICE_SECRET));
    strncpy(aliyun_info.productKey, aliyun_INFO_productKey, strlen(aliyun_INFO_productKey));
}

```

这里就是我在阿里云上注册的设备信息。

```
static rt_err_t aliyun_mqtt_entry(void)
{
    MQTTPacket_connectData condata = MQTTPacket_connectData_initializer;
    unsigned char output[20]={ 0 };
    static char passstr[41]={0};
    char url[100]= {0};
    memcpy(url,aliyun_SERVER_URL,strlen(aliyun_SERVER_URL));
			
		tiny_sha1_hmac((unsigned char *)aliyun_INFO_DEVICE_SECRET,
			              strlen(aliyun_INFO_DEVICE_SECRET),
		               (unsigned char *)aliyunpassword,
										strlen(aliyunpassword),output);

for(int i=0;i<20;i++)
    {
        sprintf(&passstr[2*i],"%02x",output[i]);
    }
    passstr[40]='\0';
    
    for(int i = 0;url[i] != '\0';i++)              
    {
        if(url[i] >= 'A' && url[i] <= 'Z')
        {
            url[i] += 32;
        }
    }									   //阿里云协议规定只能小写
		
    mq_client.uri = url;
    memcpy(&(mq_client.condata), &condata, sizeof(condata));
    mq_client.condata.clientID.cstring = mqtt_clientid;
    mq_client.condata.keepAliveInterval = 100;  //阿里云协议规定必须在60—300之间
    mq_client.condata.cleansession = 1;
    mq_client.condata.username.cstring = aliyunusername;
    mq_client.condata.password.cstring = passstr;

mq_client.buf_size = mq_client.readbuf_size = 1024 * 2;
    mq_client.buf = rt_calloc(1, mq_client.buf_size);
    mq_client.readbuf = rt_calloc(1, mq_client.readbuf_size);
    if (!(mq_client.buf && mq_client.readbuf))
    {
        rt_kprintf("No memory for MQTT client buffer!");
        return -RT_ENOMEM;
    }

/* registered callback */
    mq_client.connect_callback = mqtt_connect_callback;
    mq_client.online_callback = mqtt_online_callback;
    mq_client.offline_callback = mqtt_offline_callback;

/* set subscribe table. */
    mq_client.messageHandlers[0].topicFilter = aliyun_MQTT_SUBTOPIC;
    mq_client.messageHandlers[0].callback = mqtt_callback;

mq_client.defaultMessageHandler = mqtt_callback;

paho_mqtt_start(&mq_client);
    
    return RT_EOK;
}
```

做完以上这些应该就可以连上阿里云了，如果需要进一步的使用阿里云，就要继续看说明文档了，和onenet差不多，多看多理解就会了。

[attach]4088[/attach]

[attach]4089[/attach]

[attach]4088[/attach]

[attach]4089[/attach]