JAVA操作 FTP 下载文件

    /**       *        * JAVA操作 FTP 下载       * 文件下载。       *       */      private void ftpDownload()      {          FTPClient ftpClient = null;          InputStream input = null;          boolean loginFlag = false;          List<String> list = new ArrayList<String>();          try          {              int defaultPort = CommonsMessage.FTP_DEFAULT_PORT; // 21              int timeout = M400Constant.NUM_SIXTY_THOUSAND * M400Constant.NUM_TWO; // 120000              ftpClient = new FTPClient();                ftpClient.setDefaultPort(defaultPort);              ftpClient.setConnectTimeout(timeout);  //            ftpClient.setSoTimeout(timeout);              ftpClient.setDefaultTimeout(timeout);              ftpClient.setDataTimeout(timeout);              ftpClient.setControlEncoding("UTF-8");              FTPClientConfig conf = new FTPClientConfig(FTPClientConfig.SYST_UNIX);              conf.setServerLanguageCode("en");              conf.setDefaultDateFormatStr("MMM dd HH:mm");              ftpClient.configure(conf);                ftpClient.connect(SystemConfig.getKey("scpFtpIp"));              loginFlag = ftpClient.login(SystemConfig.getKey("scpFtpUserName").trim(),                      SystemConfig.getKey("scpFtpPassword").trim());              String ftpDir = SystemConfig.getKey("ftpHangupDir").trim();              if (!loginFlag)              {                  DEBUGGER.debug("login scp ftp is :" + loginFlag);              }              // String ftpDir = SystemConfig.getKey("ftpHangupDir").trim();                if (ftpClient.changeWorkingDirectory(ftpDir))              {                                      FTPFile file[] = ftpClient.listFiles(ftpDir);                    if (file != null && file.length > 0)                  {                      DEBUGGER.debug("hungup file size is:  " + file.length);                      for (int i = 0; i < file.length; i++)                      {                          String fileName = file[i].getName();                          ftpClient.setBufferSize(CommonsMessage.ONE_K_BUFFER_SIZE);                            // 设置文件类型（二进制）                          ftpClient.setFileType(FTP.BINARY_FILE_TYPE);                            input = ftpClient.retrieveFileStream(fileName);                          processInput(ftpClient, input, list, fileName);                            // if (downFlag) {                          // ftpClient.deleteFile(fileName);                          // }                      }                  }                  else                  {                      try                      {                          Thread.sleep(M400Constant.NUM_FIVE_THOUSAND);                      }                      catch (InterruptedException e)                      {                          /*                           * if (DEBUGGER.isDebugEnable()) {                           * DEBUGGER.debug("Failed to queryScpToQuery", e); }                           */                          error("Failed to queryScpToQuery", e);                      }                  }                }              else              {                  DEBUGGER.debug("scp dir is error ");              }            }          catch (Exception e)          {              /*               * DEBUGGER.debug("dowonload file is faild  ", e);               */              error("dowonload file is faild  ", e);          }          finally          {              close(input, "close inputStream  is faild  ");              if (ftpClient != null)              {                  try                  {                      deleteFile(ftpClient, list);                      boolean logoutFlag = false;                      try                      {                          logoutFlag = ftpClient.logout();                          // DEBUGGER.debug("logout : " + logoutFlag);                      }                      catch (Exception e)                      {                          /*                           * DEBUGGER.debug("logout : " + logoutFlag);                           */                          error("logout : " + logoutFlag, e);                      }                      ftpClient = null;                  }                  catch (Exception e)                  {                      /*                       * if (DEBUGGER.isDebugEnable()) {                       * DEBUGGER.error("Failed to ftpDownload", e); }                       */                      error("Failed to ftpDownload", e);                  }                  // try {                  // ftpClient.disconnect();                  // } catch (IOException e) {                  // if (DEBUGGER.isDebugEnable()) {                  // DEBUGGER.debug("Failed to ftpDownload", e);                  // }                  // }              }          }      }        /**       * 处理ftp对应文件输入流。       *        * @param ftpClient       *            ftp客户端对象       * @param input       *            ftp文件输入流       * @param list       *            处理完毕的文件列表，用于执行文件删除使用       * @param fileName       *            当前处理的文件名称       */      private void processInput(FTPClient ftpClient, InputStream input, List<String> list, String fileName)      {          if (input == null)          {              return;          }          // boolean downFlag = callingService(input);          callingService(input);          try          {              input.close();              ftpClient.completePendingCommand();              list.add(fileName);          }          catch (Exception e)          {              /*               * DEBUGGER.debug("Failed to ftpDownload", e);               */              error("Failed to ftpDownload", e);          }      }  }