配置 FTP 服务器以支持 IPv6

学习如何编写 Java 程序来与启用 IPv6 的 FTP 服务器通信

ftp_enable = 1
ftp_listen = 0.0.0.0@21
ftp_port_srcport = 20

package com.ibm.ipv6.ftp;

import java.io.BufferedInputStream;
import java.io.BufferedReader;
import java.io.File;
import java.io.FileOutputStream;
import java.io.InputStreamReader;

import sun.net.ftp.FtpClient;

/**
 * @author Makham Kumar
 *
 */
public class IPv6FTPClient extends FtpClient{

    private static final String sourceClass = "IPv6FTPClient";
    private static final String SPACE= " ";
    private static final String SEP = "-";
    private static final String LINE = "\n";

    public IPv6FTPClient(){ }

public static void main(String[] ipv6Main) {
      final String sourceMethod = "main";
      BufferedReader bRead = null;
      IPv6FTPClient ipv6Ins = null;
      String strOption = null;
      String strFileName = null;
      boolean bStatus = true;
	try {
   	      if(ipv6Main.length == 3)
   	      {
   	        ipv6Ins = new IPv6FTPClient();
   	        ipv6Ins.loginToMachine(ipv6Main[0], ipv6Main[1], ipv6Main[2]);
   	        ipv6Ins.listFileSets();
   	        // Capturing details from the user to download files from the FTP server

     	      do {
     	      console(LINE+LINE+SPACE+"Want to download a file ? [Y/N] : ");
              bRead = new BufferedReader(new InputStreamReader(System.in));
              strOption = bRead.readLine();
               if(strOption.equalsIgnoreCase("Y"))
               {
                console(LINE+SPACE+"Enter the file name to download : ");
                strFileName = bRead.readLine();
                bStatus = ipv6Ins.getFile(strFileName);
               }
               else if(strOption.equalsIgnoreCase("N"))
               {
                bStatus = false;
                ipv6Ins.closeServer();
                console(LINE+LINE+SPACE+"Closing the FTP server connection "+LINE);
               }
               else
               {
                bStatus = false;
                console(LINE+LINE+SPACE+"Entered invalid option.");
               }
              } while (bStatus);
               bRead.close();
          }
          else
          {
           console(LINE+"Entered invalid arguments");
          }
           console(LINE+LINE+SPACE+"Application existing !!!"+LINE+LINE);
         }catch(Exception eM)
          {
           eM.printStackTrace();
           console(LINE+"Application existing !!!"+LINE+LINE);
          }
         finally
         {
          try {
            if(bRead != null)
            bRead.close();
           } catch (Exception eFinally) {
            eFinally.printStackTrace();
           }
         }
 }


 /**
  * This utility method connects to FTP server using Username and Password
  * @return void
  */
 private void loginToMachine(String strMachine, String strUser, String strPasswd)
 {
    final String sourceMethod = "loginToMachine";
    try{
      openServer(strMachine);
      login(strUser,strPasswd);
      console(sourceMethod,"Successfully connected to FTP server");
      binary();
    } catch(Exception eLogin)
    {
    eLogin.printStackTrace();
    System.exit(0);
    }
 }


 /**
  * This utility method lists the names of the files in
  * the respective FTP user directory
  * @return void
  */
 private void listFileSets()
 {
    final String sourceMethod = "listFileSets";
    String fileName;
    BufferedReader reader = null;
    try{
        reader = new BufferedReader(new InputStreamReader(list()));
        while ((fileName = reader.readLine()) != null) {
        console(LINE+fileName);
            }
        reader.close();
       }catch(Exception eList)
       {
        eList.printStackTrace();
       }
       finally
       {
        try {
         if(reader != null)
         reader.close();
        }catch (Exception eFinally) {
         eFinally.printStackTrace();
       }
       }
 }


 /**
  * This utility method downloads the file from the FTP server to
  * the location where this Java program is executed
  * @return boolean
  */
 private boolean getFile(String fileName)
 {
    final String sourceMethod = "getFile";
    boolean bStatus = false;
    BufferedInputStream bInputStream = null; 
    FileOutputStream fOutputStream = null;
    String strPath = "."+File.separator+"download"+File.separator;
    try {
        bInputStream = new BufferedInputStream(get(fileName));
        fOutputStream = new FileOutputStream(strPath+fileName);
        int iStart = 0;
        byte[] byteArray = new byte[1024];

        while ((iStart = bInputStream.read(byteArray)) >= 0) {
           fOutputStream.write(byteArray, 0, iStart);
        }
        fOutputStream.close();
        bInputStream.close();
        console(sourceMethod,"Successfully downloaded the file : "+fileName);
        bStatus = true;
        } catch (Exception eGetFile) {
           eGetFile.printStackTrace();
        }
        finally
        {
		 try {
          if(fOutputStream != null)
           fOutputStream.close();
          if(bInputStream != null)
           bInputStream.close();
          } catch (Exception eFinally) {
           eFinally.printStackTrace();
          }
        }
    return bStatus;
  }


 /**
  * This utility method prints the text to console
  * @param String - Source method name
  * @param String - Message text
  * @return void
  */
 private static void console(String sourceMethod, String msgText)
 {
    System.out.println(LINE+SPACE+sourceClass+SEP+sourceMethod+SEP+msgText);
 }


 /**
  * This utility method prints the text to console
  * @param String - Message text
  * @return void
  */
 private static void console(String msgText)
 {
     System.out.print(msgText);
 }

}

set IPV6ADDRESS="$IPV6_ADDRESS"
set USERID="$USERID"
set PASSWD="$PASSWD"
set JAVA_HOME_15="$JAVA_HOME_15"

set IPV6ADDRESS="2002:9b8:708f:0:0:0:0:1"
set USERID="ipv6"
set PASSWD="ipv6"
set JAVA_HOME_15="C:\Makham\was\wasnd\java"		

Makham V. Kumar 在 IBM 印度软件实验室的 IBM WebSphere Partner Gateway 开发团队工作。他的主要兴趣是使用 Java 2 Platform Enterprise Edition (J2EE) 中的新技术，业务集成领域，以及基于开放源码和 WebSphere 开发工具。Makham 是毕业于印度 Belgaum 卡纳塔克邦大学的一名工程师。