开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > Internet/网络编程 > Ftp服务器 > 查看源码
Unit1.~pas
资源名称：tftp_delphi.rar　[点击查看]
上传用户：wshicoco
上传日期：2009-03-23
资源大小：1150k
文件大小：15k
源码类别：

Ftp服务器

开发平台：

Delphi

Unit1.~pas：源码内容
  1. unit Unit1;
  3. interface
  5. uses
  6.   Windows, Messages, SysUtils, Variants, Classes, Graphics, Controls, Forms,
  7.   Dialogs, StdCtrls, ComCtrls, ExtCtrls, IdBaseComponent, IdComponent,
  8.   IdUDPBase, IdUDPServer, IdUDPClient,IdSocketHandle, IdIPWatch;
  10. type
  11.   TForm1 = class(TForm)
  12.     PageControl1: TPageControl;
  13.     TabSheet1: TTabSheet;
  14.     TabSheet2: TTabSheet;
  15.     TabSheet3: TTabSheet;
  16.     apply_button: TButton;
  17.     Label1: TLabel;
  18.     Label2: TLabel;
  19.     Label3: TLabel;
  20.     Label4: TLabel;
  21.     locIP_edit: TEdit;
  22.     locPort_edit: TEdit;
  23.     remoteIP_edit: TEdit;
  24.     remotePort_edit: TEdit;
  25.     read_button: TButton;
  26.     StatusBar: TStatusBar;
  27.     write_button: TButton;
  28.     Timer1: TTimer;
  29.     logmemo: TMemo;
  30.     path_edit: TEdit;
  31.     browse_button: TButton;
  32.     OpenDialog1: TOpenDialog;
  33.     client: TIdUDPServer;
  34.     cancel_button: TButton;
  35.     stop_button: TButton;
  36.     trace_button: TButton;
  37.     IPWatch: TIdIPWatch;
  38.     clear_Button: TButton;
  39.     save_button: TButton;
  40.     procedure FormCreate(Sender: TObject);
  41.     procedure apply_buttonClick(Sender: TObject);
  42.     procedure read_buttonClick(Sender: TObject);
  43.     procedure browse_buttonClick(Sender: TObject);
  44.     procedure write_buttonClick(Sender: TObject);
  45.     procedure clientUDPRead(Sender: TObject; AData: TStream;
  46.       ABinding: TIdSocketHandle);
  47.     procedure cancel_buttonClick(Sender: TObject);
  48.     procedure stop_buttonClick(Sender: TObject);
  49.     procedure Timer1Timer(Sender: TObject);
  50.     procedure trace_buttonClick(Sender: TObject);
  51.     procedure clear_ButtonClick(Sender: TObject);
  52.     procedure save_buttonClick(Sender: TObject);
  53.   private
  54.     { Private declarations }
  55.   public
  56.     { Public declarations }
  57.   end;
  58. type
  59.   rflip=record
  60.     a1:byte;
  61.     a2:byte;
  62.   end;
  63.   frame=record
  64.     op:word;
  65.     info:array[1..514]of byte;
  66.   end;
  68. var
  69.   Form1: TForm1;
  70.   remoteIP:string;
  71.   remoteport:integer;
  72.   locport:integer;
  73.   transmode,last:boolean;
  74.   filename:string;
  75.   transFrame,recFrame:frame;
  76.   from_file,to_file:file;
  77.   ack_NO,block_NO:word;
  78.   numwrite,numread:integer;
  79.   require1,require2,trans:boolean;
  80.   reqcount,transcount:longint;
  81.   count:longint;
  82.   starttime:longint;
  83.   timeready,trace,acktran:boolean;
  84. implementation
  86. {$R *.dfm}
  88. function selfinc(a:word):word;
  89. var
  90.   x:word;
  91. begin
  92.   x:=a;
  93.   if x=65535 then selfinc:=0
  94.   else begin
  95.     x:=x+1;
  96.     selfinc:=x;
  97.   end;
  98. end;
  100. function flipout(orig:word):rflip;
  101. var
  102.   a:byte;
  103.   s:rflip;
  104. begin
  105.   s:=rflip(orig);
  106.   a:=s.a1;
  107.   s.a1:=s.a2;
  108.   s.a2:=a;
  109.   flipout:=s;
  110. end;
  112. function flipin(a1,a2:byte):word;
  113. var
  114.   a:rflip;
  115. begin
  116.   a.a1:=a2;
  117.   a.a2:=a1;
  118.   flipin:=word(a);
  119. end;
  121. procedure TForm1.FormCreate(Sender: TObject);
  122. begin
  123.   statusbar.Panels.Items[0].Text:='空闲';
  124.   remoteIP:='127.0.0.1';
  125.   remoteport:=1000;
  126.   locport:=1000;
  127.   opendialog1.InitialDir:=getcurrentdir;
  128.   block_NO:=0;
  129.   ack_NO:=0;
  130.   require1:=false;
  131.   require2:=false;
  132.   trans:=false;
  133.   reqcount:=0;
  134.   transcount:=0;
  135.   timeready:=false;
  136.   trace:=false;
  137.   acktran:=false;
  138.   locIP_edit.Text:=IPWatch.LocalIP;
  139. end;
  141. procedure TForm1.apply_buttonClick(Sender: TObject);
  142. begin
  143.   client.Active:=false;
  144.   locport:=strtoint(locPort_edit.Text);
  145.   remoteIP:=remoteIP_edit.Text;
  146.   remotePort:=strtoint(remotePort_edit.Text);
  147.   write_button.Enabled:=true;
  148.   read_button.Enabled:=true;
  149.   client.DefaultPort:=locport;
  150.   client.Bindings.Add;
  151.   client.Bindings.Items[0].Port:=locport;
  152.   client.Active:=true;
  153.   apply_button.Enabled:=false;
  154.   stop_button.Enabled:=true;
  155.   statusbar.Panels.Items[0].Text:='目标绑定';
  156.   logmemo.Lines.Append(datetostr(date)+' '+timetostr(now));
  157.   logmemo.Lines.Append('绑定远程目标：'+remoteIP+'端口 '+inttostr(remoteport));
  158. end;
  160. procedure TForm1.read_buttonClick(Sender: TObject);
  161. begin
  162.   stop_button.Enabled:=false;
  163.   read_button.Enabled:=false;
  164.   write_button.Enabled:=false;
  165.   browse_button.Enabled:=true;
  166.   cancel_button.Enabled:=true;
  167.   browse_button.Caption:='确定';
  168.   path_edit.Enabled:=true;
  169.   transmode:=true;
  170. end;
  172. procedure TForm1.browse_buttonClick(Sender: TObject);
  173. var
  174.   i,j:integer;
  175. const
  176.   mode='octet';
  177. begin
  178.   if transmode then
  179.   begin
  180.     starttime:=0;
  181.     timeready:=true;
  182.     count:=0;
  183.     browse_button.Enabled:=false;
  184.     cancel_button.Enabled:=false;
  185.     filename:=path_edit.Text;
  186.     transframe.op:=word(flipout(1));
  187.     for i:=1 to length(filename) do
  188.       transframe.info[i]:=ord(filename[i]);
  189.     transframe.info[length(filename)+1]:=0;
  190.     for j:=length(filename)+2 to length(filename)+7 do
  191.       transframe.info[j]:=ord(mode[j-length(filename)-1]);
  192.     transframe.info[length(filename)+7]:=0;
  193.     client.SendBuffer(remoteIP,remotePort,transframe,length(filename)+9);
  194.     filename:=getcurrentdir+''+filename;
  195.     assignfile(to_file,filename);
  196.     rewrite(to_file,1);
  197.     require1:=true;
  198.     reqcount:=0;
  199.     statusbar.Panels.Items[0].Text:='读文件请求';
  200.     logmemo.Lines.Append(datetostr(date)+' '+timetostr(now));
  201.     logmemo.Lines.Append('RRQ to    '+remoteIP);
  202.     logmemo.text:=logmemo.Text+'01';
  203.     for i:=1 to 514 do
  204.       if transframe.info[i]<>0 then
  205.         logmemo.text:=logmemo.Text+(chr(transframe.info[i]))
  206.       else break;
  207.     logmemo.Text:=logmemo.Text+'0octet0';
  208.   end
  209.   else begin
  210.     if opendialog1.Execute then
  211.     begin
  212.       starttime:=0;
  213.       timeready:=true;
  214.       browse_button.Enabled:=false;
  215.       cancel_button.Enabled:=false;
  216.       filename:=opendialog1.FileName;
  217.       path_edit.Text:=filename;
  218.       for i:=length(fileName) downto 1 do
  219.       if fileName[i]='' then
  220.         break;
  221.       j:=1;
  222.       while i<length(filename) do
  223.       begin
  224.         transframe.info[j]:=ord(filename[i+1]);
  225.         i:=i+1;
  226.         j:=j+1;
  227.       end;
  228.       transframe.info[j]:=0;
  229.       for i:=j+1 to j+6 do
  230.         transframe.info[i]:=ord(mode[i-j]);
  231.       transframe.info[j+6]:=0;
  232.       transframe.op:=word(flipout(2));
  233.       client.SendBuffer(remoteIP,remotePort,transframe,j+8);
  234.       assignfile(from_file,filename);
  235.       reset(from_file,1);
  236.       last:=false;
  237.       require2:=true;
  238.       reqcount:=0;
  239.       statusbar.Panels.Items[0].Text:='写文件请求';
  240.       count:=0;
  241.       logmemo.Lines.Append(datetostr(date)+' '+timetostr(now));
  242.       logmemo.Lines.Append('WRQ to    '+remoteIP);
  243.       logmemo.text:=logmemo.Text+'02';
  244.       for i:=1 to 514 do
  245.       if transframe.info[i]<>0 then
  246.         logmemo.text:=logmemo.Text+(chr(transframe.info[i]))
  247.       else break;
  248.       logmemo.Text:=logmemo.Text+'0octet0';
  249.     end;
  250.   end;
  251. end;
  253. procedure TForm1.write_buttonClick(Sender: TObject);
  254. begin
  255.   stop_button.Enabled:=false;
  256.   read_button.Enabled:=false;
  257.   write_button.Enabled:=false;
  258.   browse_button.Enabled:=true;
  259.   cancel_button.Enabled:=true;
  260.   browse_button.Caption:='浏览';
  261.   path_edit.Enabled:=false;
  262.   transmode:=false;
  263.   
  264. end;
  266. procedure TForm1.clientUDPRead(Sender: TObject; AData: TStream;
  267.   ABinding: TIdSocketHandle);
  268. var
  269.   i:integer;
  270.   temp:array[1..512] of byte;
  271. begin
  272.   adata.ReadBuffer(recframe,adata.Size);
  273.   case word(flipout(recframe.op)) of
  274.   3:begin
  275.     if (flipin(recframe.info[1],recframe.info[2])=selfinc(ack_NO)) then
  276.     begin
  277.       statusbar.Panels.Items[0].Text:='接收文件';
  278.       require1:=false;
  279.       acktran:=false;
  280.       for i:=1 to adata.Size-4 do
  281.         temp[i]:=recframe.info[i+2];
  282.       blockwrite(to_file,temp,adata.size-4,numwrite);
  283.       count:=count+numwrite;
  284.       if trace then begin
  285.       logmemo.Lines.Append(datetostr(date)+' '+timetostr(now));
  286.       logmemo.Lines.Append('Data to local    ');
  287.       logmemo.text:=logmemo.Text+'03'+inttostr(recframe.info[1])+inttostr(recframe.info[2]);
  288.       logmemo.Text:=logmemo.Text+'   信息长度  '+inttostr(numwrite)+'  byte';
  289.       end;
  290.       ack_NO:=ack_NO+1;
  291.       transframe.op:=word(flipout(4));
  292.       transframe.info[1]:=flipout(ack_NO).a1;
  293.       transframe.info[2]:=flipout(ack_NO).a2;
  294.       client.SendBuffer(remoteIP,remotePort,transframe,4);
  295.       acktran:=true;
  296.       reqcount:=0;
  297.       if trace then begin
  298.       logmemo.Lines.Append(datetostr(date)+' '+timetostr(now));
  299.       logmemo.Lines.Append('ACK to '+remoteIP+'    ');
  300.       logmemo.text:=logmemo.Text+'04'+inttostr(transframe.info[1])+inttostr(transframe.info[2]);
  301.       end;
  302.       if numwrite<512 then
  303.       begin
  304.         closefile(to_file);
  305.         numwrite:=0;
  306.         ack_NO:=0;
  307.         read_button.Enabled:=true;
  308.         write_button.Enabled:=true;
  309.         stop_button.Enabled:=true;
  310.         path_edit.Enabled:=false;
  311.         statusbar.Panels.Items[0].Text:='接收完毕';
  312.         logmemo.Lines.Append('文件接受完毕');
  313.         timeready:=false;
  314.         acktran:=false;
  315.       end;
  316.     end;
  317.   end;
  318.   4:begin
  319.     if (flipin(recframe.info[1],recframe.info[2])=block_NO) then
  320.     begin
  321.       trans:=false;
  322.       if last then block_NO:=0
  323.       else begin
  324.         if trace then begin
  325.           logmemo.Lines.Append(datetostr(date)+' '+timetostr(now));
  326.           logmemo.Lines.Append('ACK to local   ');
  327.           logmemo.text:=logmemo.Text+'04'+inttostr(recframe.info[1])+inttostr(recframe.info[2]);
  328.         end;
  329.         statusbar.Panels.Items[0].Text:='发送文件';
  330.         require2:=false;
  331.         block_NO:=block_NO+1;
  332.         blockread(from_file,temp,512,numread);
  333.         transframe.op:=word(flipout(3));
  334.         transframe.info[1]:=flipout(block_NO).a1;
  335.         transframe.info[2]:=flipout(block_NO).a2;
  336.         for i:=3 to numread+2 do
  337.         transframe.info[i]:=temp[i-2];
  338.         client.SendBuffer(remoteIP,remotePort,transframe,numread+4);
  339.         trans:=true;
  340.         reqcount:=0;
  341.         if trace then begin
  342.           logmemo.Lines.Append(datetostr(date)+' '+timetostr(now));
  343.           logmemo.Lines.Append('Data to '+remoteIP+'   ');
  344.           logmemo.text:=logmemo.Text+'03'+inttostr(transframe.info[1])+inttostr(transframe.info[2]);
  345.           logmemo.Text:=logmemo.Text+' 信息长度  '+inttostr(numread)+'  byte';
  346.         end;
  347.         if numread<512 then
  348.         begin
  349.           statusbar.Panels.Items[0].Text:='发送完毕';
  350.           logmemo.Lines.Append('文件发送完毕');
  351.           closefile(from_file);
  352.           last:=true;
  353.           numread:=0;
  354.           cancel_button.Enabled:=true;
  355.           read_button.Enabled:=true;
  356.           write_button.Enabled:=true;
  357.           stop_button.Enabled:=true;
  358.           timeready:=false;
  359.         end;
  360.         count:=count+numread;
  361.       end;
  362.     end;
  363.   end;
  364.   5:begin
  365.     logmemo.Lines.Append('error: code='+inttostr(flipin(recframe.info[1],recframe.info[2])));
  366.     require1:=false;
  367.     case flipin(recframe.info[1],recframe.info[2]) of
  368.     0:begin
  369.        filename:='';
  370.        for i:=3 to adata.Size-2 do
  371.          filename:=filename+chr(recframe.info[i]);
  372.        showmessage(filename);
  373.     end;
  374.     1: showmessage('File not found.');
  375.     2: showmessage('Access violation.');
  376.     3: showmessage('Disk full or allocation exceeded.');
  377.     4: showmessage('Illegal TFTP operation.');
  378.     5: showmessage('Unknown transfer ID.');
  379.     6: showmessage('File already exists.');
  380.     7: showmessage('No such user.');
  381.     end;
  382.     block_NO:=0;
  383.     ack_NO:=0;
  384.     read_button.Enabled:=true;
  385.     write_button.Enabled:=true;
  386.     cancel_button.Enabled:=true;
  387.     stop_button.Enabled:=true;
  388.   end;
  389.   end;
  390. end;
  392. procedure TForm1.cancel_buttonClick(Sender: TObject);
  393. begin
  394.   statusbar.Panels.Items[0].Text:='空闲';
  395.   browse_button.Enabled:=false;
  396.   cancel_button.Enabled:=false;
  397.   path_edit.Enabled:=false;
  398.   read_button.Enabled:=true;
  399.   write_button.Enabled:=true;
  400.   stop_button.Enabled:=true;;
  401. end;
  403. procedure TForm1.stop_buttonClick(Sender: TObject);
  404. begin
  405.   stop_button.Enabled:=false;
  406.   apply_button.Enabled:=true;
  407.   client.Active:=false;
  408.   client.Bindings.Items[0].Free;
  409.   statusbar.Panels.Items[0].Text:='空闲';
  410. end;
  412. procedure TForm1.Timer1Timer(Sender: TObject);
  413. var
  414.   i:integer;
  415.   v:real;
  416. begin
  417.   if require1 then
  418.   begin
  419.     reqcount:=reqcount+1;
  420.     for i:=1 to 512 do
  421.       if transframe.info[i]=0 then break;
  422.     client.SendBuffer(remoteIP,remotePort,transframe,i+8);
  423.     if reqcount=5 then
  424.     begin
  425.       showmessage('连接主机超时');
  426.       logmemo.Lines.Append(datetostr(date)+' '+timetostr(now));
  427.       logmemo.Lines.Append('连接主机超时');
  428.       block_NO:=0;
  429.       ack_NO:=0;
  430.       read_button.Enabled:=true;
  431.       write_button.Enabled:=true;
  432.       cancel_button.Enabled:=true;
  433.       stop_button.Enabled:=true;
  434.       require1:=false;
  435.       statusbar.Panels.Items[0].Text:='重置';
  436.     end;
  437.   end;
  438.   if require2 then
  439.   begin
  440.     reqcount:=reqcount+1;
  441.     for i:=1 to 512 do
  442.       if transframe.info[i]=0 then break;
  443.     client.SendBuffer(remoteIP,remotePort,transframe,i+8);
  444.     if reqcount=5 then
  445.     begin
  446.       showmessage('连接主机超时');
  447.       logmemo.Lines.Append(datetostr(date)+' '+timetostr(now));
  448.       logmemo.Lines.Append('连接主机超时');
  449.       statusbar.Panels.Items[0].Text:='重置';
  450.       block_NO:=0;
  451.       ack_NO:=0;
  452.       read_button.Enabled:=true;
  453.       write_button.Enabled:=true;
  454.       cancel_button.Enabled:=true;
  455.       stop_button.Enabled:=true;
  456.       require2:=false;
  457.     end;
  458.   end;
  459.   if trans then
  460.   begin
  461.     reqcount:=reqcount+1;
  462.     if (reqcount mod 3=0) then
  463.       client.SendBuffer(remoteIP,remotePort,transframe,numread+4);
  464.     if reqcount=9 then
  465.     begin
  466.       showmessage('发送文件超时');
  467.       logmemo.Lines.Append(datetostr(date)+' '+timetostr(now));
  468.       logmemo.Lines.Append('发送文件超时');
  469.       block_NO:=0;
  470.       ack_NO:=0;
  471.       read_button.Enabled:=true;
  472.       write_button.Enabled:=true;
  473.       cancel_button.Enabled:=true;
  474.       stop_button.Enabled:=true;
  475.       trans:=false;
  476.       statusbar.Panels.Items[0].Text:='重置';
  477.       timeready:=false;
  478.     end;
  479.   end;
  480.   if acktran then
  481.   begin
  482.     reqcount:=reqcount+1;
  483.     if (reqcount mod 9=0) then
  484.       client.SendBuffer(remoteIP,remotePort,transframe,numread+4);
  485.     if reqcount=20 then
  486.     begin
  487.       showmessage('接收文件超时');
  488.       logmemo.Lines.Append(datetostr(date)+' '+timetostr(now));
  489.       logmemo.Lines.Append('接收文件超时');
  490.       block_NO:=0;
  491.       ack_NO:=0;
  492.       read_button.Enabled:=true;
  493.       write_button.Enabled:=true;
  494.       cancel_button.Enabled:=true;
  495.       stop_button.Enabled:=true;
  496.       trans:=false;
  497.       statusbar.Panels.Items[0].Text:='重置';
  498.       acktran:=false;
  499.       timeready:=false;
  500.     end;
  501.   end;
  503.   if timeready then
  504.   begin
  505.     starttime:=starttime+1;
  506.     if starttime<>0 then
  507.       begin
  508.         v:=count/starttime/1000;
  509.         statusbar.Panels.Items[1].Text:='速度: '+inttostr(trunc(v))+'KB/s';
  510.       end;
  511.   end;
  512. end;
  514. procedure TForm1.trace_buttonClick(Sender: TObject);
  515. begin
  516.   if  not trace then
  517.   begin
  518.     trace:=true;
  519.     trace_button.Caption:='停止';
  520.   end
  521.   else begin
  522.     trace:=false;
  523.     trace_button.Caption:='跟踪';
  524.   end;
  525. end;
  527. procedure TForm1.clear_ButtonClick(Sender: TObject);
  528. begin
  529.   logmemo.Clear;
  530. end;
  532. procedure TForm1.save_buttonClick(Sender: TObject);
  533. begin
  534.   logmemo.Lines.SaveToFile(getcurrentdir+'/save.txt');
  535. end;
  537. end.