AcceptEx Function[MSDN 做个记录]

AcceptEx Function

The AcceptEx function accepts a new connection, returns the local and remote address, and receives the first block of data sent by the client application.

Note  This function is a Microsoft-specific extension to the Windows Sockets specification.


引用
BOOL AcceptEx(
  __in   SOCKET sListenSocket,
  __in   SOCKET sAcceptSocket,
  __in   PVOID lpOutputBuffer,
  __in   DWORD dwReceiveDataLength,
  __in   DWORD dwLocalAddressLength,
  __in   DWORD dwRemoteAddressLength,
  __out  LPDWORD lpdwBytesReceived,
  __in   LPOVERLAPPED lpOverlapped
);

Parameters
sListenSocket
A descriptor identifying a socket that has already been called with the listen function. A server application waits for attempts to connect on this socket.

sAcceptSocket
A descriptor identifying a socket on which to accept an incoming connection. This socket must not be bound or connected.

lpOutputBuffer
A pointer to a buffer that receives the first block of data sent on a new connection, the local address of the server, and the remote address of the client. The receive data is written to the first part of the buffer starting at offset zero, while the addresses are written to the latter part of the buffer. This parameter must be specified.

dwReceiveDataLength
The number of bytes in lpOutputBuffer that will be used for actual receive data at the beginning of the buffer. This size should not include the size of the local address of the server, nor the remote address of the client; they are appended to the output buffer. If dwReceiveDataLength is zero, accepting the connection will not result in a receive operation. Instead, AcceptEx completes as soon as a connection arrives, without waiting for any data.

dwLocalAddressLength
The number of bytes reserved for the local address information. This value must be at least 16 bytes more than the maximum address length for the transport protocol in use.

dwRemoteAddressLength
The number of bytes reserved for the remote address information. This value must be at least 16 bytes more than the maximum address length for the transport protocol in use. Cannot be zero.

lpdwBytesReceived
A pointer to a DWORD that receives the count of bytes received. This parameter is set only if the operation completes synchronously. If it returns ERROR_IO_PENDING and is completed later, then this DWORD is never set and you must obtain the number of bytes read from the completion notification mechanism.

lpOverlapped
An OVERLAPPED structure that is used to process the request. This parameter must be specified; it cannot be NULL.

Return Value
If no error occurs, the AcceptEx function completed successfully and a value of TRUE is returned.

If the function fails, AcceptEx returns FALSE. The WSAGetLastError function can then be called to return extended error information. If WSAGetLastError returns ERROR_IO_PENDING, then the operation was successfully initiated and is still in progress. If the error is WSAECONNRESET, an incoming connection was indicated, but was subsequently terminated by the remote peer prior to accepting the call.

Remarks


The AcceptEx function combines several socket functions into a single API/kernel transition. The AcceptEx function, when successful, performs three tasks:

A new connection is accepted.
Both the local and remote addresses for the connection are returned.
The first block of data sent by the remote is received.

Note  The function pointer for the AcceptEx function must be obtained at run time by making a call to the WSAIoctl function with the SIO_GET_EXTENSION_FUNCTION_POINTER opcode specified. The input buffer passed to the WSAIoctl function must contain WSAID_ACCEPTEX, a globally unique identifier (GUID) whose value identifies the AcceptEx extension function. On success, the output returned by the WSAIoctl function contains a pointer to the AcceptEx function. The WSAID_ACCEPTEX GUID is defined in the Mswsock.h header file.

A program can make a connection to a socket more quickly using AcceptEx instead of the accept function.

A single output buffer receives the data, the local socket address (the server), and the remote socket address (the client).

Using a single buffer improves performance. When using AcceptEx, the GetAcceptExSockaddrs function must be called to parse the buffer into its three distinct parts (data, local socket address, and remote socket address). On Windows XP and later, once the AcceptEx function completes and the SO_UPDATE_ACCEPT_CONTEXT option is set on the accepted socket, the local address associated with the accepted socket can also be retrieved using the getsockname function. Likewise, the remote address associated with the accepted socket can be retrieved using the getpeername function.

The buffer size for the local and remote address must be 16 bytes more than the size of the sockaddr structure for the transport protocol in use because the addresses are written in an internal format. For example, the size of a sockaddr_in (the address structure for TCP/IP) is 16 bytes. Therefore, a buffer size of at least 32 bytes must be specified for the local and remote addresses.

The AcceptEx function uses overlapped I/O, unlike the accept function. If your application uses AcceptEx, it can service a large number of clients with a relatively small number of threads. As with all overlapped Windows functions, either Windows events or completion ports can be used as a completion notification mechanism.



Another key difference between the AcceptEx function and the accept function is that AcceptEx requires the caller to already have two sockets:

One that specifies the socket on which to listen.
One that specifies the socket on which to accept the connection.
The sAcceptSocket parameter must be an open socket that is neither bound nor connected.

The lpNumberOfBytesTransferred parameter of the GetQueuedCompletionStatus function or the GetOverlappedResult function indicates the number of bytes received in the request.



When this operation is successfully completed, sAcceptSocket can be passed, but to the following functions only:

ReadFile
WriteFile
send
WSASend
recv
WSARecv
TransmitFile
closesocket
setsockopt (only for SO_UPDATE_ACCEPT_CONTEXT)
Note  If the TransmitFile function is called with both the TF_DISCONNECT and TF_REUSE_SOCKET flags, the specified socket has been returned to a state in which it is neither bound nor connected. The socket handle can then be passed to the AcceptEx function in the sAcceptSocket parameter, but the socket cannot be passed to the ConnectEx function.

When the AcceptEx function returns, the socket sAcceptSocket is in the default state for a connected socket. The socket sAcceptSocket does not inherit the properties of the socket associated with sListenSocket parameter until SO_UPDATE_ACCEPT_CONTEXT is set on the socket. Use the setsockopt function to set the SO_UPDATE_ACCEPT_CONTEXT option, specifying sAcceptSocket as the socket handle and sListenSocket as the option value.


For example:
  1.  err = setsockopt( sAcceptSocket,    
  2.     SOL_SOCKET,    
  3.     SO_UPDATE_ACCEPT_CONTEXT,    
  4.     (char *)&sListenSocket,    
  5.     sizeof(sListenSocket) );   

If a receive buffer is provided, the overlapped operation will not complete until a connection is accepted and data is read. Use the getsockopt function with the SO_CONNECT_TIME option to check whether a connection has been accepted. If it has been accepted, you can determine how long the connection has been established. The return value is the number of seconds that the socket has been connected. If the socket is not connected, the getsockopt returns 0xFFFFFFFF. Applications that check whether the overlapped operation has completed, in combination with the SO_CONNECT_TIME option, can determine that a connection has been accepted but no data has been received. Scrutinizing a connection in this manner enables an application to determine whether connections that have been established for a while have received no data. It is recommended such connections be terminated by closing the accepted socket, which forces the AcceptEx function call to complete with an error.


For example:

  1.  INT seconds;   
  2. INT bytes = sizeof(seconds);   
  3. err = getsockopt( sAcceptSocket, SOL_SOCKET, SO_CONNECT_TIME,   
  4.                       (char *)&seconds, (PINT)&bytes );   
  5. if ( err != NO_ERROR ) {   
  6.     printf( "getsockopt(SO_CONNECT_TIME) failed: %ld\n", WSAGetLastError( ) );   
  7.     exit(1);   
  8. }   

Note   All I/O initiated by a given thread is canceled when that thread exits. For overlapped sockets, pending asynchronous operations can fail if the thread is closed before the operations complete. See ExitThread for more information.

Example Code

The following example uses the AcceptEx function using overlapped I/O and completion ports.

  1.  #include <stdio.h>   
  2. #include "winsock2.h"   
  3. #include "mswsock.h"   
  4.   
  5. void main() {   
  6.   //----------------------------------------   
  7.   // Declare and initialize variables   
  8.   WSADATA wsaData;   
  9.   HANDLE hCompPort;   
  10.   LPFN_ACCEPTEX lpfnAcceptEx = NULL;   
  11.   GUID GuidAcceptEx = WSAID_ACCEPTEX;   
  12.   WSAOVERLAPPED olOverlap;   
  13.      
  14.   SOCKET ListenSocket, AcceptSocket;   
  15.   sockaddr_in service;   
  16.   char lpOutputBuf[1024];   
  17.   int outBufLen = 1024;   
  18.   DWORD dwBytes;   
  19.   
  20.   //----------------------------------------   
  21.   // Initialize Winsock   
  22.   int iResult = WSAStartup( MAKEWORD(2,2), &wsaData );   
  23.   if( iResult != NO_ERROR )   
  24.     printf("Error at WSAStartup\n");   
  25.   
  26.   //----------------------------------------   
  27.   // Create a handle for the completion port   
  28.   hCompPort = CreateIoCompletionPort( INVALID_HANDLE_VALUE, NULL, (u_long)0, 0 );   
  29.   
  30.   //----------------------------------------   
  31.   // Create a listening socket   
  32.   ListenSocket = socket( AF_INET, SOCK_STREAM, IPPROTO_TCP );   
  33.   if (ListenSocket == INVALID_SOCKET) {   
  34.     printf("Error at socket(): ListenSocket\n");   
  35.     WSACleanup();   
  36.     return;   
  37.   }   
  38.   
  39.   //----------------------------------------   
  40.   // Associate the listening socket with the completion port   
  41.   CreateIoCompletionPort((HANDLE)ListenSocket, hCompPort, (u_long)0, 0);   
  42.   
  43.   //----------------------------------------   
  44.   // Bind the listening socket to the local IP address   
  45.   // and port 27015   
  46.   hostent* thisHost;   
  47.   char* ip;   
  48.   u_short port;   
  49.   port = 27015;   
  50.   thisHost = gethostbyname("");   
  51.   ip = inet_ntoa (*(struct in_addr *)*thisHost->h_addr_list);   
  52.   
  53.   service.sin_family = AF_INET;   
  54.   service.sin_addr.s_addr = inet_addr(ip);  service.sin_port = htons(port);   
  55.   
  56.   if ( bind( ListenSocket,(SOCKADDR*) &service, sizeof(service) )  == SOCKET_ERROR ) {   
  57.     printf("bind failed\n");   
  58.     closesocket(ListenSocket);   
  59.     return;   
  60.   }   
  61.   
  62.   //----------------------------------------   
  63.   // Start listening on the listening socket   
  64.   if (listen( ListenSocket, 100 ) == SOCKET_ERROR) {   
  65.     printf("error listening\n");   
  66.   }    
  67.   printf("Listening on address: %s:%d\n", ip, port);   
  68.   
  69.   //----------------------------------------   
  70.   // Load the AcceptEx function into memory using WSAIoctl.   
  71.   // The WSAIoctl function is an extension of the ioctlsocket()   
  72.   // function that can use overlapped I/O. The function's 3rd   
  73.   // through 6th parameters are input and output buffers where   
  74.   // we pass the pointer to our AcceptEx function. This is used   
  75.   // so that we can call the AcceptEx function directly, rather   
  76.   // than refer to the Mswsock.lib library.   
  77.   WSAIoctl(ListenSocket,    
  78.     SIO_GET_EXTENSION_FUNCTION_POINTER,    
  79.     &GuidAcceptEx,    
  80.     sizeof(GuidAcceptEx),   
  81.     &lpfnAcceptEx,    
  82.     sizeof(lpfnAcceptEx),    
  83.     &dwBytes,    
  84.     NULL,    
  85.     NULL);   
  86.   
  87.   //----------------------------------------   
  88.   // Create an accepting socket   
  89.   AcceptSocket = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);   
  90.   if (AcceptSocket == INVALID_SOCKET) {   
  91.     printf("Error creating accept socket.\n");   
  92.     WSACleanup();   
  93.     return;   
  94.   }   
  95.   
  96.   //----------------------------------------   
  97.   // Empty our overlapped structure and accept connections.   
  98.   memset(&olOverlap, 0, sizeof(olOverlap));   
  99.   
  100.   lpfnAcceptEx(ListenSocket,    
  101.     AcceptSocket,   
  102.     lpOutputBuf,    
  103.     outBufLen - ((sizeof(sockaddr_in) + 16) * 2),   
  104.     sizeof(sockaddr_in) + 16,    
  105.     sizeof(sockaddr_in) + 16,    
  106.     &dwBytes,    
  107.     &olOverlap);   
  108.   
  109.   //----------------------------------------   
  110.   // Associate the accept socket with the completion port   
  111.   CreateIoCompletionPort((HANDLE)AcceptSocket, hCompPort, (u_long)0, 0);   
  112.   
  113.   //----------------------------------------   
  114.   // Continue on to use send, recv, TransmitFile(), etc.,.   
  115.   ...   
  116.   
  117. }   

Notes for QOS
The TransmitFile function allows the setting of two flags, TF_DISCONNECT or TF_REUSE_SOCKET, that return the socket to a "disconnected, reusable" state after the file has been transmitted. These flags should not be used on a socket where quality of service has been requested, since the service provider may immediately delete any quality of service associated with the socket before the file transfer has completed. The best approach for a QOS-enabled socket is to simply call the closesocket function when the file transfer has completed, rather than relying on these flags.

Notes for ATM
There are important issues associated with connection setup when using Asynchronous Transfer Mode (ATM) with Windows Sockets 2. Please see the Remarks section in the accept function documentation for important ATM connection setup information.

Requirements
Client Requires Windows Vista, Windows XP, Windows 2000 Professional, or Windows NT Workstation 3.51 and later.
Server Requires Windows Server 2008, Windows Server 2003, Windows 2000 Server, or Windows NT Server 3.51 and later.
Header Declared in Mswsock.h.

Library Use Mswsock.lib.

DLL Requires Mswsock.dll.


如果你想它连接上就立即提示连接完成,则只须将dwReceiveDataLength赋0就OK.

使用AcceptEx()的一大好处是,
你可以通过一次调用就完成接受客户端连接请求和接受数据(通过传送lpOutputBuffer参数)两件事情。
也就是说,如果客户端在发出连接的同时传输数据,
你的AcceptEx()调用在连接创建并接收了客户端数据后就可以立刻返回。
这样可能是很有用的,但是也可能会引发问题,因为AcceptEx()必须等全部客户端数据都收到了才返回。
具体来说,如果你在发出AcceptEx()调用的同时传递了 lpOutputBuffer参数,那么AcceptEx()不再是一项原子型的操作,
而是分成了两步:接受客户连接,等待接收数据。当缺少一种机制来通知你的应用程序所发生的这种情况:“连接已经建立了,正在等待客户端数据”,这将意味着有可能出现客户端只发出连接请求,但是不发送数据。

posted on 2008-04-28 14:47 RedLight 阅读(1210) 评论(0)  编辑 收藏 引用 所属分类: 网络服务器开发


只有注册用户登录后才能发表评论。
网站导航: 博客园   IT新闻   BlogJava   博问   Chat2DB   管理


<2008年4月>
303112345
6789101112
13141516171819
20212223242526
27282930123
45678910

导航

统计

公告


Name: Galen
QQ: 88104725

常用链接

留言簿(3)

随笔分类

随笔档案

相册

My Friend

搜索

最新评论

阅读排行榜

评论排行榜