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

源码开发语言/平台
当前位置：首页 > 源码/资料 > Internet/网络编程 > Ftp服务器 > 查看源码
ftpsession.java
资源名称：FTPServer12.rar　[点击查看]
上传用户：lybcsm
上传日期：2007-04-26
资源大小：26k
文件大小：11k
源码类别：

Ftp服务器

开发平台：

Java

ftpsession.java：源码内容
  1. package ftpserver;
  3. import java.io.*;
  4. import java.util.*;
  5. import java.net.*;
  6. import java.text.*;
  7. import java.text.SimpleDateFormat;
  9. public class ftpsession implements Runnable {
  10.     private ftpframe frame;
  11.     private String linesep;
  12.     private Socket cs;
  13.     private Socket ds;
  14.     boolean blnBinary;
  15.     BufferedReader inData;
  16.     PrintWriter outData;
  17.     File rootPath=new File(".");
  18.     File currentPath=rootPath;
  19.     String loginname="";
  21.     //Constructor
  22.     public ftpsession(Socket cs,ftpframe frame){
  23.        this.cs=cs;
  24.        this.frame=frame;
  25.        //Line Separator
  26.        linesep=System.getProperty("line.separator");
  27.       }
  28.     public void showMessage(String Msg){
  29.        outData.println(Msg);
  30.        frame.textMessage.append(Msg+linesep);
  31.        frame.textMessage.setCaretPosition(frame.textMessage.getText().length());
  32.      }
  33.     public void resetDefault(){
  34.        blnBinary=false;
  35.        currentPath=rootPath;
  36.      }
  37.     public void run(){
  38.       try{
  39.           inData=new BufferedReader(
  40.                new InputStreamReader(cs.getInputStream()));
  41.           outData=new PrintWriter(cs.getOutputStream(),true);
  42.           showMessage("220 Java FTP Server-<version 1.0>-ready.");
  44.           String ftpCmd="";
  45.           //Process FTP client command
  46.           while(!(ftpCmd.toLowerCase().startsWith("quit"))){
  47.                try{
  48.                     ftpCmd=inData.readLine();
  49.                     ftpCommand(ftpCmd);
  50.                   }
  51.                 catch(IOException ex){
  52.                    ex.printStackTrace();
  53.                    ftpCmd="quit";
  54.                  }
  55.                }
  56.           //Close FTP Session
  57.           try{
  58.               cs.close();
  59.             }
  60.           catch(IOException e){
  61.              e.printStackTrace();
  62.            }
  64.           cs=null;
  65.           inData=null;
  66.           outData=null;
  67.         }
  68.         catch(Exception e){
  69.           e.printStackTrace();
  70.         }
  71.       }
  73.   void ftpCommand(String cmd){
  74.       if(cmd==null) cmd="";
  76.       StringTokenizer ftpCmdtok=new StringTokenizer(cmd.toLowerCase());
  77.       String ftpCmd="";
  79.       try{
  80.           ftpCmd=ftpCmdtok.nextToken();
  81.           SimpleDateFormat formatter=new SimpleDateFormat("EEE,d MMM yyyy hh:mm:ss z");
  82.           System.out.println(formatter.format(new Date())+""+cmd);
  83.           //syst
  84.           if(ftpCmd.equals("syst")){
  85.               showMessage("215 Java FTP Server.");
  86.             }
  87.           //user:Login
  88.           else if("user".indexOf(ftpCmd)!=-1){
  89.              try{
  90.                 loginname=ftpCmdtok.nextToken();
  91.                 showMessage("331 Password required for"+loginname);
  92.               }
  93.              catch(Exception e){
  94.                showMessage("500 User syntax.");
  95.              }
  96.            }
  97.           //pass: Verify password
  98.           else if("pass".indexOf(ftpCmd)!=-1){
  99.               //Add the logic of verifying password here
  100.                 showMessage("230 User"+loginname+"logged in.");
  101.                 resetDefault();
  102.               }
  103.            //port
  104.            else if(ftpCmd.equals("port")){
  105.               try{
  106.                  StringTokenizer arg=new
  107.                  StringTokenizer(ftpCmdtok.nextToken(),",",false);
  108.                  String clientIP="";
  109.                  String ipString="";
  110.                  int cmdPort;
  112.                  if(ds!=null){
  113.                      ds.close();
  114.                      ds=null;
  115.                    }
  116.                  clientIP=arg.nextToken();
  117.                  ipString=clientIP;
  118.                  //get Client IP
  119.                  for(int i=0;i<3;i++){
  120.                     String hIP=arg.nextToken();
  121.                     clientIP=clientIP+"."+hIP;
  122.                     ipString=ipString+","+hIP;
  123.                   }
  124.                  String p1=arg.nextToken();
  125.                  ipString=ipString+","+p1;
  126.                  cmdPort=new Integer(p1).intValue();
  127.                  cmdPort *=256;
  128.                  String p2= arg.nextToken();
  129.                  ipString=ipString+","+p2;
  130.                  cmdPort+=new Integer(p2).intValue();
  131.                  //Establish data connection
  132.                  ds=new Socket(clientIP,cmdPort);
  134.                  showMessage("PORT"+ipString);
  135.                  showMessage("200 PORT command successful.");
  136.                }
  137.              catch(Exception e){
  138.                 showMessage("500 Port number syntax.");
  139.               }
  140.             }
  141.           //type
  142.         else if(ftpCmd.equals("type")){
  143.            try{
  144.               String arg=ftpCmdtok.nextToken();
  145.               //Binary
  146.               if("i".indexOf(arg)!=-1){
  147.                  blnBinary=true;
  148.                  showMessage("200 Type set to I.");
  149.                }
  150.              //ASCII
  151.              else if("a".indexOf(arg)!=-1){
  152.                blnBinary=false;
  153.                showMessage("200 Type set to A.");
  154.               }
  155.              else showMessage("501 Type"+arg+"syntax.");
  156.            }
  157.           catch(Exception e){
  158.             showMessage("500 TYPE syntax.");
  159.             }
  160.           }
  161.         //mode
  162.         else if(ftpCmd.equals("mode")){
  163.            try{
  164.              String arg=ftpCmdtok.nextToken();
  165.              if(arg.equals("s"))
  166.                 showMessage("200 MODE S.");
  167.              else showMessage("501 MODE S not found.");
  168.            }
  169.          catch(Exception e){
  170.            showMessage("500 MODE syntax.");
  171.          }
  172.        }
  173.      //stru
  174.      else if(ftpCmd.equals("stru")){
  175.        try{
  176.           String arg=ftpCmdtok.nextToken();
  177.           if(arg.equals("f"))
  178.               showMessage("200 STRU F.");
  179.           else showMessage("501 STRU F not found.");
  180.         }
  181.       catch(Exception e){
  182.          showMessage("500 STRU syntax.");
  183.        }
  184.      }
  185.    //list
  186.    else if("list".indexOf(ftpCmd)!=-1){
  187.        String arg;
  188.        if(ftpCmdtok.hasMoreTokens())
  189.             arg=ftpCmdtok.nextToken();
  190.        else arg=".";
  191.        ftpList(arg);
  192.     }
  193.   //nlst
  194.   else if("nlst".indexOf(ftpCmd)!=-1){
  195.       String arg;
  196.       if(ftpCmdtok.hasMoreTokens())
  197.           arg=ftpCmdtok.nextToken();
  198.       else arg=".";
  199.       ftpList(arg);
  200.     }
  201.   else if(ftpCmd.equals("cdup"))
  202.       changeDirectory(currentPath.getParent());
  203.   else if(ftpCmd.equals("cwd")){
  204.       try{
  205.          String arg=ftpCmdtok.nextToken();
  206.          changeDirectory(arg);
  207.        }
  208.       catch(Exception e){
  209.          showMessage("500 CWD syntax.");
  210.        }
  211.      }
  212.    //xpwd:Current Directory(pwd)
  213.    else if("xpwd".indexOf(ftpCmd)!=-1){
  214.        showMessage("200 PWD"+currentPath);
  215.      }
  216.    //stor:PUT
  217.   else if(ftpCmd.equals("stor")){
  218.      try{
  219.         String arg=ftpCmdtok.nextToken();
  220.         File path=new File(currentPath,arg);
  221.         if(!path.getCanonicalPath().startsWith(rootPath.getCanonicalPath()))
  222.             throw new SecurityException();
  223.         if(blnBinary)
  224.             putLocalBinaryFile(path,arg);
  225.         else  putLocalASCIIFile(path,arg);
  226.       }
  227.     catch(Exception ex){
  228.        showMessage("500 STOR syntax.");
  229.      }
  230.    }
  231.  //retr:GET
  232.  else if(ftpCmd.equals("retr")){
  233.      try{
  234.         String arg=ftpCmdtok.nextToken();
  235.         File path=new File(currentPath,arg);
  236.         if(!path.getCanonicalPath().startsWith(rootPath.getCanonicalPath()))
  237.             throw new SecurityException();
  238.         getRemoteFile(path,arg);
  239.       }
  240.     catch(Exception ex){
  241.        showMessage("500 RETR syntax.");
  242.     }
  243.   }
  244. //help:Remote Help (remotehelp)
  245.  else if("help".indexOf(ftpCmd)!=-1){
  246.      String strhelp=
  247.         "Java FTP Server -<version 1.0>-ready."+linesep+"Help Message";
  248.       showMessage("200 Remotehelp"+strhelp);
  249.     }
  250.   //noop:No Operation
  251.  else if(ftpCmd.equals("noop"))
  252.      showMessage("200 OK.");
  253.  //quit
  254.  else if(ftpCmd.equals("quit")){
  255.      showMessage("211 Service closing control connection.Goodbye.");
  256.      resetDefault();
  257.    }
  258.  else showMessage("502"+ftpCmd+"nod found.");
  259. }
  260. catch(Exception e){
  261.   showMessage("500"+ftpCmd+"Systax.");
  262. }
  263. }
  264. void ftpList(String arg){
  265.    try{
  266.       File path=new File(currentPath,arg);
  267.       if(!path.getCanonicalPath().startsWith(rootPath.getCanonicalPath()))
  268.          throw new SecurityException();
  269.       if(path.isDirectory()){
  270.          String[] filename=path.list();
  271.          PrintWriter outFile=new
  272.          PrintWriter(ds.getOutputStream(),true);
  273.          if(blnBinary)
  274.              showMessage("150 Opening BINARY mode data connection for"+path+".");
  275.          else showMessage("150 Opening ASCII mode data connection for"+path+".");
  276.        for(int i=0;i<filename.length;i++){
  277.           outFile.println(filename[i]);
  278.         }
  279.        outFile.flush();
  280.        outFile.close();
  281.        showMessage("226 Transfer complete.");
  282.      }
  283.      else showMessage("550 Can not find the file specified.");
  284.    }
  285.    catch(Exception e){
  286.       showMessage("550 Can not find the file specified.");
  287.     }
  288.   }
  289. void changeDirectory(String arg){
  290.   try{
  291.       File path=new File(currentPath,arg);
  292.       if(!path.isDirectory()){
  293.          showMessage("550"+path+"is not a directory.");
  294.        }
  295.       else if(!path.getCanonicalPath().startsWith(rootPath.getCanonicalPath()))
  296.          showMessage("550 Not a subdirectory of"+rootPath.getCanonicalPath());
  297.       else {
  298.          currentPath=new File(path.getCanonicalPath());
  299.          showMessage("250 CWD command successful. OK."+currentPath);
  300.        }
  301.      }
  302.    catch(Exception e){
  303.       showMessage("500"+e);
  304.     }
  305.   }
  306. void putLocalBinaryFile(File file,String arg){
  307.    byte abyte[]= new byte[1024];
  308.    int inbytes;
  309.    try{
  310.       InputStream dataIn=ds.getInputStream();
  311.       FileOutputStream fileOut=new FileOutputStream(file);
  312.       if(blnBinary)
  313.          showMessage("150 Opening BINARY mode data connection for"+arg+".");
  314.       else showMessage("150 Opening ASCII mode data connection for"+arg+".");
  315.       do{
  316.          inbytes=dataIn.read(abyte);
  317.          if(inbytes!=-1)
  318.             fileOut.write(abyte,0,inbytes);
  319.         }
  320.       while(inbytes!=-1);
  321.       fileOut.flush();
  322.       fileOut.close();
  323.       showMessage("226 Closing data connection.Transfer Complete.");
  324.     }
  325.     catch(Exception e){
  326.         showMessage("550 Exception "+e);
  327.       }
  328. }
  329. void putLocalASCIIFile(File file,String arg){
  330.   String strdata;
  331.   try{
  332.       BufferedReader dataIn=new BufferedReader(new InputStreamReader(ds.getInputStream()));
  333.       PrintWriter fileOut=new PrintWriter(
  334.          new FileOutputStream(file),false);
  335.       if(blnBinary)
  336.          showMessage("150 Opening BINARY mode data connection for"+arg+".");
  337.       else showMessage("150 Opening ASCII mode data connection for"+arg+".");
  338.       do{
  339.          strdata=dataIn.readLine();
  340.          if(strdata!=null)
  341.            fileOut.println(strdata);
  342.        }
  343.       while(strdata!=null);
  344.       fileOut.flush();
  345.       fileOut.close();
  346.       showMessage("226 Closing data connection.Transfer Complete.");
  347.     }
  348.    catch(Exception e){
  349.       showMessage("550 Exception "+e);
  350.     }
  351.   }
  352.   void getRemoteFile(File file,String arg){
  353.     byte abyte[]=new byte[1024];
  354.     int inbytes;
  355.     try{
  356.        FileInputStream fileIn=new FileInputStream(file);
  357.        OutputStream dataOut=ds.getOutputStream();
  358.        if(blnBinary)
  359.           showMessage("150 Opening BINARY mode data connection for"+arg+".");
  360.        else showMessage("150 Opening ASCII mode data connection for"+arg+".");
  361.        do{
  362.           inbytes=fileIn.read(abyte);
  363.           if(inbytes!=-1)
  364.              dataOut.write(abyte,0,inbytes);
  365.          }
  366.        while(inbytes!=-1);
  367.        dataOut.flush();
  368.        dataOut.close();
  369.        showMessage("226 Closing data connection.Transfer Complete.");
  370.      }
  371.     catch(Exception e){
  372.       showMessage("550 Exception"+e);
  373.     }
  374.   }
  375. }