正文

用TTcpClient和TTcpServer进行文件的传输

IP云
IP云V管理员/3 阅读
07/30
提示：扫一扫查出行
【扫一扫了解最新限行尾号】
复制提示

发送数据时有Sendln，SendBuf，SendStream。接收数据时有Receiveln,ReceiveBuf,当时我很奇怪为什么没有ReceiveStream。因为很自然的想到是对应关系的。但当时我不知道，发数据时是一小段一小段地发的

看看SendStream代码：

  1. function TBaseSocket.SendStream(AStream: TStream): Integer;
  2. var
  3. BufLen: Integer;
  4. Buffer: array[0..511] of Byte;
  5. begin
  6. Result := 0;
  7. if Assigned(AStream) then
  8. begin
  9. repeat
  10. BufLen := AStream.Read(Buffer, SizeOf(Buffer));
  11. until (BufLen = 0) or (SendBuf(Buffer, BufLen) = SOCKET_ERROR);
  12. end;
  13. end;

从以上代码可看到，SendStream一次最多发送512字节的内容，所以，我们这接收端循环用ReceiveBuf接收就可以了。不用像以前那样写得又复杂乱。

发送端(Client)代码：

  1. unit Unit1;
  2. interface
  3. uses
  4. Windows, Messages, SysUtils, Variants, Classes, Graphics, Controls, Forms,
  5. Dialogs, StdCtrls, Sockets;
  6. type
  7. TForm1 = class(TForm)
  8. tcpclnt1: TTcpClient;
  9. btn1: TButton;
  10. procedure btn1Click(Sender: TObject);
  11. private
  12. { Private declarations }
  13. public
  14. { Public declarations }
  15. end;
  16. var
  17. Form1: TForm1;
  18. implementation
  19. {$R *.dfm}
  20. procedure TForm1.btn1Click(Sender: TObject);
  21. var
  22. f : TFileStream;//文件流
  23. i : Integer;
  24. fn : string;//文件名
  25. begin
  26. {用for循环是实现发送多个文件,如果只是发送一个文件，不用循环}
  27. for i := 1 to 11 do
  28. begin
  29. tcpclnt1.Connect; //连接服务端，我把TTcpClient的BlockMode设为bmBlocking
  30. fn := 'a' + IntToStr(i) + '.rar';
  31. f := TFileStream.Create('d:/send/' + fn,fmOpenRead); //用文件流以读方式打开要发送的文件
  32. tcpclnt1.Sendln(fn); //给对方发送文件名
  33. tcpclnt1.Sendln(IntToStr(f.Size)); //给对方发送文件大小
  34. tcpclnt1.SendStream(f); //发送文件流
  35. f.Free;//释放文件流
  36. tcpclnt1.Disconnect;//关闭连接
  37. end;
  38. end;
  39. end.

接收端(Server)代码：

  1. unit Unit1;
  2. interface
  3. uses
  4. Windows, Messages, SysUtils, Variants, Classes, Graphics, Controls, Forms,
  5. Dialogs, Sockets;
  6. type
  7. TForm1 = class(TForm)
  8. tcpsrvr1: TTcpServer;
  9. procedure FormActivate(Sender: TObject);
  10. procedure tcpsrvr1Accept(Sender: TObject;
  11. ClientSocket: TCustomIpClient);
  12. private
  13. { Private declarations }
  14. public
  15. { Public declarations }
  16. end;
  17. var
  18. Form1: TForm1;
  19. implementation
  20. {$R *.dfm}
  21. procedure TForm1.FormActivate(Sender: TObject);
  22. begin
  23. tcpsrvr1.Open; //在OnActive事件中启动TCPServer的监听
  24. end;
  25. procedure TForm1.tcpsrvr1Accept(Sender: TObject;
  26. ClientSocket: TCustomIpClient);
  27. var
  28. f : TFileStream;  //文件流
  29. iFileSize : Integer; //文件大小
  30. iTotalRec : Integer; //总接收到的字节数,用来和文件大小比较,如果比文件大小的值要小,就还要继续接收
  31. iacRec    : Integer; //每一次ReceiveBuf实际接收到的字节数
  32. pbuf      : Pointer; //缓存指针
  33. i : Integer;
  34. fn : string; //文件名
  35. begin
  36. GetMem(pbuf,512); //我们一次最多也读取512字节
  37. try
  38. iTotalRec := 0;   //先把总接收到的字节数置零
  39. fn := ClientSocket.Receiveln; //接收文件名
  40. iFileSize := StrToInt(ClientSocket.Receiveln); //接收文件大小,接收到的字符串,要转成integer
  41. f := TFileStream.Create('d:/rec/'+ fn,fmCreate);//创建文件
  42. try
  43. {如果接收到的总字节数小于文件总字节数且实际接收字节数不为-1就一直循环接收}
  44. while iTotalRec < iFileSize  do
  45. begin
  46. iacRec := ClientSocket.ReceiveBuf(pbuf^,512);//一次接收512字节
  47. if iacRec = -1 then
  48. Break;//如果实际接收字节数是-1表示出错了,退出循环(应该写个log,或作出错处理什么的)
  49. f.Write(pbuf^,iacRec);//把接收到的数据写到文件流中
  50. Inc(iTotalRec,iacRec);//叠加接收到的总字节数
  51. end;
  52. finally
  53. f.Free; //释放流
  54. end;
  55. finally
  56. FreeMem(pbuf);//释放内存
  57. end;
  58. end;
  59. end.
http://blog.csdn.net/zang141588761/article/details/52288692