Socket接口简介
类似于文件操作的一种网络连接接口，通常将其称之为“套接字”。lwIP的Socket接口兼容BSD Socket接口，但只实现完整Socket的部分功能
netconn是对RAW的封装
Socket是对netconn的封装
SOCKET结构体
struct sockaddr {
u8_t sa_len; /* 长度 */
sa_family_t sa_family; /* 协议簇 */
char sa_data[14]; /* 连续的 14 字节信息 */
};
struct sockaddr_in {
u8_t sin_len; /* 长度 */
u8_t sin_family; /* 协议簇 */
u16_t sin_port; /* 端口号 */
struct in_addr sin_addr; /* IP 地址 */
char sin_zero[8];
}为啥用两个结构体
sockaddr的缺陷是：sa_zero把目标地址和端口信息混在了一起
sockaddr_in该结构体解决了sockaddr的缺陷，把port和addr分开存储在两个变量中
NETCONN相关函数
| SOCKET API | 描述 |
| scoket | 创建一个scoket连接 |
| bind | 服务器端绑定套接字与网卡信息 |
| connect | 将 Socket 与远程 IP 地址和端口号绑定 |
| listen | 监听连接 |
| accept | 断开连接 |
| read/recv/recvfrom | 监听连接（只在TCP服务器） |
| sendto/send/write | 获取一个TCP连接（只在TCP服务器） |
| close | 关闭连接 |
Socket 编程 UDP 连接流程
实现 UDP 协议之前， 用户必须先配置结构体 sockaddr_in 的成员变量才能实现 UDP 连接，该配置步骤如下所示：
① sin_family 设置为 AF_INET 表示 IPv4 网络协议。
② sin_port 为设置端口号， 笔者设置为 8080。
③ sin_addr.s_addr 设置本地 IP 地址。
④ 调用函数 Socket 创建 Socket 连接，注意： 该函数的第二个参数 SOCK_STREAM 表
示 TCP 连接， SOCK_DGRAM 表示 UDP 连接。
⑤ 调用函数 bind 将本地服务器地址与 Socket 进行绑定。
⑥ 调用收发函数接收或者发送。
实现连接的主要函数
/* 需要自己设置远程IP地址 */
#define IP_ADDR "192.168.1.111"#define LWIP_DEMO_RX_BUFSIZE 200 /* 最大接收数据长度 */
#define LWIP_DEMO_PORT 8080 /* 连接的本地端口号 */
#define LWIP_SEND_THREAD_PRIO ( tskIDLE_PRIORITY + 3 ) /* 发送数据线程优先级 *//* 接收数据缓冲区 */
uint8_t g_lwip_demo_recvbuf[LWIP_DEMO_RX_BUFSIZE];
/* 发送数据内容 */
char g_lwip_demo_sendbuf[] = "ALIENTEK DATA \r\n";
/* 数据发送标志位 */
uint8_t g_lwip_send_flag;
struct sockaddr_in g_local_info; /* 定义Socket地址信息结构体 */
socklen_t g_sock_fd; /* 定义一个Socket接口 */
static void lwip_send_thread(void *arg);extern QueueHandle_t g_display_queue; /* 显示消息队列句柄 *//*** @brief 发送数据线程* @param 无* @retval 无*/
void lwip_data_send(void)
{sys_thread_new("lwip_send_thread", lwip_send_thread, NULL, 512, LWIP_SEND_THREAD_PRIO );
}/*** @brief lwip_demo实验入口* @param 无* @retval 无*/
void lwip_demo(void)
{BaseType_t lwip_err;char *tbuf;lwip_data_send(); /* 创建发送数据线程 */memset(&g_local_info, 0, sizeof(struct sockaddr_in)); /* 将服务器地址清空 */g_local_info.sin_len = sizeof(g_local_info);g_local_info.sin_family = AF_INET; /* IPv4地址 */g_local_info.sin_port = htons(LWIP_DEMO_PORT); /* 设置端口号 */g_local_info.sin_addr.s_addr = htons(INADDR_ANY); /* 设置本地IP地址 */g_sock_fd = socket(AF_INET, SOCK_DGRAM, 0); /* 建立一个新的socket连接 */tbuf = mymalloc(SRAMIN, 200); /* 申请内存 */sprintf((char *)tbuf, "Port:%d", LWIP_DEMO_PORT); /* 客户端端口号 */lcd_show_string(5, 150, 200, 16, 16, tbuf, BLUE);/* 建立绑定 */bind(g_sock_fd, (struct sockaddr *)&g_local_info, sizeof(struct sockaddr_in));while (1){memset(g_lwip_demo_recvbuf, 0, sizeof(g_lwip_demo_recvbuf));recv(g_sock_fd, (void *)g_lwip_demo_recvbuf, sizeof(g_lwip_demo_recvbuf), 0);lwip_err = xQueueSend(g_display_queue,&g_lwip_demo_recvbuf,0);if (lwip_err == errQUEUE_FULL){printf("队列Key_Queue已满，数据发送失败!\r\n");}}
}/*** @brief 发送数据线程函数* @param pvParameters : 传入参数(未用到)* @retval 无*/
void lwip_send_thread(void *pvParameters)
{pvParameters = pvParameters;g_local_info.sin_addr.s_addr = inet_addr(IP_ADDR); /* 需要发送的远程IP地址 */while (1){if ((g_lwip_send_flag & LWIP_SEND_DATA) == LWIP_SEND_DATA) /* 有数据要发送 */{sendto(g_sock_fd, /* scoket */(char *)g_lwip_demo_sendbuf, /* 发送的数据 */sizeof(g_lwip_demo_sendbuf), 0, /* 发送的数据大小 */(struct sockaddr *)&g_local_info, /* 接收端地址信息 */ sizeof(g_local_info)); /* 接收端地址信息大小 */g_lwip_send_flag &= ~LWIP_SEND_DATA;}vTaskDelay(100);}
}
Socket 编程 UDP 组播实验
必须对以下保证设置
\Drivers\STM32F4xx_HAL_Driver\Src\stm32f4xx_hal_eth.c
static void ETH_MACDMAConfig(ETH_HandleTypeDef *heth, uint32_t err)
macinit.ReceiveAll = ETH_RECEIVEALL_ENABLE; //使能 全部接收
macinit.MulticastFramesFilter = ETH_MULTICASTFRAMESFILTER_NONE;//不过滤 组播的帧
\Middlewares\lwip\arch\lwipopts.h
保证设置1
\Middlewares\LWIP\arch\ethernetif.c
static void low_level_init(struct netif *netif)
必须保证添加如下所有标志位
netif->flags = NETIF_FLAG_BROADCAST|NETIF_FLAG_ETHARP|NETIF_FLAG_LINK_UP|NETIF_FLAG_IGMP; /*广播 ARP协议 链接检测*/
组播的主要实现函数
/* socket信息 */
struct link_socjet_info
{struct sockaddr_in client_addr; /* 网络地址信息 */socklen_t client_addr_len; /* 网络地址信息长度 */int optval; /* 为存放选项值 */int sfd; /* socket控制块 */ip_mreq multicast_mreq; /* 组播控制块 */struct{uint8_t *buf; /* 缓冲空间 */uint32_t size; /* 缓冲空间大小 */} send; /* 发送缓冲 */struct{uint8_t *buf; /* 缓冲空间 */uint32_t size; /* 缓冲空间大小 */} recv; /* 接收缓冲 */
};/* 多播信息 */
struct ip_mreq_t
{struct ip_mreq mreq; /* 多播信息控制块 */socklen_t mreq_len; /* 多播信息长度 */
};#define LWIP_SEND_THREAD_PRIO (tskIDLE_PRIORITY + 3) /* 发送数据线程优先级 */
void lwip_send_thread(void *pvParameters);
/* 接收数据缓冲区 */
static uint8_t g_lwip_demo_recvbuf[1024];
static uint8_t g_lwip_demo_sendbuf[] = {"ALIENTEK DATA\r\n"}; /* 多播 IP 地址 */
#define GROUP_IP "224.0.1.0"/*** @brief 测试代码* @param 无* @retval 无*/
void lwip_demo(void)
{struct link_socjet_info *socket_info;struct ip_mreq_t *mreq_info;socket_info = mem_malloc(sizeof(struct link_socjet_info));mreq_info = mem_malloc(sizeof(struct ip_mreq_t));socket_info->sfd = socket(AF_INET, SOCK_DGRAM, 0);if (socket_info->sfd < 0){printf("socket failed!\n");}socket_info->client_addr.sin_family = AF_INET;socket_info->client_addr.sin_addr.s_addr = htonl(INADDR_ANY); /* 待与 socket 绑定的本地网络接口 IP */ socket_info->client_addr.sin_port = htons(9999); /* 待与 socket 绑定的本地端口号 */socket_info->client_addr_len = sizeof(socket_info->client_addr);/* 设置接收和发送缓冲区 */socket_info->recv.buf = g_lwip_demo_recvbuf;socket_info->recv.size = sizeof(g_lwip_demo_recvbuf);socket_info->send.buf = g_lwip_demo_sendbuf;socket_info->send.size = sizeof(g_lwip_demo_sendbuf);/* 将 Socket 与本地某网络接口绑定 */int ret = bind(socket_info->sfd, (struct sockaddr*)&socket_info->client_addr, socket_info->client_addr_len);if (ret < 0){printf(" bind error!\n ");}mreq_info->mreq.imr_multiaddr.s_addr = inet_addr(GROUP_IP); /* 多播组 IP 地址设置 */mreq_info->mreq.imr_interface.s_addr = htonl(INADDR_ANY); /* 待加入多播组的 IP 地址 */mreq_info->mreq_len = sizeof(struct ip_mreq);/* 添加多播组成员（该语句之前，socket 只与 某单播IP地址相关联 执行该语句后 将与多播地址相关联） */ret = setsockopt(socket_info->sfd,IPPROTO_IP,IP_ADD_MEMBERSHIP,&mreq_info->mreq,mreq_info->mreq_len);if (ret < 0){printf("setsockopt failed !");}else{printf("setsockopt success\n");}int length = 0;struct sockaddr_in sender;int sender_len = sizeof(sender);sys_thread_new("lwip_send_thread", lwip_send_thread, (void *)socket_info, 512, LWIP_SEND_THREAD_PRIO );while(1){length = recvfrom(socket_info->sfd,socket_info->recv.buf,socket_info->recv.size,0,(struct sockaddr*)&sender,(socklen_t *)&sender_len);socket_info->recv.buf[length]='\0';printf("%s %d : %s\n", inet_ntoa(sender.sin_addr), ntohs(sender.sin_port), socket_info->recv.buf);vTaskDelay(10);}setsockopt(socket_info->sfd, IPPROTO_IP, IP_DROP_MEMBERSHIP,&mreq_info->mreq, mreq_info->mreq_len);closesocket(socket_info->sfd);
}/*** @brief 发送数据线程函数* @param pvParameters : 传入struct link_socjet_info结构体* @retval 无*/
void lwip_send_thread(void *pvParameters)
{struct link_socjet_info *socket_info = pvParameters;socket_info->client_addr.sin_addr.s_addr = inet_addr(GROUP_IP); /* 组播ip */while (1){/* 数据广播 */sendto(socket_info->sfd, socket_info->send.buf, socket_info->send.size + 1, 0, (struct sockaddr*)&socket_info->client_addr,socket_info->client_addr_len);vTaskDelay(1000);}
}Socket 编程 TCP 客户端流程
实现 TCP 客户端之前，用户必须先配置结构体 sockaddr_in 的成员变量才能实现TCPClient 连接，该配置步骤如下所示：
① sin_family 设置为 AF_INET 表示 IPv4 网络协议。
② sin_port 为设置端口号。
③ sin_addr.s_addr 设置远程 IP 地址。
④ 调用函数 Socket 创建 Socket 连接， 注意： 该函数的第二个参数 SOCK_STREAM 表
示 TCP 连接， SOCK_DGRAM 表示 UDP 连接。
⑤ 调用函数 connect 连接远程 IP 地址。
⑥ 调用收发函数实现远程通讯。
Socket 接口的 TCPClient 实验
实现的主要代码
/* 设置远程IP地址 */
//#define DEST_IP_ADDR0 192
//#define DEST_IP_ADDR1 168
//#define DEST_IP_ADDR2 1
//#define DEST_IP_ADDR3 167/* 需要自己设置远程IP地址 */
#define IP_ADDR "192.168.1.37"#define LWIP_DEMO_RX_BUFSIZE 100 /* 最大接收数据长度 */
#define LWIP_DEMO_PORT 8080 /* 连接的本地端口号 */
#define LWIP_SEND_THREAD_PRIO ( tskIDLE_PRIORITY + 3 ) /* 发送数据线程优先级 */
/* 接收数据缓冲区 */
uint8_t g_lwip_demo_recvbuf[LWIP_DEMO_RX_BUFSIZE]; /* 发送数据内容 */
uint8_t g_lwip_demo_sendbuf[] = "ALIENTEK DATA \r\n";
/* 数据发送标志位 */
uint8_t g_lwip_send_flag;
int g_sock = -1;
int g_lwip_connect_state = 0;
static void lwip_send_thread(void *arg);extern QueueHandle_t g_display_queue; /* 显示消息队列句柄 *//*** @brief 发送数据线程* @param 无* @retval 无*/
void lwip_data_send(void)
{sys_thread_new("lwip_send_thread", lwip_send_thread, NULL, 512, LWIP_SEND_THREAD_PRIO );
}/*** @brief lwip_demo实验入口* @param 无* @retval 无*/
void lwip_demo(void)
{struct sockaddr_in atk_client_addr;err_t err;int recv_data_len;BaseType_t lwip_err;char *tbuf;lwip_data_send(); /* 创建发送数据线程 */while (1){
sock_start:g_lwip_connect_state = 0;atk_client_addr.sin_family = AF_INET; /* 表示IPv4网络协议 */atk_client_addr.sin_port = htons(LWIP_DEMO_PORT); /* 端口号 */atk_client_addr.sin_addr.s_addr = inet_addr(IP_ADDR); /* 远程IP地址 */g_sock = socket(AF_INET, SOCK_STREAM, 0); /* 可靠数据流交付服务既是TCP协议 */memset(&(atk_client_addr.sin_zero), 0, sizeof(atk_client_addr.sin_zero));tbuf = mymalloc(SRAMIN, 200); /* 申请内存 */sprintf((char *)tbuf, "Port:%d", LWIP_DEMO_PORT); /* 客户端端口号 */lcd_show_string(5, 150, 200, 16, 16, tbuf, BLUE);/* 连接远程IP地址 */err = connect(g_sock, (struct sockaddr *)&atk_client_addr, sizeof(struct sockaddr));if (err == -1){printf("连接失败\r\n");g_sock = -1;closesocket(g_sock);myfree(SRAMIN, tbuf);vTaskDelay(10);goto sock_start;}printf("连接成功\r\n");lcd_show_string(5, 90, 200, 16, 16, "State:Connection Successful", BLUE);g_lwip_connect_state = 1;while (1){recv_data_len = recv(g_sock,g_lwip_demo_recvbuf,LWIP_DEMO_RX_BUFSIZE,0);if (recv_data_len <= 0 ){closesocket(g_sock);g_sock = -1;lcd_fill(5, 89, lcddev.width,110, WHITE);lcd_show_string(5, 90, 200, 16, 16, "State:Disconnect", BLUE);myfree(SRAMIN, tbuf);goto sock_start;}/* 接收的数据 */ lwip_err = xQueueSend(g_display_queue,&g_lwip_demo_recvbuf,0);if (lwip_err == errQUEUE_FULL){printf("队列Key_Queue已满，数据发送失败!\r\n");}vTaskDelay(10);}}
}/*** @brief 发送数据线程函数* @param pvParameters : 传入参数(未用到)* @retval 无*/
void lwip_send_thread(void *pvParameters)
{pvParameters = pvParameters;err_t err;while (1){while (1){if(((g_lwip_send_flag & LWIP_SEND_DATA) == LWIP_SEND_DATA) && (g_lwip_connect_state == 1)) /* 有数据要发送 */{err = write(g_sock, g_lwip_demo_sendbuf, sizeof(g_lwip_demo_sendbuf));if (err < 0){break;}g_lwip_send_flag &= ~LWIP_SEND_DATA;}vTaskDelay(10);}closesocket(g_sock);}
}
Socket 编程 TCP 服务器流程
实现 TCP 服务器之前，用户必须先配置结构体 sockaddr_in 的成员变量才能实现TCPServer 连接，该配置步骤如下所示：
① sin_family 设置为 AF_INET 表示 IPv4 网络协议。
② sin_port 为设置端口号。
③ sin_addr.s_addr 设置本地 IP 地址。
④ 调用函数 Socket 创建 Socket 连接，注意：该函数的第二个参数 SOCK_STREAM 表
示 TCP 连接， SOCK_DGRAM 表示 UDP 连接。
⑤ 调用函数 bind 绑定本地 IP 地址和端口号。
⑥ 调用函数 listen 监听连接请求。
⑦ 调用函数 accept 监听连接。
⑧ 调用收发函数进行通讯。
上述的步骤就是 Socket 编程接口配置 TCPServer 的流程。
Socket 接口的 TCPServer 实验
之后应用不要什么goto代码
/* 设置远程IP地址 */
//#define DEST_IP_ADDR0 192
//#define DEST_IP_ADDR1 168
//#define DEST_IP_ADDR2 1
//#define DEST_IP_ADDR3 167/* 需要自己设置远程IP地址 */
//#define IP_ADDR "192.168.1.167"#define LWIP_DEMO_RX_BUFSIZE 200 /* 最大接收数据长度 */
#define LWIP_DEMO_PORT 8080 /* 连接的本地端口号 */
#define LWIP_SEND_THREAD_PRIO ( tskIDLE_PRIORITY + 3 ) /* 发送数据线程优先级 *//* 接收数据缓冲区 */
uint8_t g_lwip_demo_recvbuf[LWIP_DEMO_RX_BUFSIZE];
/* 发送数据内容 */
uint8_t g_lwip_demo_sendbuf[] = "ALIENTEK DATA \r\n";/* 数据发送标志位 */
uint8_t g_lwip_send_flag;
int g_sock_conn; /* 请求的 socked */
int g_lwip_connect_state = 0;
static void lwip_send_thread(void *arg);
extern QueueHandle_t g_display_queue; /* 显示消息队列句柄 *//*** @brief 发送数据线程* @param 无* @retval 无*/
void lwip_data_send(void)
{sys_thread_new("lwip_send_thread", lwip_send_thread, NULL, 512, LWIP_SEND_THREAD_PRIO );
}/*** @brief lwip_demo实验入口* @param 无* @retval 无*/
void lwip_demo(void)
{struct sockaddr_in server_addr; /* 服务器地址 */struct sockaddr_in conn_addr; /* 连接地址 */socklen_t addr_len; /* 地址长度 */int err;int length;int sock_fd;char *tbuf;BaseType_t lwip_err;lwip_data_send(); /* 创建一个发送线程 */sock_fd = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP); /* 建立一个新的socket连接 */memset(&server_addr, 0, sizeof(server_addr)); /* 将服务器地址清空 */server_addr.sin_family = AF_INET; /* 地址家族 */server_addr.sin_addr.s_addr = htonl(INADDR_ANY); /* 注意转化为网络字节序 */server_addr.sin_port = htons(LWIP_DEMO_PORT); /* 使用SERVER_PORT指定为程序头设定的端口号 */tbuf = mymalloc(SRAMIN, 200); /* 申请内存 */sprintf((char *)tbuf, "Port:%d", LWIP_DEMO_PORT); /* 客户端端口号 */lcd_show_string(5, 150, 200, 16, 16, tbuf, BLUE);err = bind(sock_fd, (struct sockaddr *)&server_addr, sizeof(server_addr)); /* 建立绑定 */if (err < 0) /* 如果绑定失败则关闭套接字 */{closesocket(sock_fd); /* 关闭套接字 */myfree(SRAMIN, tbuf);}err = listen(sock_fd, 4); /* 监听连接请求 */if (err < 0) /* 如果监听失败则关闭套接字 */{closesocket(sock_fd); /* 关闭套接字 */}while(1){g_lwip_connect_state = 0;addr_len = sizeof(struct sockaddr_in); /* 将链接地址赋值给addr_len */g_sock_conn = accept(sock_fd, (struct sockaddr *)&conn_addr, &addr_len); /* 对监听到的请求进行连接，状态赋值给sock_conn */if (g_sock_conn < 0) /* 状态小于0代表连接故障，此时关闭套接字 */{closesocket(sock_fd);}else {lcd_show_string(5, 90, 200, 16, 16, "State:Connection Successful", BLUE);g_lwip_connect_state = 1;}while (1){memset(g_lwip_demo_recvbuf,0,LWIP_DEMO_RX_BUFSIZE);length = recv(g_sock_conn, (unsigned int *)g_lwip_demo_recvbuf, sizeof(g_lwip_demo_recvbuf), 0); /* 将收到的数据放到接收Buff */if (length <= 0){goto atk_exit;}// printf("%s",g_lwip_demo_recvbuf);lwip_err = xQueueSend(g_display_queue,&g_lwip_demo_recvbuf,0);if (lwip_err == errQUEUE_FULL){printf("队列Key_Queue已满，数据发送失败!\r\n");}}
atk_exit:if (g_sock_conn >= 0){ closesocket(g_sock_conn);g_sock_conn = -1;lcd_fill(5, 89, lcddev.width,110, WHITE);lcd_show_string(5, 90, 200, 16, 16, "State:Disconnect", BLUE);myfree(SRAMIN, tbuf);}}
}/*** @brief 发送数据线程函数* @param pvParameters : 传入参数(未用到)* @retval 无*/
static void lwip_send_thread(void *pvParameters)
{pvParameters = pvParameters;while (1){if(((g_lwip_send_flag & LWIP_SEND_DATA) == LWIP_SEND_DATA) && (g_lwip_connect_state == 1)) /* 有数据要发送 */{send(g_sock_conn, g_lwip_demo_sendbuf, sizeof(g_lwip_demo_sendbuf), 0); /* 发送数据 */g_lwip_send_flag &= ~LWIP_SEND_DATA;}vTaskDelay(1);}
}
Socket 编程接口 TCP 服务器多连接实验
开发板作为服务器，让多个客户端连接
客户端信息的结构体
/* 客户端的信息 */
struct client_info
{int socket_num; /* socket号的数量 */struct sockaddr_in ip_addr; /* socket客户端的IP地址 */int sockaddr_len; /* socketaddr的长度 */
};客户端的任务信息结构体
/* 客户端的任务信息 */
struct client_task_info
{UBaseType_t client_task_pro; /* 客户端任务优先级 */uint16_t client_task_stk; /* 客户端任务优先级 */TaskHandle_t * client_handler; /* 客户端任务控制块 */char *client_name; /* 客户端任务名称 */char *client_num; /* 客户端任务数量 */
};socket信息结构体
/* socket信息 */
struct link_socjet_info
{int sock_listen; /* 监听 */int sock_connect; /* 连接 */struct sockaddr_in listen_addr; /* 监听地址 */struct sockaddr_in connect_addr;/* 连接地址 */
};
实现多链接的主要函数
/*** @brief 客户端的任务函数* @param pvParameters : 传入链接客户端的信息* @retval 无*/
void lwip_client_thread_entry(void *param)
{struct client_info* client = param;/* 某个客户端连接 */printf("Client[%d]%s:%d is connect server\r\n", client->socket_num, inet_ntoa(client->ip_addr.sin_addr),ntohs(client->ip_addr.sin_port));/* 向客户端发送连接成功信息 */send(client->socket_num, (const void* )send_data, strlen(send_data), 0);while (1){char str[2048];memset(str, 0, sizeof(str));int bytes = recv(client->socket_num, str, sizeof(str), 0);//客户端发来的数据/* 获取关闭连接的请求 */if (bytes <= 0){mem_free(client);closesocket(client->socket_num);break;//退出这个whiel 删除任务}printf("[%d]%s:%d=>%s...\r\n", client->socket_num, inet_ntoa(client->ip_addr.sin_addr),ntohs(client->ip_addr.sin_port), str);send((int )client->socket_num, (const void * )str, (size_t )strlen(str), 0);}printf("[%d]%s:%d is disconnect...\r\n", client->socket_num, inet_ntoa(client->ip_addr.sin_addr),ntohs(client->ip_addr.sin_port));vTaskDelete(NULL); /* 删除该任务 */
}/*** @brief lwip_demo实验入口* @param 无* @retval 无*/
void lwip_demo(void)
{struct client_info *client_fo;struct client_task_info *client_task_fo;struct link_socjet_info *socket_link_info;int sin_size = sizeof(struct sockaddr_in);char client_name[10] = "cli";char client_num[10];/* socket连接结构体申请内存 */socket_link_info = mem_malloc(sizeof(struct link_socjet_info));/* 设置客户端任务信息 */client_task_fo = mem_malloc(sizeof(struct client_task_info));client_task_fo->client_handler = NULL;client_task_fo->client_task_pro = 5;client_task_fo->client_task_stk = 512;/* 创建socket连接 */if ((socket_link_info->sock_listen = socket(AF_INET, SOCK_STREAM, 0)) == -1){printf("Socket error\r\n");return;}/* 初始化连接的服务端地址 *///记录每个客户端的ip地址socket_link_info->listen_addr.sin_family = AF_INET;socket_link_info->listen_addr.sin_port = htons(8088);socket_link_info->listen_addr.sin_addr.s_addr = htonl(INADDR_ANY);memset(&(socket_link_info->listen_addr.sin_zero), 0, sizeof(socket_link_info->listen_addr.sin_zero));/* 绑定socket和连接的服务端地址信息 */if (bind(socket_link_info->sock_listen, (struct sockaddr * )&socket_link_info->listen_addr, sizeof(struct sockaddr)) < 0){printf("Bind fail!\r\n");goto __exit;}/* 监听客户端的数量 */listen(socket_link_info->sock_listen, 4);printf("begin listing...\r\n");while (1){/* 请求客户端连接 */socket_link_info->sock_connect = accept(socket_link_info->sock_listen, (struct sockaddr* )&socket_link_info->connect_addr, (socklen_t* )&sin_size);if (socket_link_info->sock_connect == -1){printf("no socket,waitting others socket disconnect.\r\n");continue;}lwip_itoa((char *)socket_link_info->sock_connect, (size_t)client_num, 10);strcat(client_name, client_num);client_task_fo->client_name = client_name;client_task_fo->client_num = client_num;/* 初始化连接客户端信息 */client_fo = mem_malloc(sizeof(struct client_info));client_fo->socket_num = socket_link_info->sock_connect;memcpy(&client_fo->ip_addr, &socket_link_info->connect_addr, sizeof(struct sockaddr_in));client_fo->sockaddr_len = sin_size;/* 创建连接的客户端任务 */xTaskCreate((TaskFunction_t )lwip_client_thread_entry,(const char * )client_task_fo->client_name,(uint16_t )client_task_fo->client_task_stk,(void * )(void*) client_fo,(UBaseType_t )client_task_fo->client_task_pro ++ ,(TaskHandle_t * )&client_task_fo->client_handler);if (client_task_fo->client_handler == NULL){printf("no memery for thread %s startup failed!\r\n",client_task_fo->client_name);mem_free(client_fo);continue;}else{printf("thread %s success!\r\n", client_task_fo->client_name);}}__exit: printf("listener failed\r\n");/* 关闭这个socket */closesocket(socket_link_info->sock_listen);vTaskDelete(NULL); /* 删除本任务 */
}
)
