学习笔记：delphi实现网络通信之select模型

说明：所有的winsock的定义用的是jwawinsock2。(整个包的下载：http://blog.delphi-jedi.net/home/)

主要函数：select

目的：允许那些想要避免在套接字调用上阻塞的应用程序有能力管理多个套接字。

函数定义：select(nfds:integer;readfds:Pfd_set;writefds:Pfd_set;exceptfds:Pfd_set;timeout:Ptimeval)

套接集合：FD_SET结构

PFD_SET=^Fd_set

Fd_set=record

    fd_count:integer;

   fd_array:array[0..FD_SETSIZE-1] of Tsocket;

end;{FD_SETSIZE系统默认为64.也就是系统默认管理64个套接字。实际可以定义到1000。}

关于FD_SET集合操作函数。

FD_ZERO(SET:PFD_SET)  初始化set为空集合。集合在使用前应该总是清空。

FD_CLR(s:TSOCKET;set:PFD_SET) 从set移除套接字。

FD_ISSETs(S:TSOCKET;SET:PFD_SET) 检查s是不是set的成员，如果是返回TRUE。

FD_SET(S:TSOCKET;set:PFD_SET)添加套接字到集合。

delphi代码：

program Proserver;
//控制台程序。
{$APPTYPE CONSOLE}

uses
  JwaWinsock2,Windows,SysUtils;

var
  nPort:UINT;
  sListen,sNew:TSocket;
  socket_in,addrRemote:sockaddr_in;
  fdSocket,fdRead:fd_set;
  i,nAddrLen:integer;
  szText:array[0..255] of AnsiChar;
procedure initsock;
     var
       v_wsadata:WSAData;
       sockversion:Cardinal;
      begin
         sockversion:=MAKEWORD(2,2);
         try
          if  WSAStartup(sockversion,v_wsadata)<>0 then
            Exit;

         except
           Exit;
         end;
      end;
procedure cleansock;
      begin
        WSACleanup();
      end;
begin
   initsock;
   nport:=4567;
   sListen:=socket(AF_INET,SOCK_STREAM,IPPROTO_TCP);
   socket_in.sin_family:=AF_INET;
   socket_in.sin_port:=htons(nPort);
   socket_in.sin_addr.S_addr:=INADDR_ANY;

   //进行SOCKET绑定到本地机器
   if bind(sListen,psockaddr(@socket_in),SizeOf(socket_in))=socket_error then
     begin
       writeln('Failed bind()');
       Exit;
     end
   else
     begin
       Writeln('SOCKET绑定成功。');
     end;

   //进入监听模式
   Writeln('程序进入监听状态......');
   listen(sListen,5);

   //select模型处理过程
   //1、初始化一个套接字集合fdsocket，添加监听套接字句柄到这个集合。
   FD_ZERO(fdSocket);
   _FD_SET(sListen,fdSocket);

   //进行等待状态中。。。。。。
   Writeln('进入无限循环状态。。。。。');
   while True do
   begin
     // 2、将FDSOCKET集合的一个拷贝FDREAD传递给SELECT函数。
     fdRead:=fdSocket;
     if select(0,@fdread,nil,nil,nil)>0 then
       begin
         for i:=0 to fdSocket.fd_count-1 do
          begin
            if FD_ISSET(fdSocket.fd_array[i],fdRead) then
             begin
               if fdSocket.fd_array[i]=sListen then
                 begin
                   if fdSocket.fd_count<FD_SETSIZE then
                     begin
                       nAddrLen:=SizeOf(addrRemote);
                       sNew:=accept(sListen,psockaddr(@addrRemote),@nAddrlen);
                       _FD_SET(sNew,fdSocket);
                       Writeln('接收到连接：'+strpas(inet_ntoa(addrRemote.sin_addr)));
                     end
                   else
                     begin
                      Writeln('连接太多，超出系统要求。');
                      Continue;
                     end;
                 end
               else
                 begin
                   if recv(fdSocket.fd_array[i],szText,SizeOf(szText),0)>0 then
                     begin
                       Writeln('接收的数据是：'+strpas(sztext));
                     end
                   else
                     begin
                       closesocket(fdSocket.fd_array[i]);
                       FD_CLR(fdSocket.fd_array[i],fdSocket);
                       Writeln('当前连接已判断。');
                     end;
                 end;
             end;
          end;
       end
     else
      begin
        Writeln('Failed select().');
        Break;
      end;
   end;
  cleansock;
end.