什麼是流?流,簡單來說就是建立在面向對象基礎上的一種抽象的處理數據的工具。在流中,定義了一些處理數據的基本操作,如讀取數據,寫入數據等,程序員是對流進行所有操作的,而不用關心流的另一頭數據的真正流向。流不但可以處理文件,還可以處理動態內存、網絡數據等多種數據形式。如果你對流的操作非常熟練,在程序中利用流的方便性,寫起程序會大大提高效率的。
一、Delphi中流的基本概念及函數聲明
在Delphi中,所有流對象的基類為TStream類,其中定義了所有流的共同屬性和方法。
TStream類中定義的屬性介紹如下:
1、Size:此屬性以字節返回流中數據大小。
2、Position:此屬性控制流中存取指針的位置。
Tstream中定義的虛方法有四個:
1、Read:此方法實現將數據從流中讀出。函數原形為:
Function Read(var Buffer;Count:Longint):Longint;virtual;abstract;
參數Buffer為數據讀出時放置的緩沖區,Count為需要讀出的數據的字節數,該方法返回值為實際讀出的字節數,它可以小於或等於Count中指定的值。
2、Write:此方法實現將數據寫入流中。函數原形為:
Function Write(var Buffer;Count:Longint):Longint;virtual;abstract;
參數Buffer為將要寫入流中的數據的緩沖區,Count為數據的長度字節數,該方法返回值為實際寫入流中的字節數。
3、Seek:此方法實現流中讀取指針的移動。函數原形為:
Function Seek(Offset:Longint;Origint:Word):Longint;virtual;abstract;
參數Offset為偏移字節數,參數Origint指出Offset的實際意義,其可能的取值如下:
soFromBeginning:Offset為移動後指針距離數據開始的位置。此時Offset必須大於或者等於零。
soFromCurrent:Offset為移動後指針與當前指針的相對位置。
soFromEnd:Offset為移動後指針距離數據結束的位置。此時Offset必須小於或者等於零。該方法返回值為移動後指針的位置。
4、Setsize:此方法實現改變數據的大小。函數原形為:
Function Setsize(NewSize:Longint);virtual;
另外,TStream類中還定義了幾個靜態方法:
1、ReadBuffer:此方法的作用是從流中當前位置讀取數據。函數原形為:
Procedure ReadBuffer(var Buffer;Count:Longint);
參數的定義跟上面的Read相同。注意:當讀取的數據字節數與需要讀取的字節數不相同時,將產生EReadError異常。
2、WriteBuffer:此方法的作用是在當前位置向流寫入數據。函數原形為:
Procedure WriteBuffer(var Buffer;Count:Longint);
參數的定義跟上面的Write相同。注意:當寫入的數據字節數與需要寫入的字節數不相同時,將產生EWriteError異常。
3、CopyFrom:此方法的作用是從其它流中拷貝數據流。函數原形為:
Function CopyFrom(Source:TStream;Count:Longint):Longint;
參數Source為提供數據的流,Count為拷貝的數據字節數。當Count大於0時,CopyFrom從Source參數的當前位置拷貝Count個字節的數據;當Count等於0時,CopyFrom設置Source參數的Position屬性為0,然後拷貝Source的所有數據;
參考資料:
不是中文的
http://homepages.borland.com/efg2lab/Library/Delphi/IO/StreamIO.htm
lovejingtao大大的文章:談Delphi編程中“流”的應用
http://Delphi.ktop.com.tw/TOPIC.ASP?TOPIC_ID=33689
TWinSocketStream用於採用阻塞式Socket連接的資料讀寫,
在這邊有一篇關於這幾種流的簡單說明和例子,可參考一下:
http://www.legalsoft.com.cn/Articles/ArticleBrowse.ASP?idArticle=328
那段BCB的WinSocketStream的代碼轉成Delphi如下:
uses ScktComp; procedure TMyClientThread.Execute; var pStream: TWinSocketStream; buffer: string; begin { create a TWinSocketStream for reading and writing } pStream := TWinSocketStream.Create(ClientSocket1.Socket, 60000); try { fetch and process commands until the connection or thread is terminated } while (not Terminated) and (ClIEntSocket1.Active) do begin try GetNextRequest(buffer); { GetNextRequest must be a thread-safe method } { write the request to the server } pStream.Write(buffer, Length(buffer) + 1); { continue the communication (e.g. read a response from the server) } ... except if not(ExceptObject is EAbort) then Synchronize(HandleThreadException); { you must write HandleThreadException } end; end; finally pStream.free; end; end;