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

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

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(datetostr(date)+'   '+timetostr(now));
  366.     logmemo.Lines.Append('error: code='+inttostr(flipin(recframe.info[1],recframe.info[2])));
  367.     require1:=false;
  368.     case flipin(recframe.info[1],recframe.info[2]) of
  369.     0:begin
  370.        filename:='';
  371.        for i:=3 to adata.Size-2 do
  372.          filename:=filename+chr(recframe.info[i]);
  373.        showmessage(filename);
  374.        logmemo.Lines.Append(filename);
  375.     end;
  376.     1: begin
  377.       showmessage('File not found.');
  378.       logmemo.Lines.Append(datetostr(date)+'   '+timetostr(now));
  379.       logmemo.Lines.Append('error: code=1');
  380.       logmemo.Lines.Append('File not found');
  381.     end;
  382.     2:begin
  383.       showmessage('Access violation.');
  384.       logmemo.Lines.Append(datetostr(date)+'   '+timetostr(now));
  385.       logmemo.Lines.Append('error: code=1');
  386.       logmemo.Lines.Append('Access violation.');
  387.     end;
  388.     3: begin
  389.       showmessage('Disk full or allocation exceeded.');
  390.       logmemo.Lines.Append(datetostr(date)+'   '+timetostr(now));
  391.       logmemo.Lines.Append('error: code=1');
  392.       logmemo.Lines.Append('Disk full or allocation exceeded.');
  393.     end;
  394.     4:begin
  395.       showmessage('Illegal TFTP operation.');
  396.       logmemo.Lines.Append(datetostr(date)+'   '+timetostr(now));
  397.       logmemo.Lines.Append('error: code=1');
  398.       logmemo.Lines.Append('Illegal TFTP operation.');
  399.     end;
  400.     5:begin
  401.       showmessage('Unknown transfer ID.');
  402.       logmemo.Lines.Append(datetostr(date)+'   '+timetostr(now));
  403.       logmemo.Lines.Append('error: code=1');
  404.       logmemo.Lines.Append('Unknown transfer ID.');
  405.     end;
  406.     6:begin
  407.       showmessage('File already exists.');
  408.       logmemo.Lines.Append(datetostr(date)+'   '+timetostr(now));
  409.       logmemo.Lines.Append('error: code=1');
  410.       logmemo.Lines.Append('File already exists.');
  411.     end;
  412.     7:begin
  413.       showmessage('No such user.');
  414.       logmemo.Lines.Append(datetostr(date)+'   '+timetostr(now));
  415.       logmemo.Lines.Append('error: code=1');
  416.       logmemo.Lines.Append('No such user.');
  417.     end;
  418.     end;
  419.     block_NO:=0;
  420.     ack_NO:=0;
  421.     read_button.Enabled:=true;
  422.     write_button.Enabled:=true;
  423.     cancel_button.Enabled:=true;
  424.     stop_button.Enabled:=true;
  425.   end;
  426.   end;
  427. end;
  429. procedure TForm1.cancel_buttonClick(Sender: TObject);
  430. begin
  431.   statusbar.Panels.Items[0].Text:='空闲';
  432.   browse_button.Enabled:=false;
  433.   cancel_button.Enabled:=false;
  434.   path_edit.Enabled:=false;
  435.   read_button.Enabled:=true;
  436.   write_button.Enabled:=true;
  437.   stop_button.Enabled:=true;;
  438. end;
  440. procedure TForm1.stop_buttonClick(Sender: TObject);
  441. begin
  442.   stop_button.Enabled:=false;
  443.   apply_button.Enabled:=true;
  444.   client.Active:=false;
  445.   client.Bindings.Items[0].Free;
  446.   statusbar.Panels.Items[0].Text:='空闲';
  447. end;
  449. procedure TForm1.Timer1Timer(Sender: TObject);
  450. var
  451.   i:integer;
  452.   v:real;
  453. begin
  454.   if require1 then
  455.   begin
  456.     reqcount:=reqcount+1;
  457.     for i:=1 to 512 do
  458.       if transframe.info[i]=0 then break;
  459.     client.SendBuffer(remoteIP,remotePort,transframe,i+8);
  460.     if reqcount=5 then
  461.     begin
  462.       showmessage('连接主机超时');
  463.       logmemo.Lines.Append(datetostr(date)+' '+timetostr(now));
  464.       logmemo.Lines.Append('连接主机超时');
  465.       block_NO:=0;
  466.       ack_NO:=0;
  467.       read_button.Enabled:=true;
  468.       write_button.Enabled:=true;
  469.       cancel_button.Enabled:=true;
  470.       stop_button.Enabled:=true;
  471.       require1:=false;
  472.       statusbar.Panels.Items[0].Text:='重置';
  473.     end;
  474.   end;
  475.   if require2 then
  476.   begin
  477.     reqcount:=reqcount+1;
  478.     for i:=1 to 512 do
  479.       if transframe.info[i]=0 then break;
  480.     client.SendBuffer(remoteIP,remotePort,transframe,i+8);
  481.     if reqcount=5 then
  482.     begin
  483.       showmessage('连接主机超时');
  484.       logmemo.Lines.Append(datetostr(date)+' '+timetostr(now));
  485.       logmemo.Lines.Append('连接主机超时');
  486.       statusbar.Panels.Items[0].Text:='重置';
  487.       block_NO:=0;
  488.       ack_NO:=0;
  489.       read_button.Enabled:=true;
  490.       write_button.Enabled:=true;
  491.       cancel_button.Enabled:=true;
  492.       stop_button.Enabled:=true;
  493.       require2:=false;
  494.     end;
  495.   end;
  496.   if trans then
  497.   begin
  498.     reqcount:=reqcount+1;
  499.     if (reqcount mod 3=0) then
  500.       client.SendBuffer(remoteIP,remotePort,transframe,numread+4);
  501.     if reqcount=9 then
  502.     begin
  503.       showmessage('发送文件超时');
  504.       logmemo.Lines.Append(datetostr(date)+' '+timetostr(now));
  505.       logmemo.Lines.Append('发送文件超时');
  506.       block_NO:=0;
  507.       ack_NO:=0;
  508.       read_button.Enabled:=true;
  509.       write_button.Enabled:=true;
  510.       cancel_button.Enabled:=true;
  511.       stop_button.Enabled:=true;
  512.       trans:=false;
  513.       statusbar.Panels.Items[0].Text:='重置';
  514.       timeready:=false;
  515.     end;
  516.   end;
  517.   if acktran then
  518.   begin
  519.     reqcount:=reqcount+1;
  520.     if (reqcount mod 9=0) then
  521.       client.SendBuffer(remoteIP,remotePort,transframe,numread+4);
  522.     if reqcount=20 then
  523.     begin
  524.       showmessage('接收文件超时');
  525.       logmemo.Lines.Append(datetostr(date)+' '+timetostr(now));
  526.       logmemo.Lines.Append('接收文件超时');
  527.       block_NO:=0;
  528.       ack_NO:=0;
  529.       read_button.Enabled:=true;
  530.       write_button.Enabled:=true;
  531.       cancel_button.Enabled:=true;
  532.       stop_button.Enabled:=true;
  533.       trans:=false;
  534.       statusbar.Panels.Items[0].Text:='重置';
  535.       acktran:=false;
  536.       timeready:=false;
  537.     end;
  538.   end;
  540.   if timeready then
  541.   begin
  542.     starttime:=starttime+1;
  543.     if starttime<>0 then
  544.       begin
  545.         v:=count/starttime/1000;
  546.         statusbar.Panels.Items[1].Text:='速度: '+inttostr(trunc(v))+'KB/s';
  547.       end;
  548.   end;
  549. end;
  551. procedure TForm1.trace_buttonClick(Sender: TObject);
  552. begin
  553.   if  not trace then
  554.   begin
  555.     trace:=true;
  556.     trace_button.Caption:='停止';
  557.   end
  558.   else begin
  559.     trace:=false;
  560.     trace_button.Caption:='跟踪';
  561.   end;
  562. end;
  564. procedure TForm1.clear_ButtonClick(Sender: TObject);
  565. begin
  566.   logmemo.Clear;
  567. end;
  569. procedure TForm1.save_buttonClick(Sender: TObject);
  570. begin
  571.   logmemo.Lines.SaveToFile(getcurrentdir+'/save.txt');
  572. end;
  574. end.