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

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

Ftp服务器

开发平台：

Delphi

Unit1.pas：源码内容
  1. unit Unit1;
  3. interface
  5. uses
  6.   Windows, Messages, SysUtils, Variants, Classes, Graphics, Controls, Forms,
  7.   Dialogs, StdCtrls, ComCtrls, IdBaseComponent, IdComponent, IdUDPBase,
  8.   IdUDPServer, ExtCtrls, IdSocketHandle, IdIPWatch;
  10. type
  11.   TForm1 = class(TForm)
  12.     Server: TIdUDPServer;
  13.     PageControl1: TPageControl;
  14.     TabSheet1: TTabSheet;
  15.     TabSheet2: TTabSheet;
  16.     locIP_edit: TEdit;
  17.     locPort_edit: TEdit;
  18.     Label1: TLabel;
  19.     Label2: TLabel;
  20.     apply_button: TButton;
  21.     Label3: TLabel;
  22.     path_edit: TEdit;
  23.     dir_button: TButton;
  24.     start_button: TButton;
  25.     logmemo: TMemo;
  26.     Label4: TLabel;
  27.     StatusBar: TStatusBar;
  28.     TabSheet3: TTabSheet;
  29.     Memo2: TMemo;
  30.     Timer1: TTimer;
  31.     link_edit: TEdit;
  32.     Label5: TLabel;
  33.     link_button: TButton;
  34.     IPWatch: TIdIPWatch;
  35.     clear_Button: TButton;
  36.     save_button: TButton;
  37.     procedure FormCreate(Sender: TObject);
  38.     procedure start_buttonClick(Sender: TObject);
  39.     procedure dir_buttonClick(Sender: TObject);
  40.     procedure ServerUDPRead(Sender: TObject; AData: TStream;
  41.       ABinding: TIdSocketHandle);
  42.     procedure apply_buttonClick(Sender: TObject);
  43.     procedure link_buttonClick(Sender: TObject);
  44.     procedure clear_ButtonClick(Sender: TObject);
  45.     procedure save_buttonClick(Sender: TObject);
  46.     procedure Timer1Timer(Sender: TObject);
  47.   private
  48.     { Private declarations }
  49.   public
  50.     { Public declarations }
  51.   end;
  53. type
  54.   frame=record
  55.     op:word;
  56.     info:array[1..514] of byte;
  57.   end;
  58.   frame2=record
  59.     op:word;
  60.     info:array[1..514] of byte;
  61.     len:integer;
  62.   end;
  63.   rflip=record
  64.      a1:byte;
  65.      a2:byte;
  66.   end;
  67.   client_link=record
  68.     use:boolean;
  69.     ip:string;
  70.     port:integer;
  71.     total:longint;
  72.     frame_NO:word;
  73.     filename:string;
  74.   end;
  75. var
  76.   Form1: TForm1;
  77.   globaldir:string;
  78.   locIP: string;
  79.   locPort: integer;
  80.   transframe,recframe:frame;
  81.   linkarray:array[1..20]of client_link;
  82.   maxlink:integer;
  83.   fileary:array[1..20]of file;
  84.   tranary:array[1..20]of boolean;
  85.   lastary:array[1..20]of boolean;
  86.   count:array[1..20]of longint;
  87.   frameary:array[1..20]of frame2;
  89. implementation
  91. {$R *.dfm}
  93. function selfinc(a:word):word;
  94. var
  95.   x:word;
  96. begin
  97.   x:=a;
  98.   if x=65535 then selfinc:=0
  99.   else begin
  100.     x:=x+1;
  101.     selfinc:=x;
  102.   end;
  103. end;
  105. function flipout(orig:word):rflip;
  106. var
  107.   a:byte;
  108.   s:rflip;
  109. begin
  110.   s:=rflip(orig);
  111.   a:=s.a1;
  112.   s.a1:=s.a2;
  113.   s.a2:=a;
  114.   flipout:=s;
  115. end;
  117. function flipin(a1,a2:byte):word;
  118. var
  119.   a:rflip;
  120. begin
  121.   a.a1:=a2;
  122.   a.a2:=a1;
  123.   flipin:=word(a);
  124. end;
  126. procedure TForm1.FormCreate(Sender: TObject);
  127. var
  128.   i:integer;
  129. begin
  130.   path_edit.Text:=getcurrentdir;
  131.   globaldir:=path_edit.Text;
  132.   maxlink:=5;
  133.   locport:=69;
  134.   locIP_edit.Text:=IPWatch.LocalIP;
  135.   for i:=1 to maxlink do
  136.   begin
  137.     tranary[i]:=false;
  138.     lastary[i]:=false;
  139.     linkarray[i].use:=false;
  140.     count[i]:=0;
  141.   end;
  142. end;
  144. procedure TForm1.start_buttonClick(Sender: TObject);
  145. var
  146.   i:integer;
  147. begin
  148.   statusbar.Panels.Items[0].Text:='等待连接';
  149.   logmemo.Lines.Append(datetostr(date)+'   '+timetostr(now));
  150.   logmemo.Lines.Append('server端启动');
  151.   link_button.Enabled:=false;
  152.   apply_button.Enabled:=false;
  153.   dir_button.Enabled:=false;
  154.   start_button.Enabled:=false;  
  155.   server.Active:=false;
  156.   server.DefaultPort:=locPort;
  157.   server.Bindings.Add;
  158.   server.Bindings.Items[0].Port:=locPort;
  159.   server.Active:=true;
  160.   for i:=1 to maxlink do
  161.     linkarray[i].use:=false;
  162. end;
  164. procedure TForm1.dir_buttonClick(Sender: TObject);
  165. begin
  166.   globaldir:=path_edit.Text;
  167. end;
  169. procedure TForm1.ServerUDPRead(Sender: TObject; AData: TStream;
  170.   ABinding: TIdSocketHandle);
  171. var
  172.   numread,numwrite:integer;
  173.   temp:array[1..512] of byte;
  174.   i,j:integer;
  175.   filename:string;
  176. begin
  177.   adata.ReadBuffer(recframe,adata.Size);
  178.   case word(flipout(recframe.op)) of
  179.   1:begin
  180.     filename:='';
  181.     for i:=1 to adata.Size-9 do
  182.       filename:=filename+chr(recframe.info[i]);
  183.     filename:=globaldir+''+filename;
  184.     if fileexists(filename) then
  185.     begin
  186.       for i:=1 to maxlink do
  187.         if not linkarray[i].use then
  188.         begin
  189.           statusbar.Panels.Items[0].Text:='请求读连接';
  190.           logmemo.Lines.Append(datetostr(date)+'   '+timetostr(now));
  191.           logmemo.Lines.Append('用户：  '+abinding.peerIP+'端口：'+
  192.                inttostr(abinding.PeerPort)+'读文件请求'+filename);
  193.           linkarray[i].use:=true;
  194.           linkarray[i].ip:=abinding.PeerIP;
  195.           linkarray[i].port:=abinding.PeerPort;
  196.           linkarray[i].total:=0;
  197.           linkarray[i].frame_NO:=1;
  198.           linkarray[i].filename:=filename;
  199.           assignfile(fileary[i],filename);
  200.           reset(fileary[i],1);
  201.           transframe.op:=word(flipout(3));
  202.           blockread(fileary[i],temp,512,numread);
  203.           linkarray[i].total:=linkarray[i].total+numread;
  204.           transframe.info[1]:=flipout(linkarray[i].frame_NO).a1;
  205.           transframe.info[2]:=flipout(linkarray[i].frame_NO).a2;
  206.           for j:=3 to numread+2 do
  207.             transframe.info[j]:=temp[j-2];
  208.           server.SendBuffer(linkarray[i].IP,linkarray[i].Port,transframe,numread+4);
  209.           frameary[i].op:=transframe.op;
  210.           for j:=1 to numread-2 do
  211.             frameary[i].info[j]:=transframe.info[j];
  212.           frameary[i].len:=numread+4;
  213.           tranary[i]:=true;
  214.           count[i]:=0;
  215.           break;
  216.         end else
  217.         begin
  218.           if i=maxlink then
  219.           begin
  220.             logmemo.Lines.Append(datetostr(date)+'   '+timetostr(now));
  221.             logmemo.Lines.Append('用户：  '+abinding.peerIP+'端口：'+
  222.                inttostr(abinding.PeerPort)+'请求读文件失败：最大连接数限制');
  223.             transframe.op:=word(flipout(5));
  224.             transframe.info[1]:=flipout(0).a1;
  225.             transframe.info[2]:=flipout(0).a2;
  226.             filename:='max linked';
  227.             for j:=3 to 12 do
  228.               transframe.info[j]:=ord(filename[j-2]);
  229.             server.SendBuffer(abinding.PeerIP,abinding.PeerPort,transframe,14);
  230.           end;
  231.         end;
  232.     end
  233.     else begin
  234.       logmemo.Lines.Append(datetostr(date)+'   '+timetostr(now));
  235.       logmemo.Lines.Append('用户：  '+abinding.peerIP+'端口：'+
  236.                inttostr(abinding.PeerPort)+'请求读文件失败：文件不存在'+filename);
  237.       transframe.op:=word(flipout(5));
  238.       transframe.info[1]:=flipout(1).a1;
  239.       transframe.info[2]:=flipout(1).a2;
  240.       filename:='file not found';
  241.       for i:=3 to 16 do
  242.         transframe.info[i]:=ord(filename[i-2]);
  243.       server.SendBuffer(abinding.PeerIP,abinding.PeerPort,transframe,18);
  244.     end;
  245.   end;
  246.   2:begin
  247.     filename:='';
  248.     for i:=1 to adata.Size-9 do
  249.       filename:=filename+chr(recframe.info[i]);
  250.     filename:=globaldir+''+filename;
  251.     if (not fileexists(filename)) then
  252.     begin
  253.       for i:=1 to maxlink do
  254.         if (not linkarray[i].use) then
  255.         begin
  256.           logmemo.Lines.Append(datetostr(date)+'   '+timetostr(now));
  257.           logmemo.Lines.Append('用户：  '+abinding.peerIP+'端口：'+
  258.                inttostr(abinding.PeerPort)+'写文件请求'+filename);
  259.           linkarray[i].use:=true;
  260.           linkarray[i].ip:=abinding.PeerIP;
  261.           linkarray[i].port:=abinding.PeerPort;
  262.           linkarray[i].total:=0;
  263.           linkarray[i].frame_NO:=0;
  264.           linkarray[i].filename:=filename;
  265.           lastary[i]:=false;
  266.           assignfile(fileary[i],filename);
  267.           rewrite(fileary[i],1);
  268.           transframe.op:=word(flipout(4));
  269.           transframe.info[1]:=flipout(linkarray[i].frame_NO).a1;
  270.           transframe.info[2]:=flipout(linkarray[i].frame_NO).a2;
  271.           server.SendBuffer(abinding.PeerIP,abinding.PeerPort,transframe,4);
  272.           frameary[i].op:=transframe.op;
  273.           for j:=1 to 2 do
  274.             frameary[i].info[j]:=transframe.info[j];
  275.           frameary[i].len:=4;
  276.           tranary[i]:=true;
  277.           count[i]:=0;
  278.           break;
  279.         end else
  280.         begin
  281.           if i=maxlink then
  282.           begin
  283.             statusbar.Panels.Items[0].Text:='请求写连接';
  284.             logmemo.Lines.Append(datetostr(date)+'   '+timetostr(now));
  285.             logmemo.Lines.Append('用户：  '+abinding.peerIP+'端口：'+
  286.               inttostr(abinding.PeerPort)+'请求写文件失败：最大连接数限制');
  287.             transframe.op:=word(flipout(5));
  288.             transframe.info[1]:=flipout(0).a1;
  289.             transframe.info[2]:=flipout(0).a2;
  290.             filename:='max linked';
  291.             for j:=3 to 12 do
  292.               transframe.info[j]:=ord(filename[j-2]);
  293.             server.SendBuffer(abinding.PeerIP,abinding.PeerPort,transframe,14);
  294.           end;
  295.         end;
  296.     end
  297.     else begin
  298.       logmemo.Lines.Append(datetostr(date)+'   '+timetostr(now));
  299.       logmemo.Lines.Append('用户：  '+abinding.peerIP+'端口：'+
  300.         inttostr(abinding.PeerPort)+'请求写文件失败：文件已经存在'+filename);
  301.       transframe.op:=word(flipout(5));
  302.       transframe.info[1]:=flipout(0).a1;
  303.       transframe.info[2]:=flipout(0).a2;
  304.       filename:='file already exist';
  305.       for i:=3 to 20 do
  306.         transframe.info[i]:=ord(filename[i-2]);
  307.       server.SendBuffer(abinding.PeerIP,abinding.PeerPort,transframe,22);
  308.     end;
  309.   end;
  310.   3:begin
  311.     for i:=1 to maxlink do
  312.       if((linkarray[i].use)and(linkarray[i].ip=abinding.PeerIP)
  313.          and(linkarray[i].port=abinding.PeerPort)) then  break;
  314.     if (flipin(recframe.info[1],recframe.info[2])=(selfinc(linkarray[i].frame_NO))) then
  315.     begin
  316.       tranary[i]:=false;
  317.       statusbar.Panels.Items[0].Text:='传送中...';
  318.       for j:=1 to adata.Size-4 do
  319.         temp[j]:=recframe.info[j+2];
  320.       blockwrite(fileary[i],temp,adata.size-4,numwrite);
  321.       linkarray[i].total:=linkarray[i].total+numwrite;
  322.       linkarray[i].frame_NO:=linkarray[i].frame_NO+1;
  323.       transframe.op:=word(flipout(4));
  324.       transframe.info[1]:=flipout(linkarray[i].frame_NO).a1;
  325.       transframe.info[2]:=flipout(linkarray[i].frame_NO).a2;
  326.       server.SendBuffer(linkarray[i].ip,linkarray[i].port,transframe,4);
  327.       frameary[i].op:=transframe.op;
  328.       for j:=1 to 2 do
  329.         frameary[i].info[j]:=transframe.info[j];
  330.       frameary[i].len:=4;
  331.       tranary[i]:=true;
  332.       count[i]:=0;
  333.       if numwrite<512 then
  334.       begin
  335.         logmemo.Lines.Append(datetostr(date)+'   '+timetostr(now));
  336.         logmemo.Lines.Append('用户：  '+abinding.peerIP+'端口：'+
  337.           inttostr(abinding.PeerPort)+'文件接收完毕'+linkarray[i].filename);
  338.         closefile(fileary[i]);
  339.         linkarray[i].frame_NO:=0;
  340.         statusbar.Panels.Items[0].Text:='接收完毕';
  341.         linkarray[i].use:=false;
  342.         tranary[i]:=false;
  343.         count[i]:=0;
  344.       end;
  345.     end;
  346.   end;
  347.   4:begin
  348.     for i:=1 to maxlink do
  349.       if((linkarray[i].use)and(linkarray[i].ip=abinding.PeerIP)
  350.          and(linkarray[i].port=abinding.PeerPort)) then  break;
  351.     if (flipin(recframe.info[1],recframe.info[2])=linkarray[i].frame_NO) then
  352.     begin
  353.       tranary[i]:=false;
  354.       if not lastary[i] then
  355.       begin
  356.         linkarray[i].frame_NO:=linkarray[i].frame_NO+1;
  357.         seek(fileary[i],linkarray[i].total);
  358.         blockread(fileary[i],temp,512,numread);
  359.         linkarray[i].total:=linkarray[i].total+numread;
  360.         transframe.op:=word(flipout(3));
  361.         transframe.info[1]:=flipout(linkarray[i].frame_NO).a1;
  362.         transframe.info[2]:=flipout(linkarray[i].frame_NO).a2;
  363.         for j:=3 to numread+2 do
  364.           transframe.info[j]:=temp[j-2];
  365.         server.SendBuffer(linkarray[i].ip,linkarray[i].port,transframe,numread+4);
  366.         statusbar.Panels.Items[0].Text:='传送中...';
  367.         frameary[i].op:=transframe.op;
  368.         for j:=1 to numread-2 do
  369.           frameary[i].info[j]:=transframe.info[j];
  370.         frameary[i].len:=numread+4;
  371.         tranary[i]:=true;
  372.         count[i]:=0;
  373.         if numread<512 then
  374.         begin
  375.           statusbar.Panels.Items[0].Text:='发送完毕';
  376.           logmemo.Lines.Append(datetostr(date)+'   '+timetostr(now));
  377.           logmemo.Lines.Append('用户：  '+abinding.peerIP+'端口：'+
  378.             inttostr(abinding.PeerPort)+'文件发送完毕'+linkarray[i].filename);
  379.           lastary[i]:=true;
  380.           closefile(fileary[i]);
  381.         end;
  382.       end
  383.       else
  384.       begin
  385.         lastary[i]:=false;
  386.         linkarray[i].use:=false;
  387.       end;
  388.     end;
  389.   end;
  390.   else begin
  391.     logmemo.Lines.Append(datetostr(date)+'   '+timetostr(now));
  392.     logmemo.Lines.Append('用户：  '+abinding.peerIP+'端口：'+
  393.     inttostr(abinding.PeerPort)+'错误的操作请求');
  394.       transframe.op:=word(flipout(5));
  395.     transframe.info[1]:=flipout(0).a1;
  396.     transframe.info[2]:=flipout(0).a2;
  397.     filename:='wrong operation';
  398.     for j:=3 to 17 do
  399.       transframe.info[j]:=ord(filename[j-2]);
  400.     server.SendBuffer(abinding.PeerIP,abinding.PeerPort,transframe,19);
  402.   end;
  403.   end;
  404. end;
  406. procedure TForm1.apply_buttonClick(Sender: TObject);
  407. begin
  408.   locport:=strtoint(locport_edit.Text);
  409. end;
  411. procedure TForm1.link_buttonClick(Sender: TObject);
  412. begin
  413.   if ((strtoint(link_edit.Text)>20)or(strtoint(link_edit.Text)<1)) then
  414.   begin
  415.     showmessage('非法设定(max=20,min=1)');
  416.     link_edit.Clear;
  417.   end
  418.   else maxlink:=strtoint(link_edit.Text);
  419. end;
  421. procedure TForm1.clear_ButtonClick(Sender: TObject);
  422. begin
  423.   logmemo.Clear;
  424. end;
  426. procedure TForm1.save_buttonClick(Sender: TObject);
  427. begin
  428.   logmemo.Lines.SaveToFile(getcurrentdir+'/save.txt');
  429. end;
  431. procedure TForm1.Timer1Timer(Sender: TObject);
  432. var
  433.   i:integer;
  434. begin
  435.   for i:=1 to maxlink do
  436.   begin
  437.     if tranary[i] then
  438.     begin
  439.       count[i]:=count[i]+1;
  440.       if count[i] mod 3=0 then
  441.         server.SendBuffer(linkarray[i].ip,linkarray[i].port,frameary[i],frameary[i].len);
  442.       if count[i]=9 then
  443.       begin
  444.         tranary[i]:=false;
  445.         count[i]:=0;
  446.         linkarray[i].use:=false;
  447.         logmemo.Lines.Append(datetostr(date)+'   '+timetostr(time));
  448.         logmemo.Lines.Append('用户: '+linkarray[i].ip+inttostr(linkarray[i].port)
  449.           +'连接超时');
  450.       end;
  451.     end;
  452.   end;
  453. end;
  455. end.