Select模型原理

利用select函数,推断套接字上是否存在数据,或者是否能向一个套接字写入数据。目的是防止应用程序在套接字处于锁定模式时,调用recv(或send)从没有数据的套接字上接收数据,被迫进入堵塞状态。

select參数和返回值意义例如以下:

int select (

IN int nfds,                           //0,无意义

IN OUT fd_set* readfds,      //检查可读性

IN OUT fd_set* writefds,     //检查可写性

IN OUT fd_set* exceptfds,  //例外数据

IN const struct timeval* timeout);    //函数的返回时间

struct  timeval {

long    tv_sec;        //秒

long    tv_usec;     //毫秒

};

select返回fd_set中可用的套接字个数。

fd_set是一个SOCKET队列,下面宏能够对该队列进行操作:

FD_CLR( s, *set) 从队列set删除句柄s;

FD_ISSET( s, *set) 检查句柄s是否存在与队列set中;

FD_SET( s, *set )把句柄s加入到队列set中;

FD_ZERO( *set ) 把set队列初始化成空队列.

Select工作流程

1:用FD_ZERO宏来初始化我们感兴趣的fd_set。

也就是select函数的第二三四个參数。

2:用FD_SET宏来将套接字句柄分配给对应的fd_set。

假设想要检查一个套接字是否有数据须要接收,能够用FD_SET宏把套接接字句柄加入可读性检查队列中

3:调用select函数。

假设该套接字没有数据须要接收,select函数会把该套接字从可读性检查队列中删除掉,

4:用FD_ISSET对套接字句柄进行检查。

假设我们所关注的那个套接字句柄仍然在開始分配的那个fd_set里,那么说明立即能够进行对应的IO操 作。比方一个分配给select第一个參数的套接字句柄在select返回后仍然在select第一个參数的fd_set里,那么说明当前数据已经来了, 立即能够读取成功而不会被堵塞。

#include <winsock2.h>
#include <stdio.h>   

#define PORT  5150   

#define MSGSIZE  1024   

#pragma comment(lib, "ws2_32.lib")   

int g_iTotalConn1 = 0;
int g_iTotalConn2 = 0;   

SOCKET g_CliSocketArr1[FD_SETSIZE];
SOCKET g_CliSocketArr2[FD_SETSIZE];  

DWORD WINAPI WorkerThread1(LPVOID lpParam);
int CALLBACK ConditionFunc1(LPWSABUF lpCallerId,LPWSABUF lpCallerData, LPQOS lpSQOS,LPQOS lpGQOS,LPWSABUF lpCalleeId, LPWSABUF lpCalleeData,GROUP FAR * g,DWORD dwCallbackData);

DWORD WINAPI WorkerThread2(LPVOID lpParam);
int CALLBACK ConditionFunc2(LPWSABUF lpCallerId,LPWSABUF lpCallerData, LPQOS lpSQOS,LPQOS lpGQOS,LPWSABUF lpCalleeId, LPWSABUF lpCalleeData,GROUP FAR * g,DWORD dwCallbackData);

int main(int argc, char* argv[])
{
 WSADATA wsaData;
 SOCKET sListen, sClient;
 SOCKADDR_IN local, client;
 int iAddrSize = sizeof(SOCKADDR_IN);
 DWORD dwThreadId;
 // Initialize windows socket library
 WSAStartup(0x0202, &wsaData);
 // Create listening socket
 sListen = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
 // Bind   

 local.sin_family = AF_INET;
 local.sin_addr.S_un.S_addr = htonl(INADDR_ANY);
 local.sin_port = htons(PORT);
 bind(sListen, (sockaddr*)&local, sizeof(SOCKADDR_IN));   

 // Listen   

 listen(sListen, 3);   

 // Create worker thread   

 CreateThread(NULL, 0, WorkerThread1, NULL, 0, &dwThreadId);
// CreateThread(NULL, 0, WorkerThread2, NULL, 0, &dwThreadId);  

 while (TRUE)
 {
  sClient = WSAAccept(sListen, (sockaddr*)&client, &iAddrSize, ConditionFunc1, 0);
  printf("1:Accepted client:%s:%d:%d\n", inet_ntoa(client.sin_addr), ntohs(client.sin_port), g_iTotalConn1);
  g_CliSocketArr1[g_iTotalConn1++] = sClient;
/*
  sClient = WSAAccept(sListen, (sockaddr*)&client, &iAddrSize, ConditionFunc2, 0);
  printf("2:Accepted client:%s:%d:%d\n", inet_ntoa(client.sin_addr), ntohs(client.sin_port), g_iTotalConn2);
  g_CliSocketArr2[g_iTotalConn2++] = sClient;   */

 }
 return 0;
}   

DWORD WINAPI WorkerThread1(LPVOID lpParam)
{
 int i;
 fd_set fdread;
 int ret;
 struct timeval tv = {1, 0};
 char szMessage[MSGSIZE];
 while (TRUE)
 {
  FD_ZERO(&fdread);   //1清空队列
  for (i = 0; i < g_iTotalConn1; i++)
  {
   FD_SET(g_CliSocketArr1[i], &fdread);   //2将要检查的套接口增加队列
  }   

  // We only care read event
  ret = select(0, &fdread, NULL, NULL, &tv);   //3查询满足要求的套接字,不满足要求,出队
  if (ret == 0)
  {
   // Time expired
   continue;
  }   

  for (i = 0; i < g_iTotalConn1; i++)
  {
   if (FD_ISSET(g_CliSocketArr1[i], &fdread))    //4.是否依旧在队列
   {
    // A read event happened on g_CliSocketArr   

    ret = recv(g_CliSocketArr1[i], szMessage, MSGSIZE, 0);
    if (ret == 0 || (ret == SOCKET_ERROR && WSAGetLastError() == WSAECONNRESET))
    {
    // Client socket closed
     printf("1:Client socket %d closed.\n", g_CliSocketArr1[i]);
     closesocket(g_CliSocketArr1[i]);
     if (i < g_iTotalConn1-1)
     {
      g_CliSocketArr1[i--] = g_CliSocketArr1[--g_iTotalConn1];
     }
    }
    else
    {
     // We reveived a message from client
     szMessage[ret] = '\0';
     send(g_CliSocketArr1[i], szMessage, strlen(szMessage), 0);
    }
   }
  }
 }
} 

int CALLBACK ConditionFunc1(LPWSABUF lpCallerId,LPWSABUF lpCallerData, LPQOS lpSQOS,LPQOS lpGQOS,LPWSABUF lpCalleeId, LPWSABUF lpCalleeData,GROUP FAR * g,DWORD dwCallbackData)
{
 if (g_iTotalConn1 < FD_SETSIZE)
  return CF_ACCEPT;
 else
  return CF_REJECT;
}

DWORD WINAPI WorkerThread2(LPVOID lpParam)
{
 int i;
 fd_set fdread;
 int ret;
 struct timeval tv = {1, 0};
 char szMessage[MSGSIZE];
 while (TRUE)
 {
  FD_ZERO(&fdread);   //1清空队列
  for (i = 0; i < g_iTotalConn2; i++)
  {
   FD_SET(g_CliSocketArr2[i], &fdread);   //2将要检查的套接口增加队列
  }   

  // We only care read event
  ret = select(0, &fdread, NULL, NULL, &tv);   //3查询满足要求的套接字,不满足要求,出队
  if (ret == 0)
  {
   // Time expired
   continue;
  }   

  for (i = 0; i < g_iTotalConn2; i++)
  {
   if (FD_ISSET(g_CliSocketArr2[i], &fdread))    //4.是否依旧在队列
   {
    // A read event happened on g_CliSocketArr   

    ret = recv(g_CliSocketArr2[i], szMessage, MSGSIZE, 0);
    if (ret == 0 || (ret == SOCKET_ERROR && WSAGetLastError() == WSAECONNRESET))
    {
     // Client socket closed
     printf("2:Client socket %d closed.\n", g_CliSocketArr1[i]);
     closesocket(g_CliSocketArr2[i]);
     if (i < g_iTotalConn2-1)
     {
      g_CliSocketArr2[i--] = g_CliSocketArr2[--g_iTotalConn2];
     }
    }
    else
    {
     // We reveived a message from client
     szMessage[ret] = '\0';
     send(g_CliSocketArr2[i], szMessage, strlen(szMessage), 0);
    }
   }
  }
 }
} 

int CALLBACK ConditionFunc2(LPWSABUF lpCallerId,LPWSABUF lpCallerData, LPQOS lpSQOS,LPQOS lpGQOS,LPWSABUF lpCalleeId, LPWSABUF lpCalleeData,GROUP FAR * g,DWORD dwCallbackData)
{
 if (g_iTotalConn2 < FD_SETSIZE)
  return CF_ACCEPT;
 else
  return CF_REJECT;
}

server的几个主要动作例如以下:

1.创建监听套接字,绑定,监听;

2.创建工作者线程;

3.创建一个套接字数组,用来存放当前全部活动的client套接字,每accept一个连接就更新一次数组;

4.接受client的连接。

这里有一点须要注意的,就是我没有又一次定义FD_SETSIZE宏,所以server最多支持的并发连接数为64。并且,这里决不能无条件的accept,server应该依据当前的连接数来决定是否接受来自某个client的连接。

工作者线程里面是一个死循环,一次循环完毕的动作是:

1.将当前全部的client套接字增加到读集fdread中;

2.调用select函数;

3.查看某个套接字是否仍然处于读集中,假设是,则接收数据。假设接收的数据长度为0,或者发生WSAECONNRESET错误,则表示client套接字主动关闭,这时须要将server中相应的套接字所绑定的资源释放掉,然后调整我们的套接字数组(将数组中最后一个套接字挪到当前的位置上)

除了须要有条件接受client的连接外,还须要在连接数为0的情形下做特殊处理,由于假设读集中没有不论什么套接字,select函数会立马返回,这将导致工作者线程成为一个毫无停顿的死循环,CPU的占用率立即达到100%。

关系到套接字列表的操作都须要使用循环,在轮询的时候,须要遍历一次,再新的一轮開始时,将列表增加队列又须要遍历一次.也就是说,Select在工作一次时,须要至少遍历2次列表,这是它效率较低的原因之中的一个.在大规模的网络连接方面,还是推荐使用IOCP或EPOLL模型.可是Select模型能够使用在诸如对战类游戏上,比方相似星际这样的,由于它小巧易于实现,并且对战类游戏的网络连接量并不大.

对于Select模型想要突破Windows 64个限制的话,能够採取分段轮询,一次轮询64个.比如套接字列表为128个,在第一次轮询时,将前64个放入队列中用Select进行状态查询,待本次操作全部结束后.将后64个再增加轮询队列中进行轮询处理.这样处理须要在非堵塞式下工作.以此类推,Select也能支持无限多个.

注意:

1.那个最大的连接数是指每个线程能够处理的连接数,当你有多个线程时,连接数是能够无限增长的,只是此时的效率就比較低。

2.关于发送操作writefds的问题,当套接字成功连接或者一个套接字刚刚成功接收信息时都会调用。

3.我们一般会创建一个套接字来进行监听,之后用accept返回的套接字进行通信。这里要注意一点,用于监听的套接字在没有新连接时也会进行writefds的操作。

Select模型原理的更多相关文章

  1. 【转】Select模型原理

    Select模型原理利用select函数,判断套接字上是否存在数据,或者能否向一个套接字写入数据.目的是防止应用程序在套接字处于锁定模式时,调用recv(或send)从没有数据的套接字上接收数据,被迫 ...

  2. 关于 Poco::TCPServer框架 (windows 下使用的是 select模型) 学习笔记.

    说明 为何要写这篇文章 ,之前看过阿二的梦想船的<Poco::TCPServer框架解析> http://www.cppblog.com/richbirdandy/archive/2010 ...

  3. Windows I/O模型之一:Select模型

    1.概念理解 在进行网络编程时,我们常常见到同步(Sync)/异步(Async),阻塞(Block)/非阻塞(Unblock) 四种调用模式: 同步:所谓同步,就是在发出一个功能调用时,在没有得到结果 ...

  4. windows socket编程select模型使用

    int select(         int nfds,            //忽略         fd_ser* readfds,    //指向一个套接字集合,用来检测其可读性       ...

  5. socket编程的select模型

    在掌握了socket相关的一些函数后,套接字编程还是比较简单的,日常工作中碰到很多的问题就是客户端/服务器模型中,如何让服务端在同一时间高效的处理多个客户端的连接,我们的处理办法可能会是在服务端不停的 ...

  6. linux下多路复用模型之Select模型

    Linux关于并发网络分为Apache模型(Process per Connection (进程连接) ) 和TPC , 还有select模型,以及poll模型(一般是Epoll模型) Select模 ...

  7. 比较一下Linux下的Epoll模型和select模型的区别

    一. select 模型(apache的常用) 1. 最大并发数限制,因为一个进程所打开的 FD (文件描述符)是有限制的,由 FD_SETSIZE 设置,默认值是 1024/2048 ,因此 Sel ...

  8. word2vec模型原理与实现

    word2vec是Google在2013年开源的一款将词表征为实数值向量的高效工具. gensim包提供了word2vec的python接口. word2vec采用了CBOW(Continuous B ...

  9. Select模型及tcp select模型

    参考:http://m.blog.csdn.net/article/details?id=51420015 一.套接字模式 套接字模式简单的决定了操作套接字时,Winsock函数是如何运转的.Wins ...

随机推荐

  1. jQuery.data() 使用方法

    data() 方法向被选元素附加数据,或者从被选元素获取数据.在实际开发中,可以用来记录上一步操作某一对象的值,来给下一步操作做一些判断 $("#btn1").click(func ...

  2. 解决eclipse中logcat不显示log的问题

    调试程序需要打印一些消息出来,logcat不好用的话就很麻烦了.这个问题折腾了好久,为啥就是不出来呢? 上网找了很多解决办法: 重启eclipse 重启adb 重启logcat ......等等好多 ...

  3. PHP Date()函数详细参数

    在页面的最前页加上 date_default_timezone_set(PRC); /*把时间调到北京时间,php5默认为格林威治标准时间*/ date () a: "am"或是& ...

  4. 到底AR初创公司Magic Leap是不是骗子?我看未必

    AR技术和VR技术在今年的发展可谓是日新月异,眼看年末已至,不成想却出现了大新闻.最炙手可热的神秘AR初创公司Magic Leap被硅谷付费媒体The Information(付费读者大多为硅谷资深投 ...

  5. Kth Largest Element in an Array

    Find K-th largest element in an array. Notice You can swap elements in the array Example In array [9 ...

  6. sqlserver 2008 服务器拒绝连接;拒绝访问指定的数据库

    sqlserver配置管理器----sqlserver网络配置 --- 启用 named pipes OK 由于之前的程序是SQL2000开发的,迁移到SQL20008出了这个问题. 二 和主题没有什 ...

  7. c 函数及指针学习 7

    1.结构的存储分配 1 2 printf("%d \n",sizeof(char)); printf("%d \n",sizeof(int)); int 类型为 ...

  8. 使用Cyclone IV控制DDR2

    根据你的DDR2手册配置好megacore,megacore会生成一个example top: 在quartus中运行megacore生成的xxx_pin_assignments.tcl,指定DDR2 ...

  9. Makefile简介

    1.源程序的编译在Linux下面,如果要编译一个C语言源程序,我们要使用GNU的gcc编译器. 下面我们以一个实例来说明如何使用gcc编译器.假设我们有下面一个非常简单的源程序(hello.c):in ...

  10. gsp序列模式挖掘

    数据挖掘进阶之序列模式挖掘GSP算法 绪 继续数据挖掘方面算法的讲解,前面讲解了数据挖掘中关联规则算法FP-Growth的实现.此篇博文主要讲解基于有趣性度量标准的GSP序列模式挖掘算法.有关论文后期 ...