非阻塞方式下Socket读取数据的一个例子

王朝delphi·作者佚名  2006-01-08
窄屏简体版  字體: |||超大  

标题:非阻塞方式下Socket读取数据的一个例子

作者:DreamTiger

发表时间:2000-1-15 下午 05:59:13

发信人: lBlade (刀锋), 信区: Delphi

标 题: Re: 斑竹帮忙看看偶这段Socket程序!救救我! (转载)

发信站: BBS 水木清华站 (Tue Jan 11 14:22:56 2000)

【 在 windlike (风花雪月) 的大作中提到: 】

: 多谢指教!

: 我去大富翁看了。其中有这么一端:

: 阻塞方式可以产生OnClientRead(Write)事件

: 而非阻塞方式,需要自己去读。不会产生这些事件

: 请问,是这样的吗?如果是,那么如何知道有数据

: 到达呢?

: 偶的Server肯定要用stThreadBlocking

: 谢谢

的确如此。在Block方式下,可以通过Windows消息机制进行事件处理,

但在NonBlock方式下,读写操作都必须自己手动处理。

可以看看下面的示例程序。

(一个简单的文件服务器,客户端发送文件名到Server上,Server读取

文件名后把Server上的该文件内容发送到客户端)

定义一个TFileServerThread线程类,重载其ClientExecute方法。

在ServerSocket的GetThread事件中创建出一个新线程进行处理。

procedure TForm1.ServerSocketGetThread(Sender: TObject;

ServerSocket: TServerClientWinSocket;

var SocketThread: TServerClientThread);

begin

// Create a new thread for connection

SocketThread := TFileServerThread.Create(False, ServerSocket);

end;

有关TFileServerThread的定义和ServerExecute过程实现如下:

(可以通过SocketStream.WaitForData(时间长度)进行数据等待)

TFileServerThread = class(TServerClientThread)

public

procedure ServerExecute; override;

end;

procedure TFileServerThread.ServerExecute;

var

Data: array[0..1023] of char;

FileName: String;

SocketStream: TWinSocketStream;

begin

while not Terminated and ServerSocket.Connected do

try

SocketStream := TWinSocketStream.Create(ServerSocket, 60000);

try

FillChar(Data, SizeOf(Data), 0);

if SocketStream.Read(Data, SizeOf(Data)) = 0 then

begin

// If we didn't get any data after 60 seconds then close the connect

ion

ServerSocket.Close;

Terminate;

end;

FileName := Data;

if Length(FileName) > 2 then

Delete(FileName, Pos(#13#10, FileName), 2); // Delete #13#10

if FileExists(FileName) and ServerSocket.Connected then

begin

ServerSocket.SendStream(TFileStream.Create(FileName, fmOpenRead or

fmShareCompat or fmShareDenyNone));

// Need to use SendMessage here otherwise S could change

SendMessage(Form1.Listbox1.Handle, LB_ADDSTRING, 0, Integer(PChar(Fi

leName)));

// PostMessage here is OK because we are not relying on any data

PostMessage(Form1.Handle, CM_INCCOUNT, 0, 0);

end;

finally

SocketStream.Free;

end;

except

HandleException;

end;

end;

 
 
 
免责声明:本文为网络用户发布,其观点仅代表作者个人观点,与本站无关,本站仅提供信息存储服务。文中陈述内容未经本站证实,其真实性、完整性、及时性本站不作任何保证或承诺,请读者仅作参考,并请自行核实相关内容。
 
 
© 2005- 王朝網路 版權所有 導航