select模型的一个问题
2016-09-19 22:55
417 查看
select模型的一个简单程序,读套接口集合中包括监听套接口,但只有第一次connect到来时select返回,后来的connect到来select不返回。当时把代码中FD_SET(clientfd, &read) 代码注释都返回,不知是什么原因。源码如下:
#include <stdio.h>
#include <WinSock2.h>
#include <Windows.h>
#pragma comment(lib, "ws2_32.lib")
// select(), fd_set FD_CLR FD_SET FD_ISSET FD_ZERO
int main(int argc, char *argv[])
{
WORD ver = MAKEWORD(2, 2);
WSADATA data;
int nRet = WSAStartup(ver, &data);
if (0 != nRet)
{
return -1;
}
int nError = 0;
SOCKET fd = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
if (INVALID_SOCKET == fd)
{
nError = WSAGetLastError();
return -2;
}
sockaddr_in addr;
addr.sin_family = AF_INET;
addr.sin_addr.s_addr = inet_addr("192.168.1.103");
addr.sin_port = htons(10000);
nRet = bind(fd, (sockaddr *)&addr, sizeof(addr));
if (SOCKET_ERROR == nRet)
{
nError = WSAGetLastError();
return -2;
}
nRet = listen(fd, 5);
if (SOCKET_ERROR == nRet)
{
nError = WSAGetLastError();
return -2;
}
fd_set read;
FD_ZERO(&read);
FD_SET(fd, &read);
fd_set write;
FD_ZERO(&write);
fd_set except;
FD_ZERO(&except);
while (1)
{
//nRet = select(0, &read, NULL, &except, NULL);
nRet = select(0, &read, &write, &except, NULL);
printf("selet come on...!\n");
if (SOCKET_ERROR == nRet) //?
{
nError = WSAGetLastError();
return -2;
}
else if (0 == nRet)
{
printf("time out!\n");
continue;
}
for (int j = 0; j < write.fd_count; ++j)
{
if (FD_ISSET(write.fd_array[j], &write))
{
printf("enable write!\n");
}
}
for (int k = 0; k < except.fd_count; ++k)
{
if (FD_ISSET(except.fd_array[k], &except))
{
printf("enable exception!\n");
nError = WSAGetLastError();
}
}
for (int i = 0; i < read.fd_count; ++i)
{
if (FD_ISSET(read.fd_array[i], &read))
{
if (fd == read.fd_array[i])
{
sockaddr_in addr;
int nSize = sizeof(addr);
SOCKET clientfd = accept(fd, (sockaddr *)&addr, &nSize);
if (SOCKET_ERROR != clientfd)
{
FD_SET(clientfd, &read);
/*FD_SET(clientfd, &except);
FD_SET(clientfd, &write);*/
nRet = getsockname(fd, (sockaddr *)&addr, &nSize);
if (SOCKET_ERROR == nRet)
{
nError = WSAGetLastError();
continue;
}
}
}
else
{
char szRevBuff[4]={0}; //接收缓存区少,待接收的数据量大的情况
int nLen = sizeof(szRevBuff);
nRet = recv(read.fd_array[i], szRevBuff, nLen, 0);
if (SOCKET_ERROR == nRet)
{
nError = WSAGetLastError();
return -5;
}
else if (0 == nRet) //gracefully closed
{
closesocket(read.fd_array[i]);
}
else
{
printf("recv data: %s!\n", szRevBuff);
}
nRet = send(read.fd_array[i], szRevBuff, nRet, 0);
if (SOCKET_ERROR == nRet)
{
nError = WSAGetLastError();
printf("send data fail: %s!\n", szRevBuff);
}
}
}
}
}
getchar();
return 0;
};
#include <stdio.h>
#include <WinSock2.h>
#include <Windows.h>
#pragma comment(lib, "ws2_32.lib")
// select(), fd_set FD_CLR FD_SET FD_ISSET FD_ZERO
int main(int argc, char *argv[])
{
WORD ver = MAKEWORD(2, 2);
WSADATA data;
int nRet = WSAStartup(ver, &data);
if (0 != nRet)
{
return -1;
}
int nError = 0;
SOCKET fd = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
if (INVALID_SOCKET == fd)
{
nError = WSAGetLastError();
return -2;
}
sockaddr_in addr;
addr.sin_family = AF_INET;
addr.sin_addr.s_addr = inet_addr("192.168.1.103");
addr.sin_port = htons(10000);
nRet = bind(fd, (sockaddr *)&addr, sizeof(addr));
if (SOCKET_ERROR == nRet)
{
nError = WSAGetLastError();
return -2;
}
nRet = listen(fd, 5);
if (SOCKET_ERROR == nRet)
{
nError = WSAGetLastError();
return -2;
}
fd_set read;
FD_ZERO(&read);
FD_SET(fd, &read);
fd_set write;
FD_ZERO(&write);
fd_set except;
FD_ZERO(&except);
while (1)
{
//nRet = select(0, &read, NULL, &except, NULL);
nRet = select(0, &read, &write, &except, NULL);
printf("selet come on...!\n");
if (SOCKET_ERROR == nRet) //?
{
nError = WSAGetLastError();
return -2;
}
else if (0 == nRet)
{
printf("time out!\n");
continue;
}
for (int j = 0; j < write.fd_count; ++j)
{
if (FD_ISSET(write.fd_array[j], &write))
{
printf("enable write!\n");
}
}
for (int k = 0; k < except.fd_count; ++k)
{
if (FD_ISSET(except.fd_array[k], &except))
{
printf("enable exception!\n");
nError = WSAGetLastError();
}
}
for (int i = 0; i < read.fd_count; ++i)
{
if (FD_ISSET(read.fd_array[i], &read))
{
if (fd == read.fd_array[i])
{
sockaddr_in addr;
int nSize = sizeof(addr);
SOCKET clientfd = accept(fd, (sockaddr *)&addr, &nSize);
if (SOCKET_ERROR != clientfd)
{
FD_SET(clientfd, &read);
/*FD_SET(clientfd, &except);
FD_SET(clientfd, &write);*/
nRet = getsockname(fd, (sockaddr *)&addr, &nSize);
if (SOCKET_ERROR == nRet)
{
nError = WSAGetLastError();
continue;
}
}
}
else
{
char szRevBuff[4]={0}; //接收缓存区少,待接收的数据量大的情况
int nLen = sizeof(szRevBuff);
nRet = recv(read.fd_array[i], szRevBuff, nLen, 0);
if (SOCKET_ERROR == nRet)
{
nError = WSAGetLastError();
return -5;
}
else if (0 == nRet) //gracefully closed
{
closesocket(read.fd_array[i]);
}
else
{
printf("recv data: %s!\n", szRevBuff);
}
nRet = send(read.fd_array[i], szRevBuff, nRet, 0);
if (SOCKET_ERROR == nRet)
{
nError = WSAGetLastError();
printf("send data fail: %s!\n", szRevBuff);
}
}
}
}
}
getchar();
return 0;
};
相关文章推荐
- WinSock 下 select() 模型的一个问题
- WinSock 下 select() 模型的一个问题
- 一个很奇怪的问题 关于SelectByPoint 待解决
- 一个linux典型的select模型更新方法
- 一个基于线程池的WSAEventSelect模型服务器设计
- Select I/O模型来实现一个并发处理多个客户端的TCP服务器
- 【解决】Select网络模型问题——奇怪的发送接收问题
- 关于select对象在FireFox中的一个兼容性问题
- 一个基于线程池的WSAEventSelect模型服务器设计
- 一个linux典型的select模型更新方法
- 请教大家一个问题:.net3.5的实体数据模型如何插入和编辑数据
- 一个一对多问题的设计模型
- 一个linux典型的select模型更新方法
- PD中建CDM模型,一个Diagram中有两张表,字段不能重复的问题解决
- 使用SQL Server Business Intelligence Development Studio 2005设计报表模型时的一个容易被忽视的问题
- 基于矩阵的流程数学模型的一个小问题
- 一个linux典型的select模型更新方法
- 采用DOM模型时创建一个Select节点后,要删除option项的解决方法
- 使用Select I/O模型来实现一个并发处理多个客户端的TCP服务器
- 一个一对多问题的设计模型