Delphi ServerSocket,ClientSocket示例 2008-05-09 16:20
| Delphi TServerSocket,TClientSocket实现传送文件代码 1.建立两个工程Server及Client， 分别放TServerSocket及TClientSocket控件,Demo,Edit控件等。 2.设置TServerSocket name为 SS, ServerType为stNonBlocking,TClientSocket name为cs,ClientType为ctNonBlocking表示异步读写信息。注意ClientType和ServerType要相一致.若为ctBlocking则表示同步读写信息。(相一致，这点相当重要！香巴拉～) 3.Socket传送文件的顺序图 a)Client-->Server MP_QUERY b)Server-->Client MP_ACCEPT c) Client-->Server MP_FileProperty d)Server-->Client MP_NextWillBeData e)Client-->Server MP_NextWillBeData f)Server-->Client MP_DATA g) Client-->Server 发送数据 h) Server接收数据并处理 i)Client-->Server MP_END结束 4.Client端代码 unit UnitClient; interface uses Windows, Messages, SysUtils, Classes, Graphics, Controls, Forms, Dialogs, ScktComp, StdCtrls, Buttons, ExtCtrls, ComCtrls; Const //设置协议标志符 //标志将要发送文件名 MP_QUERY ='aaaaa'; //标志服务器拒绝接收 MP_REFUSE ='bbbbb'; //标志服务器同意接收文件 MP_ACCEPT ='ccccc'; //标志将要传递数据 MP_NEXTWILLBEDATA='https://www.it610.com/article/ddddd'; //标志服务器端准备接收数据 MP_DATA ='https://www.it610.com/article/eeeee'; //标志客户端取消了本次发送操作 MP_ABORT ='fffff'; //标志已经发送完毕 MP_END='iiiii'; //标志发送的文件长度 MP_FILEPROPERTY='jjjjj'; //指定每次发送包的大小 iBYTEPERSEND=1024; type TForm1 = class(TForm) OpenDialog1: TOpenDialog; cs: TClientSocket; Panel1: TPanel; btnSendFile: TBitBtn; edtIPAddress: TEdit; Memo1: TMemo; edtHostName: TEdit; RB1: TRadioButton; RB2: TRadioButton; ProBar: TProgressBar; Btncancel: TBitBtn; Btnexit: TBitBtn; procedure btnSendFileClick(Sender: TObject); procedure csRead(Sender: TObject; Socket: TCustomWinSocket); procedure FormCreate(Sender: TObject); procedure BtncancelClick(Sender: TObject); procedure BtnexitClick(Sender: TObject); private //定义一个发送文件的数据流 fsSend: TFileStream; //设置开始状态位 tStart:Boolean; //标识当前时间 TickCount:Longword; { Private declarations } public { Public declarations } end; var Form1: TForm1; implementation {$R *.DFM} //发送文件 procedure TForm1.btnSendFileClick(Sender: TObject); begin //关闭套接字连接 cs.Close; //初始化进程条 Probar.Position:=0; if RB1.Checked then begin cs.Host:=''; //指定要连接的主机IP地址 cs.Address:=edtIPAddress.Text; end else //指定要连接的主机名 cs.Host:=edtHostName.Text; //要连接的主机所用端口号 cs.Port:=2000; //打开套接字连接 cs.Open; //点击发送确认按钮 if OpenDialog1.Execute then Begin //发送连接请求 cs.Socket.SendText(MP_QUERY+OpenDialog1.FileName); end; end; //客户端接收来自服务器端的信息 procedure TForm1.csRead(Sender: TObject; Socket: TCustomWinSocket); var MsgRecv:string; bufSend:pointer; iLength:Integer; begin //得到客户端发来的信息 MsgRecv:=Socket.ReceiveText; //取前5位，得到协议标志符 MsgRecv:=copy(MsgRecv,1,5); //接收到拒绝信息 if MsgRecv=MP_REFUSE then memo1.Lines.Add('连接请求被拒绝!') //接收到确认接收信息 else if MsgRecv=MP_ACCEPT then begin //为要发送的文件创建文件流 fsSend:=TFileStream.Create(OpenDialog1.FileName,fmOpenRead); tStart:=False; //进度条显示 Probar.Max:=fsSend.Size; memo1.Lines.Add('开始发送!'); //获取发送开始时的时间 TickCount:=GetTickCount; //创建文件流并发送文件长度。 Socket.SendText(MP_FILEPROPERTY+inttostr(Trunc(fsSend.Size/iBYTEPERSEND)+1)); end else if MsgRecv=MP_NEXTWILLBEDATA then begin //通知接收端将要传送数据。 Socket.SendText(MP_NEXTWILLBEDATA); end else if MsgRecv=MP_DATA then begin //接收到确认信息，开始发送数据。 if not tStart then begin memo1.Lines.Add('发送数据中... ...'); tStart:=True; end; //还有数据没有发送。 if fsSend.Position< fsSend.Size-1 then begin iLength:=fsSend.Size-1-fsSend.Position; //将数据分段发送 if iLength>iBYTEPERSEND then iLength:=iBYTEPERSEND; GetMem(bufSend,iLength+1); try //读取文件流数据 fsSend.Read(bufSend^,iLength); //发送长度为iLength的数据 Socket.SendBuf(bufSend^,iLength); //进度条显示 Probar.Position:=fsSend.Position; finally //释放内存 FreeMem(bufSend,iLength+1); end; //发送完毕 end else begin //通知主机文件传送结束。 Socket.SendText(MP_END); memo1.Lines.Add('发送完成!'); //获取发送耗时 memo1.Lines.Add('发送耗时'+IntToStr(GetTickCount-TickCount)+'毫秒'); fsSend.Free; end; //取消文件发送过程 end else if MsgRecv=MP_ABORT then begin memo1.Lines.Add('中止!'); //文件传送取消 fsSend.Free; end; end; procedure TForm1.FormCreate(Sender: TObject); begin Memo1.Clear; end; //取消 procedure TForm1.BtncancelClick(Sender: TObject); begin //取消文件发送过程 cs.Socket.SendText(MP_ABORT); end; procedure TForm1.BtnexitClick(Sender: TObject); begin Form1.Close; end; end. 5.Server端代码 unit UnitServer; interface uses Windows, Messages, SysUtils, Classes, Graphics, Controls, Forms, Dialogs, StdCtrls, Buttons, ScktComp, ExtCtrls; Const //设置协议标志符 //标志将要发送文件名 MP_QUERY ='aaaaa'; //标志服务器拒绝接收 MP_REFUSE ='bbbbb'; //标志服务器同意接收文件 MP_ACCEPT ='ccccc'; //标志将要传递数据 MP_NEXTWILLBEDATA='https://www.it610.com/article/ddddd'; //标志服务器端准备接收数据 MP_DATA ='https://www.it610.com/article/eeeee'; //标志客户端取消了本次发送操作 MP_ABORT ='fffff'; //标志已经发送完毕 MP_END='iiiii'; //标志发送的文件长度 MP_FILEPROPERTY='jjjjj'; //指定每次发送包的大小 iBYTEPERSEND=1024; type TForm1 = class(TForm) SaveDialog1: TSaveDialog; ss: TServerSocket; Memo1: TMemo; procedure ssClientRead(Sender: TObject; Socket: TCustomWinSocket); procedure FormCreate(Sender: TObject); procedure FormDestroy(Sender: TObject); private //定义一个接收文件的数据流 fsRecv:TFileStream; //设置开始状态位 tStart:Boolean; //标识当前时间 TickCount:Longword; { Private declarations } public { Public declarations } end; 【delphi|Delphi ServerSocket,ClientSocket示例】var Form1: TForm1; implementation {$R *.DFM} //服务器端接收来自客户端的信息 procedure TForm1.ssClientRead(Sender: TObject; Socket: TCustomWinSocket); var msgr,theFileName:string; bufRecv:Pointer; iLength:Integer; begin //接收到的数据的长度 iLength:=Socket.ReceiveLength; //开辟一块新的内存，用来保存接收到的数据 GetMem(bufRecv,iLength); try //接收数据 Socket.ReceiveBuf(bufRecv^,iLength); //将接收到的数据以字符串的形式存到msgr中 msgr:=StrPas(PChar(bufRecv)); //取前5个字符 msgr:=Copy(msgr,1,5); if msgr=MP_QUERY then begin //去掉字符串前后的空格和控制字符 msgr:=Trim(StrPas(PChar(bufRecv))); //第5个字符后面的字符串为文件名 theFileName:=ExtractFileName(Copy(msgr,6,Length(msgr))); SaveDialog1.Title:='请选择或输入接收到的数据保存到的文件名：'; SaveDialog1.FileName:=theFileName; //点击确认保存按钮 if SaveDialog1.Execute then begin //为需保存的文件创建文件流 fsRecv:=TFileStream.Create(SaveDialog1.FileName,fmCreate); //如果同意接收数据。 memo1.Lines.Add ('开始接收！'); TickCount:=GetTickCount; //发送同意接收文件的信息 Socket.SendText(MP_ACCEPT); tStart:=False; end else //发送拒绝接收文件的信息 Socket.SendText(MP_REFUSE); end else if msgr=MP_FILEPROPERTY then begin //接收文件长度并说明主机可以接收数据了 Socket.SendText(MP_NEXTWILLBEDATA); end else if msgr=MP_NEXTWILLBEDATA then begin //要求发送端发送数据 Socket.SendText(MP_DATA); end else if msgr=MP_END then begin memo1.Lines.Add ('文件传送完成！'); memo1.Lines.Add ('接收耗时'+IntToStr(GetTickCount-TickCount)+'毫秒'); fsRecv.Free; end //接收到文件传送取消信息 else if msgr=MP_ABORT then begin memo1.Lines.Add ('MP_ABORT'); Socket.SendText(MP_ABORT); fsRecv.Free; end else begin if not tStart then begin memo1.Lines.Add('接收数据...'); tStart:=True; end; //将接收缓冲区数据写入文件 fsRecv.WriteBuffer(bufRecv^,iLength); //通知客户端继续发送数据 Socket.SendText(MP_DATA); end; finally //释放内存 FreeMem(bufRecv,iLength); end; end; procedure TForm1.FormCreate(Sender: TObject); begin Memo1.Clear; //设置的监听端口 ss.Port:=2000; //开始监听 ss.Open; end; procedure TForm1.FormDestroy(Sender: TObject); begin ss.Close; end; end. |
推荐阅读
- Linux操作系统的学习|Linux 终端修改分辨率
- Linux操作系统的学习|Linux系统查看文件目录路径和切换目录命令大全
- JavaWeb|web站点的欢迎页面
- 服务器|彻底搞懂Cookie、Session、JWT和Token（强烈推荐）《彻底搞懂Cookie、Session、JWT和Token｜CSDN创作打卡》
- GBASE培训|认证培训 | GBase 8s 11月培训训练营圆满结束
- 环境配置|Cent OS7安装JDK8,超详细
- 计算机网络|网络编程实战之高级篇, 彻底解决面试C10k问题, 高并发服务器, IO多路复用, 同时监视多个IO事件
- 极客日报|B站回应“让用户卖隐私换会员”质疑；UI设计软件Figma封停大疆等公司账号；Arch Linux 诞生二十年|极客头条
- Linux操作系统|服务器如何部署并启动前后端分离(springboot+vue)的web项目