如何用socket实现文件的传输 我想求教在delphi中,如何用socket来实现文件从客户端发到服务端的,最好有代码参考,谢谢! 解决方案 » 免费领取超大流量手机卡,每月29元包185G流量+100分钟通话, 中国电信官方发货 D6+Win200 下调试通过--------------------点对点文件传输---------------------------采用的协议: 此协议是在前人基础上,在末尾整理了一下,应该没什么问题首先由Client发送MP_QUERY,Server接受到后发送MP_ACCEPT或MP_FEFUESE;Client接受到MP_ACCEPT发送MP_FILEPROPERTY,Server接受到后发送MP_NEXTWILLBEDATA;Client接受到发送MP_NEXTWILLBEDATA,Server接受到后发送MP_DATA;Client接受到MP_DATA,发送数据块,Server接受数据块,Server还没接受完,发送MP_NEXTWILLBEDATA,否则发送MP_ENDClient接受MP_END后,向Server发送MP_END;Server收到MP_END后,停止发送。至此,整个文件传输完毕!----------------------服务器端----------------------------unit Unit1;interfaceuses Windows, Messages, SysUtils, Variants, Classes, Graphics, Controls, Forms, Dialogs, ScktComp, StdCtrls;ConstMP_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) btnstartServer: TButton; Edit1: TEdit; Edit2: TEdit; ss: TServerSocket; SaveDialog1: TSaveDialog; Memo1: TMemo; Button1: TButton; Edit3: TEdit; procedure btnstartServerClick(Sender: TObject); procedure ssClientConnect(Sender: TObject; Socket: TCustomWinSocket); procedure ssClientRead(Sender: TObject; Socket: TCustomWinSocket); procedure ssClientError(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.btnstartServerClick(Sender: TObject);begin ss.Port:=2000;bReadText := true;Edit1.Text:='Server is listening';ss.Open;end;procedure TForm1.ssClientConnect(Sender: TObject; Socket: TCustomWinSocket);begin Edit1.Text:='Server is connected by'+Socket.RemoteAddress;end;procedure TForm1.ssClientRead(Sender: TObject; Socket: TCustomWinSocket);varsTemp: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'); SaveDialog1.FileName:=Copy(sTemp,2,Length(STemp)); if SaveDialog1.Execute then begin// ss.Socket.SendText(MP_ACCEPT); ss.Socket.Connections[0].SendText(MP_ACCEPT); fsRecv := TMemoryStream.Create;// fsRecv:=TFileStream.Create(SaveDialog1.FileName,fmCreate); edit2.Text := SaveDialog1.FileName; end else ss.Socket.Connections[0].SendText(MP_REFUSE+''); end; MP_FILEPROPERTY: begin Memo1.Lines.Add('receive MP_FILEPROPERTY'); ss.Socket.Connections[0].SendText(MP_NEXTWILLBEDATA); end; MP_NEXTWILLBEDATA: begin Memo1.Lines.Add('receive MP_NEXTWILLBEDATA'); bReadText:=false; ss.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 ss.Socket.Connections[0].SendText(MP_NEXTWILLBEDATA); end else begin fsRecv.SaveToFile(SaveDialog1.FileName); fsRecv.Free; ss.Socket.Connections[0].SendText(MP_END); end; end;end;procedure TForm1.ssClientError(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 := ss.Socket.ActiveConnections; Memo1.Lines.Add('ActiveConnectiong is ' + inttostr(j)); for I:= 0 to j- 1 do ss.Socket.Connections[i].SendText(edit3.Text)end;procedure TForm1.FormCreate(Sender: TObject);begin ss.Port:=2000;bReadText := true;Edit1.Text:='Server is listening';ss.Open;end;end.----------------------客户端----------------------------unit clientSocketu;interfaceuses Windows, Messages, SysUtils, Variants, Classes, Graphics, Controls, Forms, Dialogs, StdCtrls, ScktComp;ConstMP_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) btnConnect: TButton; btnSendFile: TButton; Edit1: TEdit; Edit2: TEdit; cs: TClientSocket; Label1: TLabel; edtIPAddress: TEdit; edtSize: TEdit; OpenDialog1: TOpenDialog; 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);beginif OpenDialog1.Execute then Begin cs.Socket.SendText(MP_QUERY+OpenDialog1.FileName); end;end;procedure TForm1.FormCreate(Sender: TObject);begin edit1.Color:=clBlack; edit1.Font.Color:=clLime;end;procedure TForm1.csRead(Sender: TObject; Socket: TCustomWinSocket);var sRecv:string;// sTemp:string; iNum:integer; bufSend:pointer;begin // GetMem(bufSend,iBytePersend+1); 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); //iBYTEPERSEND琌熌盽秖–Ω塝癳 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);// 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;{of case} end;end. WinSocket编程简单的只要记住有几个客户端对应一些端口和属性就可以了 cs.Socket.SendText(MP_FILEPROPERTY+IntToStr(Trunc(fsSend.Size/iBYTEPERSEND)+1));这句话我看不太明白,能不能帮我解释一下,谢谢! 客户端在传送文件之前,先告诉服务器端文件的大小Trunc(fsSend.Size/iBYTEPERSEND)+1) 求梦幻西游屏幕汉字识别代码 有自主产权组件或软件的兄弟请联系我,有个项目打算一起弄,可行的话一个组件有万把块收入。 dcc32命令行 编译就会报地址错 怎样从文件中读取数据? 关天怎样取得DBGRID中当前记录的序号? const定义的常量可以赋值? 不用ADO控件,直接用代码,如何连接SQLSERVER数据库 怎么样可以知道本机装有sql 2000的服务器名 如何才能让我们的程序同时适用ACCESS和SQL SERVER两种数据库? 为什么我把下面这段代码复制到自己新建的delphi项目里老出错? 有没有类似于java里的vector的数组啊 关于建立类
--------------------点对点文件传输---------------------------采用的协议:
此协议是在前人基础上,在末尾整理了一下,应该没什么问题
首先由Client发送MP_QUERY,Server接受到后发送MP_ACCEPT或MP_FEFUESE;
Client接受到MP_ACCEPT发送MP_FILEPROPERTY,Server接受到后发送MP_NEXTWILLBEDATA;
Client接受到发送MP_NEXTWILLBEDATA,Server接受到后发送MP_DATA;
Client接受到MP_DATA,发送数据块,Server接受数据块,
Server还没接受完,发送MP_NEXTWILLBEDATA,否则发送MP_END
Client接受MP_END后,向Server发送MP_END;
Server收到MP_END后,停止发送。至此,整个文件传输完毕!
----------------------服务器端----------------------------
unit Unit1;interfaceuses
Windows, Messages, SysUtils, Variants, Classes, Graphics, Controls, Forms,
Dialogs, ScktComp, StdCtrls;
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)
btnstartServer: TButton;
Edit1: TEdit;
Edit2: TEdit;
ss: TServerSocket;
SaveDialog1: TSaveDialog;
Memo1: TMemo;
Button1: TButton;
Edit3: TEdit;
procedure btnstartServerClick(Sender: TObject);
procedure ssClientConnect(Sender: TObject; Socket: TCustomWinSocket);
procedure ssClientRead(Sender: TObject; Socket: TCustomWinSocket);
procedure ssClientError(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.btnstartServerClick(Sender: TObject);
begin
ss.Port:=2000;
bReadText := true;
Edit1.Text:='Server is listening';
ss.Open;
end;procedure TForm1.ssClientConnect(Sender: TObject;
Socket: TCustomWinSocket);
begin
Edit1.Text:='Server is connected by'+Socket.RemoteAddress;
end;procedure TForm1.ssClientRead(Sender: TObject; Socket: TCustomWinSocket);
var
sTemp: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');
SaveDialog1.FileName:=Copy(sTemp,2,Length(STemp));
if SaveDialog1.Execute then
begin
// ss.Socket.SendText(MP_ACCEPT);
ss.Socket.Connections[0].SendText(MP_ACCEPT); fsRecv := TMemoryStream.Create;
// fsRecv:=TFileStream.Create(SaveDialog1.FileName,fmCreate);
edit2.Text := SaveDialog1.FileName;
end
else
ss.Socket.Connections[0].SendText(MP_REFUSE+'');
end;
MP_FILEPROPERTY:
begin
Memo1.Lines.Add('receive MP_FILEPROPERTY');
ss.Socket.Connections[0].SendText(MP_NEXTWILLBEDATA);
end;
MP_NEXTWILLBEDATA:
begin
Memo1.Lines.Add('receive MP_NEXTWILLBEDATA');
bReadText:=false;
ss.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
ss.Socket.Connections[0].SendText(MP_NEXTWILLBEDATA);
end
else
begin
fsRecv.SaveToFile(SaveDialog1.FileName);
fsRecv.Free;
ss.Socket.Connections[0].SendText(MP_END);
end;
end;
end;
procedure TForm1.ssClientError(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 := ss.Socket.ActiveConnections;
Memo1.Lines.Add('ActiveConnectiong is ' + inttostr(j));
for I:= 0 to j- 1 do
ss.Socket.Connections[i].SendText(edit3.Text)
end;procedure TForm1.FormCreate(Sender: TObject);
begin
ss.Port:=2000;
bReadText := true;
Edit1.Text:='Server is listening';
ss.Open;
end;
end.----------------------客户端----------------------------
unit clientSocketu;interfaceuses
Windows, Messages, SysUtils, Variants, Classes, Graphics, Controls, Forms,
Dialogs, StdCtrls, ScktComp;
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)
btnConnect: TButton;
btnSendFile: TButton;
Edit1: TEdit;
Edit2: TEdit;
cs: TClientSocket;
Label1: TLabel;
edtIPAddress: TEdit;
edtSize: TEdit;
OpenDialog1: TOpenDialog;
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
edit1.Color:=clBlack;
edit1.Font.Color:=clLime;
end;procedure TForm1.csRead(Sender: TObject; Socket: TCustomWinSocket);
var
sRecv:string;
// sTemp:string;
iNum:integer;
bufSend:pointer;
begin
// GetMem(bufSend,iBytePersend+1);
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);
//iBYTEPERSEND琌熌盽秖–Ω塝癳
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);
// 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;{of case}
end;
end.
一些端口和属性就可以了
这句话我看不太明白,能不能帮我解释一下,谢谢!