想用select 模型实现TCP并发服务器，大家指点一上啊多谢了

想用select 模型实现TCP并发服务器，大家指点一下啊谢谢了
想用select 模型实现TCP并发服务器，大家能给我点思路吗？谢谢

------解决方案--------------------
详细请参考Unix 网络编程第一卷
上面讲select原理很清楚，还有许多并发模型
------解决方案--------------------
思路就是了解Select模型的的实质,和阻塞模型的区别.然后找点例子看看就OK了.网上这种例子要铺出来了.

楼主的问题还是过于笼统了
------解决方案--------------------

C/C++ code

// select mode  
 #define SELECT_MODE_READY   0x001 
 #define SELECT_MODE_WRITE	0x002 

 // select return codes  
 #define SELECT_STATE_READY     0 
 #define SELECT_STATE_ERROR     1 
 #define SELECT_STATE_ABORTED     2 
 #define SELECT_STATE_TIMEOUT     3 

 #ifdef WIN32 
 	#include  <winsock2.h> 
 	#pragma comment(lib, "ws2_32.lib") 
 	#pragma warning(disable:4786) 
 	#pragma warning(disable:4996) 
 	#define SocketLen int 
 #else 
 	//network 
 	#include  <sys/socket.h> 
 	#include  <netinet/in.h> 
 	#include  <arpa/inet.h>	 
 	#include  <netinet/tcp.h> 
 	#include  <netdb.h> 
 #endif 
 int CMySocket::BlockReceive(SOCKET sock, LPCSTR pBuffer, int readSize, int nTimeOut) 
 { 
 	int selectState; 
 	int recvSize; 

 	selectState = Select(sock, SELECT_MODE_READY, nTimeOut); 
 	if (SELECT_STATE_TIMEOUT == selectState) 
 		return 0; 

 	if (SELECT_STATE_READY == selectState) 
 	{ 
 		recvSize = recv(sock, (char*)pBuffer, readSize, 0); 
 		if (recvSize  <= 0) 
 			return -1; 
 		return recvSize; 
 	} 
 	return -1; 
 } 
 int CMySocket::BlockSend(SOCKET sock, LPCSTR pBuffer, int writeSize, int nTimeOut) 
 { 
 	int selectState = 0; 
 	int sendSize = 0; 

 	selectState = Select(sock, SELECT_MODE_WRITE, nTimeOut); 
 	if (selectState == SELECT_STATE_TIMEOUT) 
 		return 0; 

 	if (selectState == SELECT_STATE_READY) 
 	{ 
 		sendSize = send(sock, (char*)pBuffer, writeSize, 0); 
 		if (sendSize  <= 0) 
 			return -1; 
 		return sendSize; 
 	}	 

 	return -1; 
 }

------解决方案--------------------
select的网络吞吐量和性能一般,优点是可以跨平台.像我上面的代码,就是平台兼容的.设计TCP服务器,如果连接量和吞吐量不大,就以用select模型,还需要一个线程用来ACCEPT连接,然后每接受了一个连接,再开一线程接收数据,循环调用上面的BlockReceive函数.
------解决方案--------------------
看下这个资源 http://download.csdn.net/source/2742482
------解决方案--------------------
用socket IOCP完成端口模型

// testiocp.cpp : Defines the entry point for the console application.
//

#include "StdAfx.h"
#include <stdio.h>
#include <winsock2.h>
#pragma comment(lib, "ws2_32.lib")

typedef struct _OVERLAPPEDPLUS
{
OVERLAPPED ol;
SOCKET socket;
int nOpCode;
WSABUF wsaBuf;
DWORD dwFlags;
DWORD dwBytes;
char pBuf[1000];
}OVERLAPPEDPLUS, *POVERLAPPEDPLUS;

DWORD WINAPI ServerWorkerThread(LPVOID CompletionPortID);

void main()
{
WORD wVersionRequested;
WSADATA wsaData;
int err;
wVersionRequested = MAKEWORD( 2, 2 );
err = WSAStartup( wVersionRequested, &wsaData );
if ( err != 0 )
{
printf("WSAStartup errors!\n");
return;
}
if ( LOBYTE( wsaData.wVersion ) != 2 ||
HIBYTE( wsaData.wVersion ) != 2 )
{
WSACleanup( );
return;
}

SOCKET sockSvr = WSASocket(AF_INET, SOCK_STREAM, 0, 0, 0, WSA_FLAG_OVERLAPPED);
if(INVALID_SOCKET == sockSvr)

想用select 模型实现TCP并发服务器，大家指点一上啊 多谢了

相关推荐

想用select 模型实现TCP并发服务器，大家指点一上啊多谢了