【小e物联网试用体验】开发板初步试用(完结-5)

ti

6.3.1创建文件iot_app/user/user_internet.c，该文件实现tcp客户端初始化、建立与应用服务器的tcp连接、tcp连接相关的回调函数等。

......

void InterNet_TCP_SendData(uint8 *buf,uint16 len);

void User_TCP_Client_Init(char * ipAddress, int32_t port);

LOCAL os_timer_t test_timer;

ip_addr_t tcp_server_ip;

typedef enum{

teClient,

teServer

}teType;

esp_tcp user_tcp;

struct ip_info client_ipinfo;

typedef struct

{

BOOL linkEn; //是否自动重联

BOOL teToff;

uint8 linkId;

teType teType;

uint8 repeaTime;

struct espconn uConn;

} espConnectionType;

espConnectionType user_contype;

static ip_addr_t host_ip;

char data[1024] = { "test ok!n" };

/**

* @brief 接收回调函数

* @param arg: contain the ip link information

* @param pdata: received data

* @param len: the lenght of received data

* @retval None

*/

static void ICACHE_FLASH_ATTR

InterNet_Receive(void *arg, char *pdata, unsigned short len)

{

os_printf("rnReceive Data:%srn",pdata);

os_printf("rn");

InterNet_TCP_SendData((uint8 *)pdata,(uint16)len); //收到什么回发什么

return;

}

......

/**

* @brief 断开连接成功后的回调函数

* @param arg: contain the ip link information

* @retval None

*/

static void ICACHE_FLASH_ATTR

InterNet_Disconnect_Cb(void *arg)

{

/*

struct espconn *pespconn = (struct espconn *)arg;

espConnectionType *linkTemp = (espConnectionType *)pespconn->reserve;

if(pespconn == NULL) {

return;

}

if(pespconn->proto.tcp != NULL) {

os_free(pespconn->proto.tcp);

}

os_free(pespconn);

linkTemp->linkEn = FALSE;*/

os_printf("rnDisConnect! try to reconnect......rn");

//try to reconnect to server

espconn_connect(&user_contype.uConn);

}

/**

* @brief 连接成功后的回调函数

* @param arg: contain the ip link information

* @retval None

*/

static void ICACHE_FLASH_ATTR

InterNet_Connect_Cb(void *arg) {

......

espconn_regist_recvcb(pespconn, InterNet_Receive);

espconn_regist_sentcb(pespconn, InterNet_Send_Cb);

espconn_regist_disconcb(pespconn, InterNet_Disconnect_Cb);

espconn_sent(pespconn, (uint8 *) data, (uint16)strlen(data));

}

/**

* @brief 重联回调函数

* @param arg: contain the ip link information

* @retval None

*/

static void ICACHE_FLASH_ATTR

InterNet_Reconnect_Cb(void *arg, sint8 errType) {

......

}

/**

* @brief dns查询回调函数

* @param name -- pointer to the name that was looked up.

* @param ipaddr -- pointer to an ip_addr_t containing the IP address of

* the hostname, or NULL if the name could not be found (or on any

* other error).

* @param callback_arg -- a user-specified callback argument passed to

* dns_gethostbyname

* @retval None

*/

LOCAL void ICACHE_FLASH_ATTR

InterNet_Dns_Cb(const char *name, ip_addr_t *ipaddr, void *arg) {

......

}

user_dns_check_cb(void *arg)

{

......

}

/** Station模式下

* @brief 配置tcp 客户端

* @param ipAddress -- 远程主机IP 地址

* @param port -- 远程主机端口号

*/

void ICACHE_FLASH_ATTR

User_TCP_Client_Init(char * ipAddress, sint32 port)

{

char ipTemp[128];

uint32 ip = 0;

sint8 result = 0;

user_contype.uConn.state = ESPCONN_NONE;

user_contype.linkId = 0;

ip = ipaddr_addr(ipAddress);

os_printf("tcp client init!(server ip:%s,server port:%d)n",ipAddress,port);

user_contype.uConn.type = ESPCONN_TCP;

user_contype.uConn.proto.tcp = malloc(sizeof(esp_tcp));

user_contype.uConn.proto.tcp->local_port = espconn_port();

wifi_get_ip_info(0,&client_ipinfo);

memcpy(&user_contype.uConn.proto.tcp->local_ip,&client_ipinfo.ip,4);

user_contype.uConn.proto.tcp->remote_port = port;

if("" != NET_DOMAIN)//DNS

{

espconn_gethostbyname(&user_contype.uConn, NET_DOMAIN, &tcp_server_ip, InterNet_Dns_Cb); // DNS function

os_timer_disARM(&test_timer);

os_timer_setfn(&test_timer, (os_timer_func_t *)user_dns_check_cb, &user_contype.uConn);

os_timer_arm(&test_timer, 1000, 0);

}else{ //IP

memcpy(&user_contype.uConn.proto.tcp->remote_ip,&ip,4);

espconn_regist_connectcb(&user_contype.uConn, InterNet_Connect_Cb);

espconn_regist_reconcb(&user_contype.uConn, InterNet_Reconnect_Cb);

result = espconn_connect(&user_contype.uConn);

os_printf("espconn remote IP:%d.%d.%d.%dn",user_contype.uConn.proto.tcp->remote_ip[0],user_contype.uConn.proto.tcp->remote_ip[1],user_contype.uConn.proto.tcp->remote_ip[2],user_contype.uConn.proto.tcp->remote_ip[3]);

os_printf("espconn remote port:%dn",user_contype.uConn.proto.tcp->remote_port);

os_printf("espconn local IP:%d.%d.%d.%dn",user_contype.uConn.proto.tcp->local_ip[0],user_contype.uConn.proto.tcp->local_ip[1],user_contype.uConn.proto.tcp->local_ip[2],user_contype.uConn.proto.tcp->local_ip[3]);

// os_printf("espconn local IP:%dn",user_contype.uConn.proto.tcp->local_ip);

os_printf("espconn local port:%dn",user_contype.uConn.proto.tcp->local_port);

if(result == 0){

os_printf("espconn connect success!n");

}else

{

os_printf("espconn connect failed!(code:%d)n",result);

}

void ICACHE_FLASH_ATTR

InterNet_TCP_SendData(uint8 *buf,uint16 len)

{

espconn_sent(&user_contype.uConn,buf,len);

}

TCP发送数据函数

TCP类型定义

客户端

服务端

接收数据函数

收到后直接echo

连接断开处理函数

断开后进行重连

设置回调函数(接收数据)

设置回调函数(发送数据)

设置回调函数(断连)

发送数据

TCP客户端初始化

先初始化变量--->

设置ip地址

设置连接类型

获取本地空闲端口

设置应用服务器端口号

设置协议类型

采用DNS连接方式

//采用IP地址

设置回调函数(连接)

设置回调函数(重连)

建立连接

6.3.2在iot_app/include目录下创建文件user_internet.h，内容如下：

#ifndef __USER_INTERNET_H

#define __USER_INTERNET_H

#define SERVER_IP "192.168.1.6"

#define SERVER_PORT 20006

void InterNet_InitTCP(char * ipAddress, int32_t port);

void InterNet_TCP_SendData(uint8 *buf,uint16_t len);

#endif

服务器IP地址

服务器端口号

TCP客户端初始化函数

TCP发送数据函数

6.3.3在iot_app/user/user_main.c中添加初始化相关代码：

......

void TCPClient(void *pvParameters)

{

User_TCP_Client_Init(SERVER_IP,SERVER_PORT);

}

......

void et_wifi_event_cb(System_Event_t *event)

{

printf("et_wifi_event_cb,event_id:%dn",event->event_id);

switch(event->event_id)

{

case EVENT_STAMODE_SCAN_DONE:

os_printf("scan done n");

break;

case EVENT_STAMODE_CONNECTED:

os_printf("connect to ssid:%s,channel:%d n",event->event_info.connected.ssid,event->event_info.connected.channel);

break;

case EVENT_STAMODE_DISCONNECTED:

os_printf("disconnect from %s, reason:%sn",event->event_info.disconnected.ssid,event->event_info.disconnected.reason);

if(true != wifi_station_get_reconnect_policy())

{

os_printf("et wifi set to reconnectn");

wifi_station_set_reconnect_policy(true);

}

os_printf("wifi reconnect start flag: %dn",wifi_reconnect_start_flag);

if(wifi_reconnect_start_flag == 1)

{

os_printf("wifi connect status:%d, restart system!n",wifi_station_get_connect_status());

system_restart();

}

break;

case EVENT_STAMODE_AUTHMODE_CHANGE:

os_printf("auth mode changed: %d -> %d n",event->event_info.auth_change.old_mode,event->event_info.auth_change.new_mode);

break;

case EVENT_STAMODE_GOT_IP:

os_printf("Got IP! ip:" IPSTR ",mask:" IPSTR ",gw:" IPSTR,IP2STR(&event->event_info.got_ip.ip),IP2STR(&event->event_info.got_ip.mask),IP2STR(&event->event_info.got_ip.gw));

os_printf("n");

//启动TCP客户端任务

User_TCP_Client_Init(SERVER_IP,SERVER_PORT);

break;

case EVENT_STAMODE_DHCP_TIMEOUT:

os_printf("wifi dhcp timeoutn");

break;

case EVENT_SOFTAPMODE_STACONNECTED:

os_printf("et station: " MACSTR "join, AID = %dn",MAC2STR(event->event_info.sta_connected.mac),event->event_info.sta_connected.aid);

break;

case EVENT_SOFTAPMODE_STADISCONNECTED://a station disconnected to ESP8266 soft-AP

os_printf("et station: " MACSTR "leave, AID = %dn",MAC2STR(event->event_info.sta_disconnected.mac),event->event_info.sta_disconnected.aid);

break;

default:

break;

}

......

void user_init(void)

{

......

espconn_init();

......

wifi_set_event_handler_cb(et_wifi_event_cb);

......

}

调用TCP客户端初始化函数

wifi事件监控回调函数

获得IP地址

获得IP地址后，进行TCP客户端初始化

espconn模块初始化

设置wifi事件监控回调函数

搜索历史

【小e物联网试用体验】开发板初步试用(完结-5)

相关推荐

精选推荐

最新话题

热门话题

创建小组步骤

站长推荐 /7