原文出处 《Windows网络编程技术》第8章 完成端口模型
由于原书附的是C代码,我把其翻译成Delphi代码。
其中winsock2.pas在delphi中不带,要另外下载http://jungla.dit.upm.es/~bti/files/winsock2.pas
program CompletionIO;
{$APPTYPE CONSOLE}
uses SysUtils, WinSock2 in ''''WinSock2.pas'''', Mains in ''''Mains.pas'''';
begin main(); end.
// Module Name: iocmplt.cpp // // Description: // // This sample illustrates how to develop a simple echo server Winsock // application using the completeion port I/O model. This // sample is implemented as a console-style application and simply prints // messages when connections are established and removed from the server. // The application listens for TCP connections on port 5150 and accepts them // as they arrive. When this application receives data from a client, it // simply echos (this is why we call it an echo server) the data back in // it''''s original form until the client closes the connection. // // 2005-2-5 // cpp convert to delphi pas by johnson //
unit Mains;
interface
uses Windows, WinSock2, WinSock, Sysutils;
const PORT = 5150; DATA_BUFSIZE = 8192;
type LPVOID = Pointer; LPPER_IO_OPERATION_DATA = ^ PER_IO_OPERATION_DATA ; PER_IO_OPERATION_DATA = packed record Overlapped: OVERLAPPED; DataBuf: TWSABUF; Buffer: array [0..DATA_BUFSIZE] of CHAR; BytesSEND: DWORD; BytesRECV: DWORD; end;
LPPER_HANDLE_DATA = ^ PER_HANDLE_DATA; PER_HANDLE_DATA = packed record Socket: TSocket; end;
procedure main;
implementation
function ServerWorkerThread(CompletionPortID: LPVOID): DWORD; stdcall; forward;
procedure printf(Fmt: string; num: Integer); begin WriteLn(Format(Fmt, [num])); end;
procedure main; var InternetAddr: SOCKADDR_IN; Listen: TSOCKET; Accept: TSOCKET; CompletionPort: THANDLE ; SystemInfo: SYSTEM_INFO ; PerHandleData: LPPER_HANDLE_DATA ; PerIoData: LPPER_IO_OPERATION_DATA ; i: Integer; RecvBytes: DWORD; Flags: DWORD; ThreadID: DWORD ; wsaData: TWSADATA ; Ret: DWORD ;
ThreadHandle: THANDLE; begin Ret := WSAStartup($0202, wsaData); if (Ret <> 0) then begin printf(''''WSAStartup failed with error %d'''', Ret); Exit; end;
// Setup an I/O completion port. CompletionPort := CreateIoCompletionPort(INVALID_HANDLE_VALUE, 0, 0, 0); if (CompletionPort = 0) then begin printf( ''''CreateIoCompletionPort failed with error: %d'''', GetLastError()); Exit; end;
// Determine how many processors are on the system.
GetSystemInfo(SystemInfo);
// Create worker threads based on the number of processors available on the // system. Create two worker threads for each processor.
for i:= 0 to SystemInfo.dwNumberOfProcessors * 2 - 1 do begin
// Create a server worker thread and pass the completion port to the thread. ThreadHandle := CreateThread(nil, 0, @ServerWorkerThread, Pointer(CompletionPort), 0, ThreadID); if (ThreadHandle = 0) then begin printf(''''CreateThread() failed with error %d'''', GetLastError()); Exit; end;
// Close the thread handle CloseHandle(ThreadHandle); end;
// Create a listening socket Listen := WSASocket(AF_INET, SOCK_STREAM, 0, nil, 0, WSA_FLAG_OVERLAPPED); if (Listen = INVALID_SOCKET) then begin printf(''''WSASocket() failed with error %d'''', WSAGetLastError()); exit; end;
InternetAddr.sin_family := AF_INET; InternetAddr.sin_addr.s_addr := htonl(INADDR_ANY); InternetAddr.sin_port := htons(PORT);
if (bind(Listen, InternetAddr, sizeof(InternetAddr)) = SOCKET_ERROR) then begin printf(''''bind() failed with error %d'''', WSAGetLastError()); exit; end;
// Prepare socket for listening
if (Winsock.listen(Listen, 5) = SOCKET_ERROR) then begin printf(''''listen() failed with error %d'''', WSAGetLastError()); exit; end else begin printf(''''Server listen on port = %d ...'''', PORT); end;
// Accept connections and assign to the completion port. while(TRUE) do begin Accept := WSAAccept(Listen, nil, nil, nil, 0); if (Accept = SOCKET_ERROR) then begin printf(''''WSAAccept() failed with error %d'''', WSAGetLastError()); exit; end;
// Create a socket information structure to associate with the socket PerHandleData := LPPER_HANDLE_DATA (GlobalAlloc(GPTR, sizeof(PER_HANDLE_DATA))); if (PerHandleData = nil) then begin printf(''''GlobalAlloc() failed with error %d'''', WSAGetLastError()); exit; end;
// Associate the accepted socket with the original completion port.
printf(''''Socket number %d connected'''', Accept); PerHandleData.Socket := Accept;
if (CreateIoCompletionPort(Accept, CompletionPort, DWORD(PerHandleData), 0) = 0) then begin printf(''''CreateIoCompletionPort() failed with error %d'''', WSAGetLastError()); exit; end;
// Create per I/O socket information structure to associate with the // WSARecv call below.
PerIoData := LPPER_IO_OPERATION_DATA(GlobalAlloc(GPTR, sizeof(PER_IO_OPERATION_DATA))); if (PerIoData = nil) then begin printf(''''GlobalAlloc() failed with error %d'''', WSAGetLastError()); exit; end;
ZeroMemory( @PerIoData.Overlapped, sizeof(OVERLAPPED)); PerIoData.BytesSEND := 0; PerIoData.BytesRECV := 0; PerIoData.DataBuf.len := DATA_BUFSIZE; PerIoData.DataBuf.buf := @PerIoData.Buffer;
Flags := 0; if (WSARecv(Accept, @(PerIoData.DataBuf), 1, @RecvBytes, @Flags, @(PerIoData.Overlapped), nil) = SOCKET_ERROR) then begin if (WSAGetLastError() <> ERROR_IO_PENDING) then begin printf(''''WSARecv() failed with error %d'''', WSAGetLastError()); exit; end end;
end; end;
function ServerWorkerThread(CompletionPortID: LPVOID): DWORD; stdcall; var CompletionPort: THANDLE; BytesTransferred: DWORD ; // Overlapped: POVERLAPPED; PerHandleData: LPPER_HANDLE_DATA ; PerIoData: LPPER_IO_OPERATION_DATA ; SendBytes, RecvBytes: DWORD; Flags: DWORD
[1] [2] 下一页 [系统软件]InstallShield Express for delphi制作安装程序定… [常用软件]InstallShield Express制作Delphi数据库安装程序 [Delphi程序]为什么选择Delphi.Net ? [Delphi程序]《关于VisiBroker For Delphi的使用》(4) [Delphi程序]Delphi 程序员代码编写标准指南 [Delphi程序]转贴:Conversion to Delphi 6: Missing unit Pro… [Delphi程序]Borland Delphi 9 的新特性 [Delphi程序]Delphi 键盘码表 [Delphi程序]Chuck Jazdzewski的离开意味着Delphi的终结吗? [Delphi程序]Delphi Access violations 问题的解决之道
|