10 求大神看一下，socket操作有无问题。

发布于 2023-08-30 13:17:48 浏览：437 订阅该版

```c

/*---------------------------------
Function: 网络连接    
Descript: 0--成功  1--失败
-----------------------------------*/
int net_open(int channel, NetPara_t* net)  //channel从1开始
{
    
    
    int sock = 0;
    int domain = 0;
    int type = 0;
    struct sockaddr_in remote_addr = {0};

if(net_port == NET_PORT_W5500) 
    {
        domain = AF_WIZ;
    }
    else if((net_port == NET_PORT_EC200) || (net_port == NET_PORT_ESP8266))
    {
        domain = AF_AT;
    }

if(net->protocolType == CONNECT_TYPE_TCP)
    {
        type = SOCK_STREAM;
    }
    else if(net->protocolType == CONNECT_TYPE_UDP)
    {
        type = SOCK_DGRAM;
    }

if(*(u32*)net->serveIP)  //远端IP不为0.0.0.0 使用IP地址
    {
    	remote_addr.sin_family = domain;
        remote_addr.sin_addr.s_addr = *(u32 *)net->serveIP;
    	remote_addr.sin_port = htons(net->servePort);
    	remote_addr.sin_len = sizeof(remote_addr);
    }
    else                    //域名解析
    {
        struct hostent *host = RT_NULL;
        host = gethostbyname(net->host);
        if (host == RT_NULL)
        {
            return 1;   
        }

remote_addr.sin_family = domain;
        remote_addr.sin_addr = *((struct in_addr *)host->h_addr);
        remote_addr.sin_port = htons(net->servePort);
        remote_addr.sin_len = sizeof(remote_addr);
    }
    
    sock = socket(domain, type, 0);
    if(sock < 0)
	{
		return 1;
	}
	if(connect(sock, (struct sockaddr *) &remote_addr, sizeof(remote_addr)) != 0)
	{
        closesocket(sock);
		return 1;
	}
    net_sock[channel] = sock;  //sokcet值保存
    
	return 0;
    
    
}

/*---------------------------------
Function: 网络发送
Descript: 0--成功  1--失败
-----------------------------------*/
int net_write(int channel, u8 *buf, int len)
{

if(net_sock[channel] <= 0)
    {
        return 1;
    }
    fd_set writeset;
	struct timeval timeout;
	int ret  = 0;
	timeout.tv_sec = 0;
	timeout.tv_usec = 0;
	FD_ZERO(&writeset);
	FD_SET(net_sock[channel], &writeset);
	ret = select(net_sock[channel] + 1, 0, &writeset, 0, &timeout);

if(ret > 0)
	{
		if(FD_ISSET(net_sock[channel], &writeset))
		{
			send(net_sock[channel], buf, len, 0);
			return 0;
		}
	}

return 1;
}

/*---------------------------------
Function: 网络接收
Descript: 0--失败  其他--接收长度
-----------------------------------*/
int net_read(int channel, u8 *buf, int len)
{
    
    if(net_sock[channel] <= 0)
    {
        return 0;
    }
    fd_set readset;
	struct timeval timeout;
	int ret  = 0;
	timeout.tv_sec = 0;
	timeout.tv_usec = 0;
	FD_ZERO(&readset);
	FD_SET(net_sock[channel], &readset);
	ret = select(net_sock[channel] + 1, &readset, 0, 0, &timeout);

if(ret > 0)
	{
		if(FD_ISSET(net_sock[channel], &readset))
		{
			int rcv_len = recv(net_sock[channel], buf, len, 0);
			if(rcv_len > 0)
			{
                return rcv_len;
			}
		}
	}
    
    return 0;
}
/*---------------------------------
Function: 网络关闭
Descript: 0--成功  1--失败
-----------------------------------*/
int net_close(int channel)
{
    closesocket(net_sock[channel]);
    net_sock[channel] = 0;
    return 0;
}
```