• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    公众号

Delphi实例分析:远程传输数据和文件

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

在Windows操作系统的平台上,WinSock是首选的网络编程接口,用于在网络上传输数据和交换信息,它构成了Windows操作系统进行网络编程的基础。对于编写网络应用程序来说,WinSock是一门非常重要的并且必须掌握的知识,虽然现在有很多的工具如FTP程序可以在网络上传输数据和文件,但是通过WinSock编程具有更大的灵活性,因为它不需要关心网络连接的细节问题。然而用WinSock编程却相当复杂,但是在Delphi中我们并不需要直接与WinSock的API函数打交道,因在Delphi中的TClientSocket组件和TServerSocket组件封装了WinSock的大部分API函数,使得对WinSock的编程大大简化。在网络通信协议的面向连接服务中,进行传输数据和交换信息之前,通信双方应该建立一条用于进行数据交换的“链路”,通信双方就是利用这个“链路”进行稳定可靠的数据传输,由于建立通信的双方都处于收发信息的状态,并且保证了数据传输的稳定性,所以在传输较大的文件时,具有较高的效率。而建立“链路”和断掉“链路”都需要消耗一定的时间,所以在传输较小文件时的效率是比较低的。

  在这里我们将了解winsock如何实现远程传输数据和文件。在一个局域网内不同的计算机上分别运行服务器端程序和客户端程序。服务器端运行后就启动,socket将建立侦听状态。客户端运行后,在客户端程序中填写服务器IP地址,然后单击“连接”按钮,向服务器端发出一个建立连接的请求,如图1所示。如果通客户端程序过端口成功和服务器端连接,服务器端的状态栏就会有“已和客户端连接”的提示,并准备传输文件,如图2所示。

  



  图1



  



  图2



  单击“发送”按钮,在弹出的对话框中选择一个准备发送的文件,然后客户端将文件的大小和其他信息等发送到服务器端,服务器端接受到文件的信息后通知客户端开始传送文件,文件的数据需要多次传递,服务器将文件全部接受并保存。系统运行如图3、图4所示:

  



  图3



  



  图4



  服务器端程序编写:

新建一个项目,并把一个TServerSocket组件放到Form1窗体上,Active设为True;端口Port设为2000,其它属性按默认值。服务器端程序代码如下:

  unit Unit1;

  interface

  uses

   Windows, Messages, SysUtils, Variants, Classes, Graphics, Controls, Forms,

   Dialogs, StdCtrls, ScktComp, ComCtrls, DB, DBTables, XPMan;

  Const

   MP_QUERY ='1';

   MP_REFUSE ='2';

   MP_ACCEPT ='3';

   MP_NEXTWILLBEDATA ='4';

   MP_DATA ='5';

   MP_ABORT ='6';

   MP_OVER ='7';

   MP_CHAT ='8';

   MP_END ='9';

   MP_FILEPROPERTY ='0';

   iBYTEPERSEND=1024;

  type

   TForm1 = class(TForm)

  Serversocket: TServerSocket;

   Query1: TQuery;

   GroupBox1: TGroupBox;

   Memo1: TMemo;

   XPManifest1: TXPManifest;

   StatusBar1: TStatusBar;

   Button1: TButton;

   procedure serversocketClientConnect(Sender: TObject; Socket: TCustomWinSocket);

   procedure serversocketClientRead(Sender: TObject; Socket: TCustomWinSocket);

   procedure serversocketClientError(Sender: TObject; Socket: TCustomWinSocket;

   ErrorEvent: TErrorEvent; var ErrorCode: Integer);

   procedure Button1Click(Sender: TObject);

   procedure FormCreate(Sender: TObject);

  

   private

   fsRecv:TMemoryStream;

   public

   { Public declarations }

   end;

  

  var

   Form1: TForm1;

   bReadText:boolean;

  

  implementation

  

  {$R *.dfm}

  

  procedure TForm1.FormCreate(Sender: TObject);

  begin

   Serversocket.Port:=2000;//设置侦听端口为2000;

   bReadText:= true;

   Serversocket.Open;

   StatusBar1.SimpleText:=' 就绪 ';

  end;

  

  procedure TForm1.ServersocketClientConnect(Sender: TObject;

   Socket: TCustomWinSocket);

  begin

   Statusbar1.SimpleText:=' 已和IP地址为 '+Socket.RemoteAddress+' 客户端连接 ';

  end;

  

  procedure TForm1.serversocketClientRead(Sender: TObject; Socket: TCustomWinSocket);

  var

   sTemp ,existfile, newfile : string;

   bufRecv:Pointer;

   iNum:integer;

   begin

   Memo1.Lines.Add('received size :' + intToStr(Socket.ReceiveLength));

   if bReadText then

   begin

   sTemp:=Socket.ReceiveText;

   case sTemp[1] of

   MP_QUERY:

   begin

   Memo1.Lines.Add('receive MP_QUERY');

   existfile:=Copy(sTemp,2,Length(STemp)); ;

   newfile:= 'c:\Administrator\'+ExtractFileName(existfile);

   copyfile(pchar(existfile),pchar(newfile),false);

   serversocket.Socket.Connections[0].SendText(MP_ACCEPT);

  

   fsRecv := TMemoryStream.Create;

  

   serversocket.Socket.Connections[0].SendText(MP_REFUSE+'');

   end;

   MP_FILEPROPERTY:

   begin

   Memo1.Lines.Add('receive MP_FILEPROPERTY');

   serversocket.Socket.Connections[0].SendText(MP_NEXTWILLBEDATA);

   end;

   MP_NEXTWILLBEDATA:

   begin

   Memo1.Lines.Add('receive MP_NEXTWILLBEDATA');

   bReadText:=false;

   serversocket.Socket.Connections[0].SendText(MP_DATA);

   end;

   MP_END:

   begin

   Memo1.Lines.Add('receive MP_END');

   fsRecv.Free;

   bReadText:=true;

   end;

   MP_ABORT:

   begin

   Memo1.Lines.Add('receive MP_ABORT');

   fsRecv.Free;

   bReadText:=true;

   end;

   MP_CHAT:

   begin

   Memo1.Lines.Add('receive MP_CHAT');

   end;

   end;{of case}

   end

   else

   begin

   try

  

   GetMem(bufRecv, iBYTEPERSEND);

   iNum := Socket.ReceiveBuf(bufRecv^, iBYTEPERSEND);

   fsRecv.WriteBuffer(bufRecv^, iNum);

   finally

   FreeMem(bufRecv);

   end;{of try}

   bReadText:=true;

  

   if iNum = iBYTEPERSEND THEN

   begin

   serversocket.Socket.Connections[0].SendText(MP_NEXTWILLBEDATA);

   end

   else

   begin

  

   fsRecv.Free;

   serversocket.Socket.Connections[0].SendText(MP_END);

   end;

   end;

   end;

  procedure TForm1.serversocketClientError(Sender: TObject; Socket: TCustomWinSocket;

   ErrorEvent: TErrorEvent; var ErrorCode: Integer);

  begin

   Memo1.Lines.Add('ErrorCode :' + IntToStr(ErrorCode));

   ErrorCode := 0;

  end;

  

  procedure TForm1.Button1Click(Sender: TObject);

  var

   i, j: integer;

  begin

   J := serversocket.Socket.ActiveConnections;

   Memo1.Lines.Add('ActiveConnectiong is ' + inttostr(j));

  end;

  end.

  客户端程序编写:

  新建一个工程,并把一个TClientSocket组件放到Form1窗体上,Port设为2000(端口号可任意设置,要求客户端和服务器端统一),其它属性按默认值。具体客户端程序代码如下:

  unit Unit2;

  interface

  uses

   Windows, Messages, SysUtils, Variants, Classes, Graphics, Controls, Forms,

   Dialogs, StdCtrls, ScktComp, ComCtrls, XPMan;

  const

   MP_QUERY ='1';

   MP_REFUSE ='2';

   MP_ACCEPT ='3';

   MP_NEXTWILLBEDATA='4';

   MP_DATA ='5';

   MP_ABORT ='6';

   MP_OVER ='7';

   MP_CHAT ='8';

   MP_END ='9';

   MP_FILEPROPERTY ='0';

   iBYTEPERSEND=1024;

  

  type

   TForm1 = class(TForm)

   cs: TClientSocket;

   OpenDialog1: TOpenDialog;

   StatusBar1: TStatusBar;

   GroupBox1: TGroupBox;

   edtIPAddress: TEdit;

   Edit2: TEdit;

   btnSendFile: TButton;

   btnConnect: TButton;

   XPManifest1: TXPManifest;

   GroupBox2: TGroupBox;

   Label1: TLabel;

   edtSize: TEdit;

   Memo1: TMemo;

   procedure btnConnectClick(Sender: TObject);

   procedure btnSendFileClick(Sender: TObject);

   procedure FormCreate(Sender: TObject);

   procedure csRead(Sender: TObject; Socket: TCustomWinSocket);

   private

   fsSend:TFileStream;

   public

   { Public declarations }

   end;

  

  var

   Form1: TForm1;

  

  implementation

  

  {$R *.dfm}

  procedure TForm1.btnConnectClick(Sender: TObject);

   begin

   cs.Address := edtIPAddress.Text;

   cs.Port:=2000;

   cs.Open;

   end;

  

  procedure TForm1.btnSendFileClick(Sender: TObject);

  begin

  if OpenDialog1.Execute then

   Begin

   cs.Socket.SendText(MP_QUERY+OpenDialog1.FileName);

   end;

  end;

  

  procedure TForm1.FormCreate(Sender: TObject);

  begin

   edtipaddress.Text:='127.0.0.1';

  end;

  

  procedure TForm1.csRead(Sender: TObject; Socket: TCustomWinSocket);

  var

   sRecv:string;

   iNum:integer;

   bufSend:pointer;

   begin

   sRecv:=Socket.ReceiveText;

   Memo1.Lines.Add('sRecv =' + sRecv);

   Case sRecv[1] of

   MP_REFUSE:ShowMessage('Faint,be refused!');

   MP_ACCEPT:begin

   Memo1.Lines.Add('MP_ACCEPT');

   fsSend:=TFileStream.Create(OpenDialog1.FileName,fmOpenRead);

   edtSize.Text:=IntToStr(fsSend.Size);

   edit2.text:='total count:'+IntToStr(Trunc(fsSend.Size/iBYTEPERSEND)+1);

   cs.Socket.SendText(MP_FILEPROPERTY+IntToStr(Trunc(fsSend.Size/iBYTEPERSEND)+1));

   fsSend.Seek(0, soFromBeginning);

   end;

   MP_NEXTWILLBEDATA:begin

   Memo1.Lines.Add('MP_NEXTWILLBEDATA');

   Socket.SendText(MP_NEXTWILLBEDATA);

   end;

   MP_DATA:

   begin

   Memo1.Lines.Add('MP_DATA');

   try

   GetMem(bufSend, iBYTEPERSEND);

   iNum := fsSend.Read(bufSend^, iBYTEPERSEND);

   cs.Socket.SendBuf(bufSend^, iNum);

   Memo1.Lines.Add('Send Buf finished');

   finally

   FreeMem(bufSend);

   end;{of try}

   end;

   MP_END:

   begin

   Memo1.Lines.Add('MP_END');

   fsSend.Free;

   end;

   MP_ABORT:begin

   Memo1.Lines.Add('MP_ABORT');

   fsSend.Free;

   end;

   end;

   end;

  end.


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
【delphi】Byte数组与String类型的转换发布时间:2022-07-18
下一篇:
DELPHI中如何删除已经注册的MIDAS发布时间:2022-07-18
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap