当前位置： 首页 > news >正文

LWIP的Socket接口

news 2025/5/19 6:13:24

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); /* 删除本任务 */
}


 

http://www.xdnf.cn/news/513343.html

相关文章：

  • 扫描件交叉合并PDF免费软件 拖拽即合并 + 自动对齐页码 档案整合更轻松
  • C++多态与虚函数详解——从入门到精通
  • 【计算机网络】第一章：计算机网络体系结构
  • 数青蛙 --- 模拟
  • Go语言中函数 vs 方法
  • JVM如何处理多线程内存抢占问题
  • 【Java学习笔记】【第一阶段项目实践】房屋出租系统（面向对象版本）
  • 【Linux】第十九章 管理SELinux安全性
  • 数字格式化库 accounting.js的使用说明
  • “Cloud Native English“云原生时代下的微服务架构设计：从理论到实战全解析
  • 【数据结构】2-3-2 单链表的插入删除
  • 结构型模式：代理模式
  • 改进模糊C均值时序聚类+编码器状态识别！IPOA-FCM-Transformer组合模型
  • 牛客网NC276055:三根木棒能否组成三角形问题详解(ACM中的A题)
  • 【C++】尾置返回类型（Trailing Return Type）总结
  • 多模态大语言模型arxiv论文略读（八十）
  • vscode优化使用体验篇（快捷键）
  • React 19版本refs也支持清理函数了。
  • 【C++】set、map 容器的使用
  • Java 中 == 与 equals() 详解
  • 索引与数据结构、并行算法
  • LlamaIndex中应用自定义提示词提升回答质量
  • go语言协程调度器 GPM 模型
  • 华为云Flexus+DeepSeek征文｜基于华为云Flexus云服务的Dify 快速构建聊天助手
  • 目标检测新突破：用MSBlock打造更强YOLOv8
  • 如何使用WordPress创建美食博客
  • 跨平台多用户环境下PDF表单“序列号生成的服务器端方案“
  • 如何实现RTSP和RTMP低至100-200ms的延迟：直播SDK的技术突破
  • Metasploit框架与网络安全攻防技术解析
  • 标准库、HAl库和LL库（PC13初始化）