用Ai-M61实现物联网开发（1）---连接巴法云

     收到安信可送出的M61已经有一段时间了，一直在考虑用这块板子做些什么。之前用ESP32和ESP8266通过Arduino 下开发都实现过连接巴法云，达到远程控制的功能，由简入手，自然也想到用M61实现同样的功能会比较容易。
    通过熟悉和安装M61在Arduino 下的开发环境后发现，由于缺少Arduino 必要wifi连接库的支持，短期内在Arduino 下开发M61的应用还是比较困难的，通过尝试移植WiFi库等一系列的失败后，重新返回到用Visual Studio Code+BL616_SDK开发。
    今天终于依葫芦画瓢的通过修改自带的例程实现了连接巴法云的功能，赶快发帖分享一下。在此声明一下，我的代码水平比较菜，只是记录我的学习过程，希望高手不吝赐教。

1. static struct bflb_device_s *uart0;
   
2. static uint32_t sta_ConnectStatus = 0;
   
3. static uint8_t sta_ConnectStatus1 = 0;
   
4. static TaskHandle_t wifi_fw_task;
   
5. int sock_client = -1;
   
6. #define MAXSIZE 1024
   
7. #define beserver_ip    "bemfa.com"  //"192.168.110.233" //"bemfa.com" //巴法云服务器地址默认即可
   
8. #define beserver_port "8344" //服务器端口，tcp创客云端口8344
   
9. //static const char* UID = "********";  //用户私钥，可在控制台获取,修改为自己的UID
   
10. //static const char* TOPIC = "******";         //主题名字，可在控制台新建
    
11. static const char subscribe[] = "cmd=1&uid=******&topic=******\r\n"; //构建订阅指令
    
12. static const char Keep_alive_str[] = "cmd=7&uid=****&type=1\r\n";//心跳数据
    
13. struct sockaddr_in  client_addr;

复制代码

有关巴法云的编程接口可以参照官网的说明，应该跟很多物联网平台类似。

1. uint8_t wifi_connect()
   
2. {
   
3.     char* ssid = "******";
   
4.     char* passwd = "*****";
   
5. 
   
6.     uint32_t ipv4_addr = 0;
   
7. 
   
8.     if (wifi_mgmr_sta_state_get() == 1) {
   
9.         wifi_sta_disconnect();
   
10.     }
    
11.     if (wifi_sta_connect(ssid, passwd, NULL, NULL, 0, 0, 0, 1)) {
    
12.         return 4;
    
13.     }
    
14. 
    
15.     //等待连接成功
    
16.     sta_ConnectStatus = 0;
    
17.     for (int i = 0;i<10*30;i++)
    
18.    // while(true)
    
19.     {
    
20.         vTaskDelay(100);
    
21.         switch (sta_ConnectStatus)
    
22.         {
    
23.             case CODE_WIFI_ON_CONNECTED:        //连接成功(表示wifi sta状态的时候表示同时获取IP(DHCP)成功，或者使用静态IP)
    
24.                 LOG_I("CODE_WIFI_ON_CONNECTED\r\n");
    
25.                 break;
    
26.             case CODE_WIFI_ON_DISCONNECT:        //连接失败（超过了重连次数还没有连接成功的状态）
    
27.                 wifi_sta_disconnect();
    
28.                 return 4;
    
29.                 break;
    
30.             case CODE_WIFI_ON_GOT_IP:       //获取IP
    
31.                 wifi_sta_ip4_addr_get(&ipv4_addr, NULL, NULL, NULL);
    
32.                 LOG_I("CODE_WIFI_ON_GOT_IP\r\n");
    
33.                 //LOG_I("wifi_sta_ip4_addr_get = %X\r\n",ipv4_addr);
    
34.                 LOG_I("wifi_sta_ip4_addr_get = %d.%d.%d.%d\r\n",(uint8_t)ipv4_addr,(uint8_t)(ipv4_addr>>8),(uint8_t)(ipv4_addr>>16),(uint8_t)(ipv4_addr>>24));//uint8_t
    
35.                 return 0;
    
36.             default:
    
37.                 //等待连接成功
    
38.                 break;
    
39.         }
    
40.     }
    
41.     return -1; //连接超时
    
42. }
    
43. 
    
44. 
    
45. 
    
46. static void wifi_connection()
    
47. {
    
48.     while (1)
    
49.     {
    
50.         if (sta_ConnectStatus == CODE_WIFI_ON_MGMR_DONE)
    
51.         { // WIFI管理初始化完毕
    
52.           if(wifi_connect()==0){
    
53.             sta_ConnectStatus1 = 1;
    
54.             LOG_I("wifi_connect() \r\n");
    
55.           }
    
56.          
    
57.          //   wifi_connect();
    
58.         }        
    
59.         vTaskDelay(3000/portTICK_PERIOD_MS);
    
60.     }
    
61. }
    

复制代码

有关WiFi的连接部分，大家可以参照论坛中的配网知识来做成网页自动配网，我还没来得及学习，只能代码里面写成固定的了。

1. 
   
2. static void wifi_tcp_client_close()
   
3. {
   
4.     if (sock_client) {
   
5.         closesocket(sock_client);
   
6.     }
   
7. 
   
8. }
   
9. 
   
10. static void wifi_tcp_client_init(char *host_name,char *port)
    
11. {
    
12.     LOG_I("tcp client task start ...\r\n");
    
13.     char *addr;
    
14. 
    
15.     ip4_addr_t dns_ip;
    
16.     netconn_gethostbyname(host_name, &dns_ip);
    
17.     addr = ip_ntoa(&dns_ip);
    
18. 
    
19.    // while (1) {
    
20.         if ((sock_client = socket(AF_INET, SOCK_STREAM, 0)) < 0) {
    
21.             LOG_E("TCP Client create socket error\r\n");
    
22.             return;
    
23.         }
    
24.         client_addr.sin_family = AF_INET;
    
25.         client_addr.sin_port = htons(atoi(port));
    
26.         client_addr.sin_addr.s_addr = inet_addr(addr);
    
27.         memset(&(client_addr.sin_zero), 0, sizeof(client_addr.sin_zero));
    
28. 
    
29.         printf("Server ip Address : %s:%s\r\n", addr, port);
    
30. 
    
31.         if (connect(sock_client, (struct sockaddr *)&client_addr, sizeof(struct sockaddr)) != 0) {
    
32.             LOG_E("TCP client connect server falied!\r\n");
    
33.             closesocket(sock_client);
    
34.             return;
    
35.         }
    
36. 
    
37.         LOG_I("TCP client connect server success!\r\n");
    
38. 
    
39.    // }
    
40. }
    
41. int wifi_tcp_client_send(const char *send_buf,uint8_t buf_size)
    
42. {   
    
43.    int cont = 0;
    
44.    if(sock_client){
    
45.       cont = write(sock_client, send_buf, buf_size) ;
    
46.             if (cont < 0) {
    
47.                 LOG_E("write socket falied!\r\n");
    
48.                 wifi_tcp_client_close();
    
49.                 sock_client = -1;
    
50.             }
    
51. 
    
52.    }
    
53.    return cont;
    
54. }
    
55. 
    
56. int wifi_tcp_client_recv(uint8_t *recv_buf)
    
57. {   
    
58.    int cont = 0;
    
59.    if(sock_client){
    
60.       cont = read(sock_client, recv_buf, MAXSIZE) ;
    
61.             if (cont < 0) {
    
62.                 LOG_E("read socket falied!\r\n");
    
63.             }
    
64. 
    
65.    }
    
66.    return cont;
    
67. }
    
68. 
    
69. static void wifi_tcp_client_read()
    
70. {
    
71.     uint8_t recv_buf[1024]={0};
    
72.     while (1)
    
73.     {
    
74.         if((sock_client > 0)&&(sta_ConnectStatus1 ==  1)){
    
75. 
    
76.             int  bufsize = wifi_tcp_client_recv(recv_buf);  //这里原来是uint8_t 类型，需要改成int，有bug。
    
77.             if(bufsize>0){          //处理接收到的数据
    
78.                 recv_buf[bufsize+1]=0;
    
79.                LOG_I("read socket msg = [%s]\r\n",recv_buf);
    
80. 
    
81.             }else {
    
82.                 LOG_I("wifi_tcp_client_close\r\n");
    
83.                 wifi_tcp_client_close();
    
84.                sock_client = -1;
    
85.             }
    
86.         }
    
87.         vTaskDelay(1000/portTICK_PERIOD_MS);
    
88.     }
    
89.    
    
90. }
    
91. static void wifi_tcp_client_creat()
    
92. {
    
93.    
    
94.     static uint8_t delay_cont = 0;
    
95.      while (1)
    
96.     {
    
97.         delay_cont++;
    
98.         if (sta_ConnectStatus1 ==  1)        //连接成功(表示wifi sta状态的时候表示同时获取IP(DHCP)成功，或者使用静态IP)
    
99.         {
    
100.         if(sock_client < 0){
     
101. 
     
102.                 LOG_I("wifi_tcp_client_init\r\n");
     
103.                 wifi_tcp_client_init(beserver_ip,beserver_port);
     
104.                 if(sock_client){
     
105.                  wifi_tcp_client_send(subscribe,sizeof(subscribe)); //发送注册指令  
     
106.                 }
     
107.         }
     
108.         if(delay_cont >=60){
     
109.             delay_cont = 0;
     
110.             if(sock_client){
     
111.               LOG_I("wifi_tcp_client_send\r\n");
     
112.               wifi_tcp_client_send(Keep_alive_str,sizeof(Keep_alive_str)); //发送心跳数据  
     
113.             }
     
114.             
     
115.         }        
     
116.         }  
     
117. 
     
118. 
     
119.         vTaskDelay(1000/portTICK_PERIOD_MS);
     
120.     }
     
121.      wifi_tcp_client_close();   
     
122. }

复制代码

这部分代码实现了类似于Arduino 下的WiFiClient的功能，用来连接巴法云并发送和接收数据。编译和下载以后，启动M61，在巴法云的管理页面已经可以看到设备已经在线了。
通过调试工具发送指令，M61也已经可以接收到数据。


我会把完整的代码放到帖子后面，大家编译的时候注意sdk目录。我也会抽时间把完整的远程控制代码慢慢的用M61实现。
wifi_tcp_client.rar (11.42 KB, 下载次数: 13)

2023-12-26 14:02 上传

点击文件名下载附件

终于交作业了

不错不错

赞

写的很好

昨天传的代码有两个地方有bug，今天稍微修改了一下。附件和正文已经更正了。

赞

这个我有几个问题：
1、怎么配置巴法云平台的订阅，还有代码#include "FreeRTOS.h"这行报错。
2、ai-m61直接通过type-c连接电脑烧录main.c文件就可以了么