Rtt中TCP服务器怎么实现多个客户端的链接处理？

发布于 2013-07-17 15:26:22 浏览：4985 订阅该版

11 个回答

bernard 2013-07-17

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

celticzy 2013-07-17

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

>有两种方法：
>1. 创建出一个新的任务来处理新的连接；
>2. 使用select。

---

第一种方法的代码，我之前写了一个，还请高手帮忙看看有什么漏洞没有。（PS，select是啥？）

```

ALIGN(RT_ALIGN_SIZE)
static rt_uint8_t tcp_server_stack[ 1024 ];
static struct rt_thread tcp_server_thread;

//echo 服务线程
static void server_echo(void* para)    
{
    struct netbuf     *buf;
    rt_uint8_t        *rec_data;
    rt_uint16_t       rec_data_len;

while(1)
    {
        netconn_recv(para,&buf);
        
        if(buf != NULL)
        {
            netbuf_data(buf,(void**)&rec_data,&rec_data_len);
            netconn_write(para,rec_data,rec_data_len,NETCONN_COPY);
            netbuf_delete(buf);                
        }
        else
        {
            //关闭连接，回收资源
            rt_kprintf("sever close!
");
            netconn_delete(para);
            break;
        }
    }
}

//监听56793端口线程，有新的连接进来则转至echo线程处理
static void tcp_server_thread_entry(void* parameter)  
{
    const rt_uint8_t welcome[] = "hello, world!
";
    struct netconn    *receive_conn, *new_conn; 
    rt_thread_t       tid = RT_NULL;

new_conn = netconn_new(NETCONN_TCP);
    netconn_bind(new_conn,NULL,56793);
    netconn_listen(new_conn);

while(1)
    {
        netconn_accept(new_conn,&receive_conn);
        
        //向新的连接发送欢迎信息
        netconn_write(receive_conn,welcome,sizeof(welcome),NETCONN_COPY);

rt_kprintf("sever open!
");

tid = rt_thread_create("connect",server_echo,(void*)receive_conn,1024,20,5);
        if(tid != RT_NULL)
        {
            rt_thread_startup(tid);
        }
        else
        {
            rt_kprintf("creat echo server failed.
");
            break;
        }

}
    netconn_delete(new_conn);
}

//对外的初始化接口
int tcp_server_thread_init(void)
{

rt_err_t result;
    result = rt_thread_init(&tcp_server_thread,
        "tcp_ser",
        tcp_server_thread_entry, RT_NULL,
        (rt_uint8_t*)&tcp_server_stack[0], sizeof(tcp_server_stack), 20, 5);
    if (result == RT_EOK)
    {
        rt_thread_startup(&tcp_server_thread);
    }
    return 0;
}

```

实测结果如下：
[attach]1914[/attach]

另外，打开3个连接后与关闭它们后，一些系统状态如下：

```

sever open!
sever open!
sever open!

finsh>>list_thre
--function:
list_thread      -- list thread
finsh>>list_thread()
 thread  pri  status      sp     stack size max used   left tick  error
-------- ---- ------- ---------- ---------- ---------- ---------- ---
connect  0x14 suspend 0x000001a8 0x00000400 0x000001b8 0x00000005 000
connect  0x14 suspend 0x000001a8 0x00000400 0x000001b8 0x00000005 000
connect  0x14 suspend 0x000001a8 0x00000400 0x000001b8 0x00000005 000
telnet   0x19 suspend 0x00000168 0x00000800 0x00000190 0x00000001 000
tcp_ser  0x14 suspend 0x00000180 0x00000400 0x000001b0 0x00000002 000
tcpip    0x0c suspend 0x00000160 0x00000400 0x00000270 0x0000000b 000
etx      0x0f suspend 0x0000011c 0x00000200 0x0000011c 0x00000010 000
erx      0x0f suspend 0x0000011c 0x00000200 0x0000018c 0x0000000d 000
tshell   0x14 ready   0x00000240 0x00000800 0x00000240 0x0000000a -04
phy      0x1e suspend 0x00000118 0x00000200 0x00000150 0x00000001 000
tidle    0x1f ready   0x000000e0 0x00000400 0x000000e0 0x00000008 000
timer    0x04 suspend 0x000000e0 0x00000200 0x000000e0 0x00000009 000
        0, 0x00000000
finsh>>list_mem()
total memory: 2097112
used memory : 15224
maximum allocated memory: 15520
        0, 0x00000000
finsh>>list_tcps()
Active PCB states:
#0 10.30.28.35:56793 <==> 10.30.28.100:56961 snd_nxt 0x000019CB rcv_nxt 0x97571EFB state: ESTABLISHED
#1 10.30.28.35:56793 <==> 10.30.28.100:56960 snd_nxt 0x000019A3 rcv_nxt 0x59B407E6 state: ESTABLISHED
#2 10.30.28.35:56793 <==> 10.30.28.100:56958 snd_nxt 0x00001986 rcv_nxt 0xF4FC9CAA state: ESTABLISHED
Listen PCB states:
#0 local port 56793 state: LISTEN
#1 local port 23 state: LISTEN
TIME-WAIT PCB states:
        0, 0x00000000
finsh>>sever close!
sever close!
sever close!

finsh>>list_thread()
 thread  pri  status      sp     stack size max used   left tick  error
-------- ---- ------- ---------- ---------- ---------- ---------- ---
telnet   0x19 suspend 0x00000168 0x00000800 0x00000190 0x00000001 000
tcp_ser  0x14 suspend 0x00000180 0x00000400 0x000001b0 0x00000002 000
tcpip    0x0c suspend 0x00000160 0x00000400 0x00000270 0x00000006 000
etx      0x0f suspend 0x0000011c 0x00000200 0x0000011c 0x00000010 000
erx      0x0f suspend 0x0000011c 0x00000200 0x0000018c 0x0000000c 000
tshell   0x14 ready   0x00000110 0x00000800 0x00000240 0x00000009 -04
phy      0x1e suspend 0x00000118 0x00000200 0x00000150 0x00000001 000
tidle    0x1f ready   0x000000e0 0x00000400 0x000000e0 0x0000000a 000
timer    0x04 suspend 0x000000e0 0x00000200 0x000000e0 0x00000009 000
        0, 0x00000000
finsh>>list_mem()
total memory: 2097112
used memory : 10264
maximum allocated memory: 15576
        0, 0x00000000

finsh>>
finsh>>list_tcps()
Active PCB states:
Listen PCB states:
#0 local port 56793 state: LISTEN
#1 local port 23 state: LISTEN
TIME-WAIT PCB states:
        0, 0x00000000
finsh>>

```

nongxiaoming 2013-07-17

rt-thread大师兄

celticzy 2013-07-17

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

bernard 2013-07-17

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

lyq262 2013-07-18

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

首先感谢楼上的各位回复。
正题：
用第一种建立线程的方式做了实验，可以处理多客户端的链接。
程序代码在原来的tcpserv()中

```
connected = accept(sock, (struct sockaddr *)&client_addr, &sin_size);
```

替换成下面代码，并注释掉while(1)的内容

```
 
connected[index] = accept(sock, (struct sockaddr *)&client_addr, &sin_size);
if(connected[index]!=-1)
	tid = rt_thread_create("connect",server_echo,(void*)&connected[index++],1024,20,5);

```

```
void server_echo(int* parameter)
{  
int str=0,bytes_received;
	char *recv_data1;
	recv_data1 = rt_malloc(1024);
	 while (1)
    {      
        /* 浠庨偖绠变腑鏀跺彇閭?欢 */
		       
            rt_kprintf("socket:%d
",*parameter);
            send(*parameter, send_data, strlen(send_data), 0);
			bytes_received = recv(*parameter, recv_data1, 1024, 0);
		   if (bytes_received <= 0)
            {
                /* 接收失败，关闭这个connected socket */
                lwip_close(*parameter);
				rt_free(recv_data1);
                break;
            }
			recv_data1[bytes_received] = '�';
            /* 寤舵椂10涓狾S Tick */
			 rt_kprintf("RECIEVED 123 = %s 
" , recv_data1);	       
    }
}
```

新状况出现了：当第六个TCP链接来时出现以下状况（串口的输出信息）
TCPServer Waiting for client on port 5000...
socket:1
socket:2
socket:3
socket:4
socket:5
(thread->stat == RT_THREAD_INIT) assert failed at rt_thread_startup:198。
在代码中不加if的话输出信息：socket:-1。
Active PCB states:
192.168.1.141:5000 <==> 192.168.1.141:53672 snd_nxt 6656 rcv_nxt -1379197972 sta
te: ESTABLISHED
192.168.1.141:5000 <==> 192.168.1.141:53669 snd_nxt 6605 rcv_nxt -942710139 stat
e: ESTABLISHED
192.168.1.141:5000 <==> 192.168.1.141:53668 snd_nxt 6561 rcv_nxt -289775766 stat
e: ESTABLISHED
192.168.1.141:5000 <==> 192.168.1.141:53667 snd_nxt 6550 rcv_nxt 824871278 state
: ESTABLISHED
192.168.1.141:5000 <==> 192.168.1.141:52262 snd_nxt 6545 rcv_nxt -1175041001 sta
te: ESTABLISHED
Listen PCB states:
local port 5000 state: LISTEN
TIME-WAIT PCB states:
        0, 0x00000000
finsh>>list_mem()
total memory: 44336
used memory : 19160
maximum allocated memory: 19856
        32, 0x00000020
finsh>>
配置信息：在原工程的配置上只修改了
#define RT_LWIP_TCP_PCB_NUM	20（TCP链接控制参数？ 但是没效果，我改成3，也能链接5个TCP）
问题：1 该情况出现的原因？和解决办法？(系统内存够用，难道是线程数量受限？线程空间不够？)
2.TCP链接数的控制。有配置参数？
3.192.168.1.141:5000 <==> 192.168.1.141:52262 （IP一样？？）