LWIP STM32

5 lwip tcp 多客户端连接长时间通信出现异常断开

发布于 2021-04-14 16:03:04 浏览：3122 订阅该版

4 个回答

mii 2021-04-14

这家伙很懒，什么也没写！

flashman2002 2021-04-14

这家伙很懒，什么也没写！

latera 2021-04-14

这家伙很懒，什么也没写！

void ClientConnectTask(void *param)
{
	err_t err = ERR_OK;
	struct netconn *conn = pClient->conn;
	
	netconn_getaddr(conn,&(pClient->ip),&(pClient->port),0);              //获取远端IP地址和端口号
	NetPrintf("client %d ip %s port %d 已连接\r\n", pClient->no, ip_ntoa(&(pClient->ip)), pClient->port);   
  
	struct netbuf *recvbuf = NULL;
	uint8_t *dataPtr;
	uint16_t dataLen;

netconn_set_recvtimeout(conn, TCP_SERVER_RECV_TIMEOUT);
	
	// 构造通信管理的结构体
	// 用pRecvBuf来对应接收
	
	for( ; ; )
	{
		int offset = 0;
		if ((err = netconn_recv(conn, &recvbuf)) == ERR_OK)
		{
			// 
			pClient->lastBusyTime = osKernelGetTickCount();
			pClient->state = CLIENT_CONNECT_STATE_WORKING;
			
			netbuf_data(recvbuf, (void *)&dataPtr, &dataLen);
//			err= netconn_write(conn, dataPtr, dataLen, NETCONN_COPY); // test
			NetPrintf("client %d recv len %d\r\n", pClient->no, dataLen);
			offset = 0;
			while(dataLen)
			{
				if(dataLen <= CLIENT_REVC_BUF_LEN)
				{
					memcpy(pClient->pRecvBuf, dataPtr+offset, dataLen);
					offset += dataLen;
					pClient->readLen = dataLen;
				}
				else
				{
					memcpy(pClient->pRecvBuf, dataPtr+offset, CLIENT_REVC_BUF_LEN);
					offset += CLIENT_REVC_BUF_LEN;
					dataPtr += CLIENT_REVC_BUF_LEN;
					pClient->readLen = CLIENT_REVC_BUF_LEN;
				}
				dataLen -= pClient->readLen;
				pClient->readPtr = 0;
				// 协议解析
				CommProtocolHandle(&TcpCommManager[pClient->no-1]);
				
			}
			netbuf_delete(recvbuf);
			recvbuf = NULL;		
		}
		else if(err == ERR_CLSD || err == ERR_RST) // 关闭 或 异常关闭
		{
			break;
		}

}
	// conn 在 离开线程后释放
	// 结束线程
	osThreadExit();
}
服务器的接收线程大概这样的，在接收到数据，先解析数据（并返回命令）。