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

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