基于小凌派RK2206開(kāi)發(fā)板wifi-tcp通信實(shí)驗(yàn)

在開(kāi)發(fā)過(guò)程中想要與開(kāi)發(fā)板進(jìn)行通信一般使用串口通信，當(dāng)開(kāi)發(fā)板使用串口與pc通信還需要專(zhuān)門(mén)的串口轉(zhuǎn)換工具才行。而小凌派開(kāi)發(fā)板自帶wifi功能。因此與pc通信時(shí)可以使用wifi功能進(jìn)行tcp通信這樣就不需要專(zhuān)門(mén)的轉(zhuǎn)換工具非常方便。

一、在使用小凌派開(kāi)發(fā)板wifi進(jìn)行tcp通信的步驟

1、要確定pc機(jī)所連接路由的wifi名稱(chēng)和密碼。通過(guò)修改代碼使小凌派連接到與pc同一網(wǎng)絡(luò)。

修改文件device/rockchip/rk2206/sdk_liteos/board/src/config_network.c 中的SSID 即wifi名稱(chēng)，和PASSWORD 即wifi密碼。

#define SSID "凌智電子"

#define PASSWORD "********"

2、確認(rèn)小凌派wifi功能是否開(kāi)啟

查看device/rockchip/rk2206/sdk_liteos/board/main.c 文件

是否調(diào)用ExternalTaskConfigNetwork();

3、確認(rèn)小凌派開(kāi)發(fā)板與開(kāi)發(fā)板在同一網(wǎng)段。

在修改以上配置后先編譯燒錄程序然后查看log確認(rèn)小凌派開(kāi)發(fā)板獲取到的ip地址。

在確認(rèn)pc的ip地址，在控制臺(tái)輸入ipconfig

可以看到兩個(gè)ip地址都是點(diǎn)2網(wǎng)段，說(shuō)明已經(jīng)在同一局域網(wǎng)。

4、 修改wifi_tcp 例程中服務(wù)地址及端口號(hào)

#define OC_SERVER_IP "192.168.2.49"

#define SERVER_PORT 6666

這個(gè)ip地址即PC的ip地址，修改后重新編譯燒錄程序。

5、 pc上打開(kāi)兩個(gè)網(wǎng)絡(luò)調(diào)試工具，一個(gè)客戶(hù)端和一個(gè)服務(wù)端，并設(shè)置ip地址和端口號(hào)

服務(wù)端 ip地址：0.0.0.0

端口號(hào)：6666

客戶(hù)端ip地址：192.168.2.50 （之前查看到小凌派的ip地址）

端口號(hào)：6666

6 、查看log等待小凌派的tcp客戶(hù)端和服務(wù)端任務(wù)啟動(dòng)

可以看到客戶(hù)端連接地址192.168.2.49:6666 即pc的ip地址

服務(wù)端監(jiān)聽(tīng)端口為6666

這表示小凌派tcp客戶(hù)端和服務(wù)端任務(wù)都已經(jīng)啟動(dòng)。

7、 在pc網(wǎng)絡(luò)調(diào)試助手點(diǎn)擊啟動(dòng)客戶(hù)端和服務(wù)端

可以觀察到網(wǎng)絡(luò)調(diào)試助手服務(wù)端有設(shè)備連接成功并且接收到了調(diào)試數(shù)據(jù)。

網(wǎng)絡(luò)調(diào)試助手的客戶(hù)端也顯示連接成功。

8、 使用網(wǎng)絡(luò)調(diào)試助手發(fā)送數(shù)據(jù)

可以查看log發(fā)現(xiàn)小凌派開(kāi)發(fā)板已經(jīng)可以正常收發(fā)數(shù)據(jù)了。

這樣就可以通過(guò)使用wifi與pc進(jìn)行通信。

二、接下來(lái)分析一下代碼的工作流程。

首先包含必要的頭文件

#include "ohos_init.h"#include "cmsis_os2.h"#include "los_task.h"#include "lz_hardware.h"#include "config_network.h"#include "lwip/tcp.h"#include "lwip/ip_addr.h"#include "lwip/priv/tcp_priv.h"#include "lwip/stats.h"#include "lwip/inet_chksum.h"

這些定義主要是 ip地址和端口號(hào)以及緩存大小

#define LOG_TAG "tcp"#define OC_SERVER_IP "192.168.2.49"#define SERVER_PORT 6666#define BUFF_LEN 256

這部分是獲取wifi連接信息，通過(guò)查詢(xún)wifi連接信息確認(rèn)wifi是否連接成功。只有wifi連接成功了才能進(jìn)行tcp通信

int get_wifi_info(WifiLinkedInfo *info){ int ret = -1; int gw, netmask; memset(info, 0, sizeof(WifiLinkedInfo)); unsigned int retry = 15; while (retry) { if (GetLinkedInfo(info) == WIFI_SUCCESS) { if (info->connState == WIFI_CONNECTED) { if (info->ipAddress != 0) { LZ_HARDWARE_LOGD(LOG_TAG, "rknetwork IP (%s)", inet_ntoa(info->ipAddress)); if (WIFI_SUCCESS == GetLocalWifiGw(&gw)) { LZ_HARDWARE_LOGD(LOG_TAG, "network GW (%s)", inet_ntoa(gw)); } if (WIFI_SUCCESS == GetLocalWifiNetmask(&netmask)) { LZ_HARDWARE_LOGD(LOG_TAG, "network NETMASK (%s)", inet_ntoa(netmask)); } if (WIFI_SUCCESS == SetLocalWifiGw()) { LZ_HARDWARE_LOGD(LOG_TAG, "set network GW"); } if (WIFI_SUCCESS == GetLocalWifiGw(&gw)) { LZ_HARDWARE_LOGD(LOG_TAG, "network GW (%s)", inet_ntoa(gw)); } if (WIFI_SUCCESS == GetLocalWifiNetmask(&netmask)) { LZ_HARDWARE_LOGD(LOG_TAG, "network NETMASK (%s)", inet_ntoa(netmask)); } ret = 0; goto connect_done; } } } LOS_Msleep(1000); retry--; }

connect_done: return ret;}

這部分是tcp服務(wù)端接收消息處理

先進(jìn)入accept（）會(huì)處于阻塞狀態(tài)，即沒(méi)有客戶(hù)端連接時(shí)一直阻塞。

單客戶(hù)端連接后又進(jìn)入接收數(shù)據(jù)狀態(tài)，此狀態(tài)也是阻塞狀態(tài)。

沒(méi)有數(shù)據(jù)時(shí)一直阻塞，不過(guò)需要注意的是在此狀態(tài)下當(dāng)客戶(hù)端斷開(kāi)連接時(shí)recv會(huì)返回-1

接收到pc客戶(hù)端的消息后通過(guò)send()發(fā)響應(yīng)消息給PC客戶(hù)端。

void tcp_server_msg_handle(int fd){ char buf[BUFF_LEN]; //接收緩沖區(qū) socklen_t client_addr_len; int cnt = 0, count; int client_fd; struct sockaddr_in client_addr = {0}; printf("waitting for client connect...\n"); /* 監(jiān)聽(tīng)socket 此處會(huì)阻塞 */ client_fd = accept(fd, (struct sockaddr*)&client_addr, &client_addr_len); // client_fd = lwip_accept(fd, (struct sockaddr*)&client_addr, &client_addr_len); printf("[tcp server] accept <%s:%d>\n", inet_ntoa(client_addr.sin_addr), ntohs(client_addr.sin_port)); while (1) { memset(buf, 0, BUFF_LEN); printf("-------------------------------------------------------\n"); printf("[tcp server] waitting client msg\n"); count = recv(client_fd, buf, BUFF_LEN, 0); //read是阻塞函數(shù)，沒(méi)有數(shù)據(jù)就一直阻塞 // count = lwip_read(client_fd, buf, BUFF_LEN); //read是阻塞函數(shù)，沒(méi)有數(shù)據(jù)就一直阻塞 if (count == -1) { printf("[tcp server] recieve data fail!\n"); LOS_Msleep(3000); break; } printf("[tcp server] rev client msg:%s\n", buf); memset(buf, 0, BUFF_LEN); sprintf(buf, "I have recieved %d bytes data! recieved cnt:%d", count, ++cnt); printf("[tcp server] send msg:%s\n", buf); send(client_fd, buf, strlen(buf), 0); //發(fā)送信息給client // lwip_write(client_fd, buf, strlen(buf)); //發(fā)送信息給client } lwip_close(client_fd); lwip_close(fd);}

這部分是tcp服務(wù)端任務(wù)代碼

服務(wù)端處理流程

socket-->bind-->listen-->accept-->recv-->send-->lwip_close

先通過(guò)socket()接口打開(kāi)一個(gè)服務(wù)端socket文件

然后設(shè)置需要綁定的服務(wù)端ip地址及端口號(hào)。

在進(jìn)行監(jiān)聽(tīng)，需要注意的是此處監(jiān)聽(tīng)不會(huì)處于阻塞態(tài)。

int wifi_server(void* arg){ int server_fd, ret;

while(1) { server_fd = socket(AF_INET, SOCK_STREAM, 0); //AF_INET:IPV4;SOCK_STREAM:TCP // server_fd = lwip_socket(AF_INET, SOCK_STREAM, 0); //AF_INET:IPV4;SOCK_STREAM:TCP if (server_fd < 0) { printf("create socket fail!\n"); return -1; }

/*設(shè)置調(diào)用close(socket)后,仍可繼續(xù)重用該socket。調(diào)用close(socket)一般不會(huì)立即關(guān)閉socket，而經(jīng)歷TIME_WAIT的過(guò)程。*/ int flag = 1; ret = setsockopt(server_fd, SOL_SOCKET, SO_REUSEADDR, &flag, sizeof(int)); if (ret != 0) { printf("[CommInitTcpServer]setsockopt fail, ret[%d]!\n", ret); } struct sockaddr_in serv_addr = {0}; serv_addr.sin_family = AF_INET; serv_addr.sin_addr.s_addr = htonl(INADDR_ANY); //IP地址，需要進(jìn)行網(wǎng)絡(luò)序轉(zhuǎn)換，INADDR_ANY：本地地址 // serv_addr.sin_addr.s_addr = inet_addr(OC_SERVER_IP); //IP地址，需要進(jìn)行網(wǎng)絡(luò)序轉(zhuǎn)換，INADDR_ANY：本地地址 serv_addr.sin_port = htons(SERVER_PORT); //端口號(hào)，需要網(wǎng)絡(luò)序轉(zhuǎn)換 /* 綁定服務(wù)器地址結(jié)構(gòu) */ ret = bind(server_fd, (struct sockaddr*)&serv_addr, sizeof(serv_addr)); // ret = lwip_bind(server_fd, (struct sockaddr*)&serv_addr, sizeof(serv_addr)); if (ret < 0) { printf("socket bind fail!\n"); lwip_close(server_fd); return -1; } /* 監(jiān)聽(tīng)socket 此處不阻塞 */ ret = listen(server_fd, 64); // ret = lwip_listen(server_fd, 64); if(ret != 0) { printf("socket listen fail!\n"); lwip_close(server_fd); return -1; } printf("[tcp server] listen:%d<%s:%d>\n",server_fd, inet_ntoa(serv_addr.sin_addr), ntohs(serv_addr.sin_port)); tcp_server_msg_handle(server_fd); //處理接收到的數(shù)據(jù) LOS_Msleep(1000); }}

這部分是tcp客戶(hù)端的接收消息處理函數(shù)

先進(jìn)行嘗試連接pc機(jī)的服務(wù)端，如果失敗則延遲5秒后重新連接直到連接成功。

連接成功后先發(fā)消息給PC的服務(wù)端，然后進(jìn)入接收狀態(tài)，此狀態(tài)是阻塞態(tài)。

當(dāng)接收到pc的消息后進(jìn)入循環(huán)發(fā)送狀態(tài)。

void tcp_client_msg_handle(int fd, struct sockaddr* dst){ socklen_t len = sizeof(*dst);

int cnt = 0, count = 0; while (connect(fd, dst, len) < 0) { printf("connect server failed...%d\n", ++count); lwip_close(fd); LOS_Msleep(5000); fd = socket(AF_INET, SOCK_STREAM, 0); //AF_INET:IPV4;SOCK_STREAM:TCP } while (1) { char buf[BUFF_LEN]; sprintf(buf, "TCP TEST cilent send:%d", ++cnt); count = send(fd, buf, strlen(buf), 0); //發(fā)送數(shù)據(jù)給server // count = lwip_write(fd, buf, strlen(buf)); //發(fā)送數(shù)據(jù)給server printf("------------------------------------------------------------\n"); printf("[tcp client] send:%s\n", buf); printf("[tcp client] client sendto msg to server %d,waitting server respond msg!!!\n", count); memset(buf, 0, BUFF_LEN); count = recv(fd, buf, BUFF_LEN, 0); //接收來(lái)自server的信息 // count = lwip_read(fd, buf, BUFF_LEN); //接收來(lái)自server的信息 if(count == -1) { printf("[tcp client] recieve data fail!\n"); LOS_Msleep(3000); break; } printf("[tcp client] rev:%s\n", buf); } lwip_close(fd);}

這部分代碼是tcp客戶(hù)端代碼

客戶(hù)端處理流程

socket-->connect-->send-->recv-->lwip_close

先通過(guò)socket（）接口創(chuàng)建客戶(hù)端的socket文件。

然后設(shè)置客戶(hù)端連接PC服務(wù)端的ip地址及端口號(hào)。

在進(jìn)行connect連接。

int wifi_client(void* arg){ int client_fd, ret; struct sockaddr_in serv_addr; while(1) { client_fd = socket(AF_INET, SOCK_STREAM, 0);//AF_INET:IPV4;SOCK_STREAM:TCP if (client_fd < 0) { printf("create socket fail!\n"); return -1; }

/*設(shè)置調(diào)用close(socket)后,仍可繼續(xù)重用該socket。調(diào)用close(socket)一般不會(huì)立即關(guān)閉socket，而經(jīng)歷TIME_WAIT的過(guò)程。*/ int flag = 1; ret = setsockopt(client_fd, SOL_SOCKET, SO_REUSEADDR, &flag, sizeof(int)); if (ret != 0) { printf("[CommInitTcpServer]setsockopt fail, ret[%d]!\n", ret); } memset(&serv_addr, 0, sizeof(serv_addr)); serv_addr.sin_family = AF_INET; serv_addr.sin_addr.s_addr = inet_addr(OC_SERVER_IP); serv_addr.sin_port = htons(SERVER_PORT); printf("[tcp client] connect:%d<%s:%d>\n",client_fd, inet_ntoa(serv_addr.sin_addr), ntohs(serv_addr.sin_port)); tcp_client_msg_handle(client_fd, (struct sockaddr*)&serv_addr); LOS_Msleep(1000); }

return 0;}

這部分是tcp創(chuàng)建客戶(hù)端和服務(wù)端任務(wù)

可以看到在創(chuàng)建客戶(hù)端和服務(wù)端任務(wù)前先阻塞判斷wifi的連接狀態(tài)。

只有wifi連接成功后才創(chuàng)建客戶(hù)端和服務(wù)端任務(wù)。

void wifi_process(void *args){ unsigned int threadID_client, threadID_server; unsigned int ret = LOS_OK; WifiLinkedInfo info;

while(get_wifi_info(&info) != 0) ;

CreateThread(&threadID_client, wifi_client, NULL, "client@ process"); CreateThread(&threadID_server, wifi_server, NULL, "server@ process");}

這部分是創(chuàng)建wifi tcp 通信任務(wù)主要是為了使用APP_FEATURE_INIT(wifi_tcp_example);

這樣當(dāng)OpenHarmony初始化完成后會(huì)自動(dòng)執(zhí)行此任務(wù)。

void wifi_tcp_example(void){ unsigned int ret = LOS_OK; unsigned int thread_id; TSK_INIT_PARAM_S task = {0}; printf("%s start ....\n", __FUNCTION__);

task.pfnTaskEntry = (TSK_ENTRY_FUNC)wifi_process; task.uwStackSize = 10240; task.pcName = "wifi_process"; task.usTaskPrio = 24; ret = LOS_TaskCreate(&thread_id, &task); if (ret != LOS_OK) { printf("Falied to create wifi_process ret:0x%x\n", ret); return; }}APP_FEATURE_INIT(wifi_tcp_example);