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

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