18,358
社区成员
发帖
与我相关
我的任务
分享socket的select模式// if(fdSocket.fd_array[i] == sListen) 是什么与谁相等
USHORT nPort = 4567; // 此服务器监听的端口号
// 创建监听套节字
SOCKET sListen = ::socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
sockaddr_in sin;
sin.sin_family = AF_INET;
sin.sin_port = htons(nPort);
sin.sin_addr.S_un.S_addr = INADDR_ANY;
// 绑定套节字到本地机器
if(::bind(sListen, (sockaddr*)&sin, sizeof(sin)) == SOCKET_ERROR)
{
printf(" Failed bind() \n");
return -1;
}
// 进入监听模式
::listen(sListen, 5);
2.
// select模型处理过程
// 1）初始化一个套节字集合fdSocket，添加监听套节字句柄到这个集合
fd_set fdSocket; // 所有可用套节字集合
FD_ZERO(&fdSocket);
FD_SET(sListen, &fdSocket);
3.
while(TRUE)
{
// 2）将fdSocket集合的一个拷贝fdRead传递给select函数，
// 当有事件发生时，select函数移除fdRead集合中没有未决I/O操作的套节字句柄，然后返回。
fd_set fdRead = fdSocket;
int nRet = ::select(0, &fdRead, NULL, NULL, NULL);
if(nRet > 0)
{
// 3）通过将原来fdSocket集合与select处理过的fdRead集合比较，
// 确定都有哪些套节字有未决I/O，并进一步处理这些I/O。
for(int i=0; i<(int)fdSocket.fd_count; i++)
{
if(FD_ISSET(fdSocket.fd_array[i], &fdRead))
{
if(fdSocket.fd_array[i] == sListen) // （1）监听套节字接收到新连接
{
if(fdSocket.fd_count < FD_SETSIZE)
{
sockaddr_in addrRemote;
int nAddrLen = sizeof(addrRemote);
SOCKET sNew = ::accept(sListen, (SOCKADDR*)&addrRemote, &nAddrLen);
FD_SET(sNew, &fdSocket);
printf("接收到连接（%s）\n", ::inet_ntoa(addrRemote.sin_addr));
}
else
{
printf(" Too much connections! \n");
continue;
}
}
else
{
char szText[256];
int nRecv = ::recv(fdSocket.fd_array[i], szText, strlen(szText), 0);
if(nRecv > 0) // （2）可读
{
szText[nRecv] = '\0';
printf("接收到数据：%s \n", szText);
}
else // （3）连接关闭、重启或者中断
{
::closesocket(fdSocket.fd_array[i]);
printf("关闭\n");
FD_CLR(fdSocket.fd_array[i], &fdSocket);
}
}
}
}
}
else
{
printf(" Failed select() \n");
break;
}
}
...全文
请发表友善的回复…
发表回复
smwhotjay 2013-08-02
- 打赏
- 举报
你道行不够,所以看不懂. 看每个代码 知道意思. 然后调试.
mirroatl262 2013-08-02
- 打赏
- 举报
for(int i=0; i<(int)fdSocket.fd_count; i++)
{
if(FD_ISSET(fdSocket.fd_array[i], &fdRead))
{
//fd_array[i] //数据元素原本存着什么 当等于slisten之后，元素又变成啥了???
if(fdSocket.fd_array[i] == sListen) //（1）监听套节字接收到新连接
{
oyljerry 2013-08-02
- 打赏
- 举报
socket都有一个值，用这个值来判断相等
mirroatl187 2013-08-02
- 打赏
- 举报
连上的socket套接字 最先链接的在fdSocket.fd_array[i]数组的 最后把??????
mirroatl187 2013-08-02
- 打赏
- 举报
函数socket编程中的listen()函数底层用的定时器实现的?????
mirroatl187 2013-08-02
- 打赏
- 举报
函数socket编程中的listen()函数底层用的定时器实现的?????
Eleven 2013-08-02
- 打赏
- 举报
The fd_set structure is used by various Windows Sockets functions and service providers, such as the select function, to place sockets into a "set" for various purposes, such as testing a given socket for readability using the readfds parameter of the select function.
mirroatl187 2013-08-02
- 打赏
- 举报
FD_SET(sListen,&fdSocket); //这里添加之后 ,这段代码就执行一次呀；之后就执行服务端的while循环 ，
//for(int i=0;i<(int)fdSocket.fd_count;i++) //fd_count怎么就循环一次之后，就自动从1变成2了呢?????
while (true)
{
//assign the fdSocket to fdRead to select
fd_set fdRead = fdSocket;
int nRet = select(NULL,&fdRead,NULL,NULL,NULL);
if (nRet <= 0)
{
printf("select failed\n");
break;
}
for(int i=0;i<(int)fdSocket.fd_count;i++) //可是循环在while
{
//check whether the socket is set
if(FD_ISSET(fdSocket.fd_array[i],&fdRead))
{
//New connect come
if(fdSocket.fd_array[i] == sListen)
{
sockaddr_in addrRemote;
int nAddrLen=sizeof(addrRemote);
SOCKET sNew=::accept(sListen,(sockaddr*)&addrRemote,&nAddrLen);
FD_SET(sNew,&fdSocket);//Put it to fdSocket sets
printf("Client %s connected\n",inet_ntoa(addrRemote.sin_addr));
}
else
{
char buffer[1024];
memset(buffer,0,1024);
int nRecev = recv(fdSocket.fd_array[i],buffer,
1024,0);
if (nRecev > 0)
{
printf("Received Client Msg:%s\n",buffer);
//echo back
::send(fdSocket.fd_array[i],buffer,
strlen(buffer),0);
}
else
{
//Close the socket and clear from the sets
closesocket(fdSocket.fd_array[i]);
FD_CLR(fdSocket.fd_array[i],&fdSocket);
}
}
}
}
}
oyljerry 2013-08-02
- 打赏
- 举报
FD_SET(sNew, &fdSocket); 增加了
mirroatl262 2013-08-02
- 打赏
- 举报
for(int i=0;i<(int)fdSocket.fd_count;i++)
{
//为什么 fdSocket.fd_count 循环一次 就自动从1 变成 2 了呢???
}
mirroatl262 2013-08-02
- 打赏
- 举报
for(int i=0;i<(int)fdSocket.fd_count;i++)
{
//为什么 fdSocket.fd_count 循环一次 就自动从1 变成 2 了呢???
}
ShengFei01 2013-08-01
- 打赏
- 举报
就是你侦听的socket，对方connect到你时，在readfds 中返回，这也有socket select的例子,你找个客户端试试就知道了：
http://download.csdn.net/detail/geoff08zhang/4571358
