程序師世界是廣大編程愛好者互助、分享、學習的平台,程序師世界有你更精彩!
首頁
編程語言
C語言|JAVA編程
Python編程
網頁編程
ASP編程|PHP編程
JSP編程
數據庫知識
MYSQL數據庫|SqlServer數據庫
Oracle數據庫|DB2數據庫
 程式師世界 >> 編程語言 >> 更多編程語言 >> Delphi >> 非阻塞方式下Socket讀取數據的一個例子

非阻塞方式下Socket讀取數據的一個例子

編輯:Delphi

 

標題:非阻塞方式下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 didnt 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;


  1. 上一頁:
  2. 下一頁:
Copyright © 程式師世界 All Rights Reserved