首页 > > 程序设计 > delphi >

关于流的使用资料及相关实例

2008-04-11 12:26:53来源：互联网阅读 ()

网络ID:wnhoo or sos_admin
网名:e梦缘
Mail:wnhoo@163.com
风花雪月 e梦情缘

什么是流？流,简单来说就是建立在面向对象基础上的一种抽象的处理数据的工具。在流中，定义了一些处理数据的基本操作，如读取数据，写入数据等，程序员是对流进行所有操作的，而不用关心流的另一头数据的真正流向。流不但可以处理文件，还可以处理动态内存、网络数据等多种数据形式。如果你对流的操作非常熟练，在程序中利用流的方便性，写起程序会大大提高效率的。

一、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;

我又找到了些......
http://www.fosu.edu.cn/netschool/delphi/050.htm
http://www.fosu.edu.cn/netschool/delphi/051.htm