急求局域网内点对点的文件传输代码,,(socket)

--------------------点对点文件传输---------------------------采用的协议：
此协议是在前人基础上，在末尾整理了一下，应该没什么问题
首先由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.
点对点文件传输程序！
   Delphi功能强大，用Delphi写软件，可以大大缩短软件的开发周期。关于点对点传文件的基本思路，就是一个服务器软件，一个客户端软件，使用同一个端口，待连接上以后，客户端给服务器发送一个请求，包括待传的文件的文件名，大小等，如果服务器接受，就开始传文件。当然，文件传输的时候可以有两种模式，ASCII码和Bin，不过一般通用Bin 就可以了。基于上面的讨论，本来用Delphi4的NMStrm，NMStrmServ 控件就可以完成，但是我测试过了，NMStrm控件对于较小的文件还可以使用，而且很方便，但是如果文件一大(1M)就会出错。所以接下来我们利用Delphi中TServerSocket和TClientSocket写这个程序由于以太包大小的限制以及DelphiSocket的处理机制(Delphi中，当你用一个Socket发送一个较大的Stream，接受方会激发多次OnRead事件，Delphi她只保证多次OnRead事件中每次数据的完整，而不会自己收集数据并返回给用户。所以不要以为你把待传文件在一个Socket中Send一次，另一个中Recv一次就可以了。你必须自己收集数据或自己定义协议。)，所以我们采用自定义协议的方法。定义协议的规范方法是利用Record End。如：
TMyFileProtocol=Record
sSendType=(ST_QUERY,ST_REFUSE,ST_DATA,ST_ABORT,...);
iLength:integer;
bufSend:Buffer;
End;
　　我曾试过这个办法，但失败了，而且我一直认为我的方法是正确的，但程序一直编译通不过，估计是Delphi有问题:) 所以我在下列的范例程序中利用另外一种办法。Socket 类中有两属性ReceiveText和ReceiveBuf，在一个OnRead事件中，只能使用一次该两属性，所以我们可以利用一个全程变量来保存是该读Text还是Buf，也就是说读一次Text，再都一次Buf，这就模拟了TMyFileProtocol。
开始程序：
写一个最简单的，主要用于讲解方法。
定义协议：
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’;
协议简介：
首先由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接受数据，并发送MP_NEXTWILLBEDATA；
循环，直到Client发送MP_OVER；
中间可以互相发送MP_CHAT+String；
Server程序：
放上以下控件:SaveDialog1,btnStartServer,
ss,(TServerSocket)
btnStartServer.OnClick(Sender:TObject);
begin
ss.Port:=2000;
ss.Open;
end;
ss.OnClientRead(Sender: TObject;Socket: TCustomWinSocket);
var
sTemp:string;
bufRecv:Pointer;
iRecvLength:integer;
begin
if bReadText then
begin
sTemp:=Socket.ReceiveText;
case sTemp[1] of
MP_QUERY:begin
//在这里拒绝
SaveDialog1.FileName:=Copy(sTemp,2,Length(STemp));
if SaveDialog1.Execute then
begin
Socket.SendText(MP_ACCEPT);
fsRecv:=TFileStream.Create(SaveDialog1.FileName,fmCreate);
end
else Socket.SendText(MP_REFUSE+’去死’);
end;
MP_FILEPROPERTY:begin
//要发送StrToInt(Copy(sTemp,2,Length(sTemp))) 次
//时间进度显示
Socket.SendText(MP_NEXTWILLBEDATA);
end;
MP_NEXTWILLBEDATA:begin
Socket.SendText(MP_DATA);
bReadText:=false;
end;
MP_END:begin
fsRecv.Free
bReadText:=true;
end;
MP_ABORT:begin
fsRecv.Free;
bReadText:=true;
end;
MP_CHAT:begin
//Chat Msg
end;
end;{of case}
end
else begin
try
GetMem(bufRecv,2000);//2000 must >iBYTESEND
Socket.ReceiveBuf(bufRecv^,iRecvLength);
fsRecv.WriteBuffer(bufRecv^,iRecvLength);
finally
FreeMem(bufRecv,2000);
end;{of try}
bReadText:=true;
Socket.SendText(MP_NEXTWILLBEDATA);
end;
end;
Client程序：
放上以下控件：edtIPAddress,OpenDialog1,btnConnect,btnSendFile,
cs. (TClientSocket)
btnConnect.OnClick(Sender:TObject);
begin
cs.Address:=edtIPAddress.Text;
cs.Port:=2000;
cs.Connect;
end;
btnSendFile.OnClick(Sender:TObject);
begin
if OpenDialog1.Execute then
Begin
cs.Socket.SendText(MP_QUERY+OpenDialog1.FileName);//FileSize???
end;
end;
cs.OnRead(Sender: TObject;Socket: TCustomWinSocket);
var
sTemp:string;
bufSend:pointer;
begin
sRecv:=Socket.ReceiveText;
Case sRecv[1] of
MP_REFUSE:ShowMessage(’Faint,be refused!’);
MP_ACCEPT:begin
fsSend:=TFileStream.Create(OpenDialog1.FileName,fmOpen);
//iBYTEPERSEND是个常量，每次发送包的大小。
Socket.SendText(MP_FILEPROPERTY+Trunc(fsSend.Size/iBYTEPERSEND)+1);
end;
MP_NEXTWILLBEDATA:begin
Socket.SendText(MP_NEXTWILLBEDATA);
end;
MP_DATA:begin
try
GetMem(bufSend,iBYTEPERSEND+1);
if (fsSend.Position+1+iBYTEPERSEND) < fsSend.Size then
begin
fsSend.Read(bufSend^,iBYTEPERSEND);
Socket.SendBuf(bufSend^,iBYTEPERSEND);
fsSend.Free;
end//普通的发送，大小为iBYTEPERSEND
else begin
fsSend.Read(bufSend^,fsSend.Size-fsSend.Position-1);
Socket.SendBuf(bufSend^,fsSend.Size-fsSend.Position-1);
end;//最后一次发送，发送剩余的数据
finally
FreeMem(bufSend,iBYTEPERSEND+1);
end;{of try}
end;
MP_ABORT:begin
//被取消了:(
fsSend.Free;
end;
end;{of case}
end;
整理程序：
　　加入错误判断，优化程序，把Server和Client联合在一起，加入剩余时间进度显示，做成能一次传多个文件，加入聊天功能，就成了一个很好的点对点传文件的程序。

调试易

急求局域网内点对点的文件传输代码,,(socket)

解决方案 »