如何编写一个高并发的tcp server

服务器在调用listen和accept后，就会阻塞在accept函数上，accpet函数返回后循环调用accept函数等待客户的TCP连接。如果这时候又大量的用户并发发起connect连接，那么在listen有队列上限(最大可接受TCP的连接数)的情况下，有多少个connect会成功了。试验证明，当连接数远远高于listen的可连接数上限时，客户端的大部分TCP请求会被抛弃，只有当listen监听队列空闲或者放弃某个连接时，才可以接收新的连接，那么我们应该如何来避免这种情况出现？

分析：

（一）客户端

客户端运行初期完成所设定的一定量的socket创建和相应的处理线程的创建，然后使用条件变量来完成线程同步，直到最后一个线程创建完成，才向所有线程发出广播通知，让所有线程并发调用connect，连接成功则关闭连接，失败则返回，如下代码所示。

socket创建和线程创建：

int testCount=300 //并发用户数

/*

每个进程需要自己独立的栈空间，linux下默认栈大小是10M，在32位的机子上一个进程需要4G的内存空间，去掉自己的栈空间全局程序段空间，一般只有3G内存可以用，创建线程时就需要从这3G的空间中分配10M出来，所以最多可以分配300个线程。当然这里还可以使用多个进程，每个进程300个线程的方式来进一步扩大并发量。

*/

int sockfd[testCount]

pthread_t ntid[testCount]

bzero(&servaddr,sizeof(servaddr))

servaddr.sin_family=AF_INET

servaddr.sin_port=htons(SERVER_PORT)

inet_pton(AF_INET,argv[1],&servaddr.sin_addr)

int testCaseIndex=0

for(testCaseIndex=0testCaseIndex<testCounttestCaseIndex++)

{

sockfd[testCaseIndex]=socket(AF_INET,SOCK_STREAM,0)

//为每个并发客户端创建一个socket

if(sockfd[testCaseIndex]==-1)

{

printf("socket established error: %s\n",(char*)strerror(errno))

return -1

}

if( pthread_create(&ntid[testCaseIndex],NULL,handleFun,&sockfd[testCaseIndex])!=0)

{

printf("create thread error :%s\n",strerror(errno))

return -1

}

//为每个并发客户端创建一个线程来执行connect

}

printf("%d client has initiated\n",testCaseIndex)

并发客户端的线程实现：线程阻塞在条件变量上（只有条件满足了并且发起唤醒动作，线程才开始执行）。

int sockfd=*((int*)arg)

{

pthread_cond_wait(&cond,&mut)

//在条件变量上等待条件满足！

//阻塞返回后立即解锁，防止互斥量加锁带来的阻塞

pthread_mutex_unlock(&mut)

int conRes=0

conRes=connect(sockfd,(struct sockaddr *)&servaddr,sizeof(servaddr))

//线程执行connect连接，每个线程在接到唤醒信号后，才可以执行该语句，来模拟多个线程的并发调用。

if(conRes==-1)

{

printf("connect error: %s\n",strerror(errno))

return 0

}

}

当条件满足时，唤醒阻塞在条件变量上的线程：

while(1)

{

sleep(2)

pthread_cond_broadcast(&cond) //在所有线程创建完成后才进行唤醒。

分类: 电脑/网络 >>程序设计 >>其他编程语言

问题描述:

用VB写实现以下功能：

一台主机，4~8台子机，子机上都有一个相同的视频文件。

主机发送命令来使所有的子机同步播放这个视频，

主机具有控制所有子机同步播放，暂停，停止的功能。

大侠们帮帮忙，要多少分我都给，只要能实现。

暂时我没多少分```嫌分少说一声``我努力加。

解析:

VB我刚学我也想编个远程控制程序,这是资料>>>>>>

VB编写一个远程控制程序

一、所用控件

在程序中将使用Winsock控件。Winsock控件是一个ActiveX控件，使用TCP协议或UDP协

议连接到远程计算机上并与之交换数据。和定时器控件一样，Winsock控件在运行时是不可见的。Winsock的工作原理是：客户端向服务器端发出连接请求，服务器端则不停地监听客户端的请求，当两者的协议沟通时，客户端和服务器端之间就建立了连接，这时客户端和服务器端就可以实现双向数据传输。实际编程中，必须分别建立一个服务器端应用程序和一个客户端应用程序，两个应用程序中分别有自己的Winsock控件。首先设置Winsock控件使用的协议，这里我们使用TCP协议。现在，让我们开始用VB建立两个程序，一个是客户端程序myclient，另一个是服务器端程序myserver。

二、编写客户端程序

首先来建客户端程序myclient。在myclient程序中建立一个窗体，加载Winsock控件，称为tcpclient，表示使用的是TCP协议，再加入两个文本框(text1和text2)，用来输入服务器的IP地址和端口号，然后建立一个按钮(cd1)，用来建立连接，按下之后就可以对连接进行初始化了，代码如下：

private sub cd1_click()

tcpclient.romotehost=text1.text

tcpclient.romoteport=val(text2.text)'端口号，缺省为1001

tcpclient.connect '调用connect方法，与指定IP地址的计算机进行连接

cd1.enabled=false

end sub

连接之后就是如何处理所收到的数据的问题了。客户端和服务器端建立连接后，如果有任何一端接收到新的数据，就会触发该端winsock控件的dataarrival事件，在响应这个事件时，可以使用getdata方法获得发送来的数据。比如可以在tcpclient的dataarrival事件中编写代码如下：

private sub tcpclient_dataarrival(byval bytestotal as long)

dim x as string

tcpclient.getdata x '使用getdata获得发送来的数据

.......

End sub

后面的省略部分表示对接收到的数据进行的具体处理，读者可以根据实际情况编写。

三、编写服务器端程序

先建立一个窗体，加载Winsock控件，名称为tcpserver。另外在窗体上加入一个文本框text1用来显示客户机的IP地址和客户机发送过来的数据信息。

当客户端程序运行时，在客户端程序按下连接按钮后，客户端向服务器端程序请求连接，这时服务器端的connectionrequest事件被触发，所以服务器端程序要解决连接问题，可以使用connectionrequest事件完成此功能。代码如下：

'在窗体的load事件中对tcpserver控件进行初始化

private sub form_load()

tcpserver.localport=1001

tcpserver.listen '把服务器置于监听检测状态

end sub

'服务器端接收到客户端的连接请求，首先检查当前状态是否处于连接关闭状态

Private sub tcpclient_connectionrequest(Byval requestID as long)

If tcpserver.state<>sckclosed then '检查控件的state属性是否为关闭

Tcpserver.close '

Tcpserver.accept requestID '

End if

End sub

现在我们在服务器端程序tcpserver的dataarrival事件中添加以下代码，以便让服务器端程序可以接收客户机端的指令，并运行相应的程序。

四、测试远程控制程序

现在，你就可以将这两个程序分别运行于两台使用TCP/IP协议联网的机器了。在客户机端你按下连接按钮，再输入你要打开的文件例如:“c: mmand”,可以看到在服务器端立刻打开一个DOS窗口.

线程函数里使用循环可以实现不停的发每发一次sleep(5000)5秒然后再次循环。你创建两个线程 之后运行线程即可，线程的运行切换由 *** 作系统CPU自己调度，不用手动切换，记住现在的 *** 作系统都是多线程抢占式的。

如果Server端死掉，客户端会捕获到一个服务退出的异常，你可以根据异常来处理。

至于代码，百度下，很多。

希望能帮到你，感谢！

---