LWIP中多连接下内存释放的问题请教

发布于 2014-04-23 22:44:20 浏览：3086 订阅该版

大家好，下面有一些问题请教一下大家。
     当前板子配置为TCP服务器，等待多个客户端的连接。由于客户端那边的网络设置的问题，客户端连接到服务器之后，自行断开时候是没有通知信息到服务器，客户端每次控制服务器的时候都是需要重新发起连接的(我也不知道那边的网络为什么要这样设计，请勿吐槽了，嘿嘿)。
    当前的解决方案是，端口1成功连接服务器并创建对应的线程，然后端口2连接成功连接服务器之后先删除端口1的线程，然后再创建端口2的线程。。。。。思路大概就是这样
   现在出现的问题就是，删除前一个线程的时候，并关闭全部的连接之后，发现内存释放的很慢，有时候要1分钟。比如服务器没有任何客户端连接的时候，内存使用时3612，端口1连接，端口2连接并删除端口1的线程，内存是5556，最后关闭端口2的连接，变为3844，在过30秒或者更长才变为3640。此后，更加严重的问题就是它回不到3612，而且每次后面的循环连接之后，不见的28(28=3640-3812)字节会累积上升占用。
    请问大家，这是为什么，是不是线程的创建于调度出现了问题了？？说一些意见！谢谢了(流水账，请多多包涵！ [s:175]  [s:175] )

```if (listen(sock, 5) == -1)
    {
        rt_kprintf("Listen error
");

/* release recv buffer */
        rt_free(recv_data);
        return;
    }

//	tcp_recv_thread_last = tcp_recv_thread;
	mtcp_parm.recv_data = recv_data;
	mtcp_parm.connected = -1;
    rt_kprintf("
TCPServer Waiting for client on port 1201...
");
    while (stop != RT_TRUE)
    {
        sin_size = sizeof(struct sockaddr_in);

/* 接受一个客户端连接socket请求，调用该函数是阻塞式的，也就是说调用该函数之后是一直处于等待状态，该线程会被suspend的*/
        connected = accept(sock, (struct sockaddr *)&client_addr, &sin_size);
        /* 返回连接成功的socket */

/*接收放回的client_addr指向客户端的地址信息*/
        rt_kprintf("I got a connection from (%s , %d)
",
                   inet_ntoa(client_addr.sin_addr), ntohs(client_addr.sin_port));//输出客户端的ip地址和发出数据的端口
		if (mtcp_parm.connected !=-1)
		{
			lwip_close(mtcp_parm.connected);			//关闭前一个客户端的连接
			rt_kprintf("Close mtcp_parm.connected %d
", mtcp_parm.connected);
//			rt_free(mtcp_parm.recv_data);
			rt_thread_delete(tcp_recv_thread);        //删除前一个客户端的连接线程，从而释放内存
			rt_kprintf("Delete tcp_recv_thread.
");
		}
		mtcp_parm.connected = connected; //保存前一个的客户端连接句柄，用于删除删前一个的客户端的连接
		tcp_recv_thread = rt_thread_create("tcp_recv",
                                   mtcp_recv, &mtcp_parm,			/*创建后一个客户端连接线程*/
                                   1024, 13, 20);
		if (tcp_recv_thread != RT_NULL)
		{ 
			rt_thread_startup(tcp_recv_thread);
			rt_kprintf("tcp_revc_thread OK %d !
", connected);
		}
		else
		{
			rt_kprintf("tcp_revc_thread fail
");
			lwip_close(connected);
			rt_kprintf("Close connected %d.
", connected);
		}
    }
    /*如果关闭服务器之后，就关闭这个socket*/
    lwip_close(sock);
    /*释放刚才申请的内存*/
    rt_free(recv_data);
	
    return ;
}
/**
* TCP SERVER的 客户端连接
**/
void mtcp_recv(void *parameter)
{
	char *recv_data;
	int connected, bytes_received;
	struct mtcp_parm *mtcp_parm;

mtcp_parm = (struct mtcp_parm *)parameter;
	connected = mtcp_parm->connected;

recv_data = mtcp_parm->recv_data;
	send(connected, WELCOME_STR, 100, 0);	//发送 欢迎.....
    while (1)
    {
       /* 从连接到的socket中读取数据，然后将数据储存到缓冲区recv_data中*/
        bytes_received = recv(connected, recv_data, 512, 0);/*bytes_received是接收数据的大小*/
		if (bytes_received <= 0)
        {
            /* 如果收到的数据小于0，那么证明接收出错了，关闭这个连接到的socket*/
            rt_kprintf("TCP recevied 0 bytes.
");
			lwip_close(connected);
			rt_kprintf("Close connected %d.
", connected);
			mtcp_parm->connected = -1;
            break;
        }
        else
        {
            /*其他数据，打印出来*/  
			aningcomp(recv_data, connected, bytes_received);
        }
    }
	rt_kprintf("mtcp_recv thread %d out
", connected);
}```
![51.jpg](https://oss-club.rt-thread.org/uploads/5057_0d2f487def4923725efe84bdda4b1a26.jpg)

![50.jpg](https://oss-club.rt-thread.org/uploads/5057_00abd84ac8416c5316a14c67dae5cdbd.jpg)