Java 类org.apache.commons.net.ftp.FTPFile 实例源码

项目：hadoop-oss 文件：FTPFileSystem.java

/**
 * Convert the file information in FTPFile to a {@link FileStatus} object. *
 * 
 * @param ftpFile
 * @param parentPath
 * @return FileStatus
 */
private FileStatus getFileStatus(FTPFile ftpFile, Path parentPath) {
  long length = ftpFile.getSize();
  boolean isDir = ftpFile.isDirectory();
  int blockReplication = 1;
  // Using default block size since there is no way in FTP client to know of
  // block sizes on server. The assumption could be less than ideal.
  long blockSize = DEFAULT_BLOCK_SIZE;
  long modTime = ftpFile.getTimestamp().getTimeInMillis();
  long accessTime = 0;
  FsPermission permission = getPermissions(ftpFile);
  String user = ftpFile.getUser();
  String group = ftpFile.getGroup();
  Path filePath = new Path(parentPath, ftpFile.getName());
  return new FileStatus(length, isDir, blockReplication, blockSize, modTime,
      accessTime, permission, user, group, filePath.makeQualified(this));
}

项目：hadoop 文件：FTPFileSystem.java

/**
 * Convert the file information in FTPFile to a {@link FileStatus} object. *
 * 
 * @param ftpFile
 * @param parentPath
 * @return FileStatus
 */
private FileStatus getFileStatus(FTPFile ftpFile, Path parentPath) {
  long length = ftpFile.getSize();
  boolean isDir = ftpFile.isDirectory();
  int blockReplication = 1;
  // Using default block size since there is no way in FTP client to know of
  // block sizes on server. The assumption could be less than ideal.
  long blockSize = DEFAULT_BLOCK_SIZE;
  long modTime = ftpFile.getTimestamp().getTimeInMillis();
  long accessTime = 0;
  FsPermission permission = getPermissions(ftpFile);
  String user = ftpFile.getUser();
  String group = ftpFile.getGroup();
  Path filePath = new Path(parentPath, ftpFile.getName());
  return new FileStatus(length, isDir, blockReplication, blockSize, modTime,
      accessTime, permission, user, group, filePath.makeQualified(this));
}

项目：JAVA- 文件：FtpClient.java

/** 获得目录下最大文件名 */
public String getMaxFileName(String remotePath) {
    try {
        ftpClient.changeWorkingDirectory(remotePath);
        FTPFile[] files = ftpClient.listFiles();
        Arrays.sort(files, new Comparator<FTPFile>() {
            public int compare(FTPFile o1, FTPFile o2) {
                return o2.getName().compareTo(o1.getName());
            }
        });
        return files[0].getName();
    } catch (IOException e) {
        logger.error("", e);
        throw new FtpException("FTP访问目录[" + remotePath + "]出错!", e);
    }
}

项目：hadoop-oss 文件：FTPFileSystem.java

/**
 * Convenience method, so that we don't open a new connection when using this
 * method from within another method. Otherwise every API invocation incurs
 * the overhead of opening/closing a TCP connection.
 */
private FileStatus[] listStatus(FTPClient client, Path file)
    throws IOException {
  Path workDir = new Path(client.printWorkingDirectory());
  Path absolute = makeAbsolute(workDir, file);
  FileStatus fileStat = getFileStatus(client, absolute);
  if (fileStat.isFile()) {
    return new FileStatus[] { fileStat };
  }
  FTPFile[] ftpFiles = client.listFiles(absolute.toUri().getPath());
  FileStatus[] fileStats = new FileStatus[ftpFiles.length];
  for (int i = 0; i < ftpFiles.length; i++) {
    fileStats[i] = getFileStatus(ftpFiles[i], absolute);
  }
  return fileStats;
}

项目：hadoop-oss 文件：FTPFileSystem.java

/**
 * Convenience method, so that we don't open a new connection when using this
 * method from within another method. Otherwise every API invocation incurs
 * the overhead of opening/closing a TCP connection.
 */
private FileStatus getFileStatus(FTPClient client, Path file)
    throws IOException {
  FileStatus fileStat = null;
  Path workDir = new Path(client.printWorkingDirectory());
  Path absolute = makeAbsolute(workDir, file);
  Path parentPath = absolute.getParent();
  if (parentPath == null) { // root dir
    long length = -1; // Length of root dir on server not known
    boolean isDir = true;
    int blockReplication = 1;
    long blockSize = DEFAULT_BLOCK_SIZE; // Block Size not known.
    long modTime = -1; // Modification time of root dir not known.
    Path root = new Path("/");
    return new FileStatus(length, isDir, blockReplication, blockSize,
        modTime, root.makeQualified(this));
  }
  String pathName = parentPath.toUri().getPath();
  FTPFile[] ftpFiles = client.listFiles(pathName);
  if (ftpFiles != null) {
    for (FTPFile ftpFile : ftpFiles) {
      if (ftpFile.getName().equals(file.getName())) { // file found in dir
        fileStat = getFileStatus(ftpFile, parentPath);
        break;
      }
    }
    if (fileStat == null) {
      throw new FileNotFoundException("File " + file + " does not exist.");
    }
  } else {
    throw new FileNotFoundException("File " + file + " does not exist.");
  }
  return fileStat;
}

项目：iBase4J-Common 文件：FtpClient.java

/** 获得目录下最大文件名 */
public String getMaxFileName(String remotePath) {
    try {
        ftpClient.changeWorkingDirectory(remotePath);
        FTPFile[] files = ftpClient.listFiles();
        Arrays.sort(files, new Comparator<FTPFile>() {
            public int compare(FTPFile o1, FTPFile o2) {
                return o2.getName().compareTo(o1.getName());
            }
        });
        return files[0].getName();
    } catch (IOException e) {
        logger.error("", e);
        throw new FtpException("FTP访问目录[" + remotePath + "]出错!", e);
    }
}

项目：xdman 文件：MVSFTPEntryParser.java

/**
 * Parses a line of an z/OS - MVS FTP server file listing and converts it
 * into a usable format in the form of an <code> FTPFile </code> instance.
 * If the file listing line doesn't describe a file, then
 * <code> null </code> is returned. Otherwise a <code> FTPFile </code>
 * instance representing the file is returned.
 *
 * @param entry
 *            A line of text from the file listing
 * @return An FTPFile instance corresponding to the supplied entry
 */
public FTPFile parseFTPEntry(String entry) {
    boolean isParsed = false;
    FTPFile f = new FTPFile();

    if (isType == FILE_LIST_TYPE) {
        isParsed = parseFileList(f, entry);
    } else if (isType == MEMBER_LIST_TYPE) {
        isParsed = parseMemberList(f, entry);
        if (!isParsed) {
            isParsed = parseSimpleEntry(f, entry);
        }
    } else if (isType == UNIX_LIST_TYPE) {
        isParsed = parseUnixList(f, entry);
    } else if (isType == JES_LEVEL_1_LIST_TYPE) {
        isParsed = parseJeslevel1List(f, entry);
    } else if (isType == JES_LEVEL_2_LIST_TYPE) {
        isParsed = parseJeslevel2List(f, entry);
    }

    if (!isParsed) {
        f = null;
    }

    return f;
}

项目：MinecraftServerSync 文件：FTPSyncClient.java

private long getTotalRemoteFileSize(Collection<String> fileNames) {
    try {
        Future<Long> fileSizeResult = perform(() -> {
            return fileNames.stream()
                    .map(rethrow((String fileName) -> {
                        FTPFile[] ftpFiles = ftpClient.listFiles(fileName);
                        if (ftpFiles.length != 1 || !ftpFiles[0].isFile()) {
                            return 0L;
                        } else {
                            return ftpFiles[0].getSize();
                        }
                    }))
                    .mapToLong(Long::valueOf)
                    .sum();
        });
        return AsyncUtil.getResult(fileSizeResult);
    } catch (ExecutionException e) {
        LOGGER.warn("Error while calculating download file size, progress will not be available.");
        LogUtil.stacktrace(LOGGER, e);
        return 0;
    }
}

项目：automat 文件：FtpClient.java

/**
 * 下载
 * 
 * @param remotePath 下载目录
 * @param localPath 本地目录
 * @return
 * @throws Exception
 */
public boolean downLoadFile(String remotePath, String localPath) throws FtpException {
    synchronized (LOCK) {
        try {
            if (ftpClient.changeWorkingDirectory(remotePath)) {// 转移到FTP服务器目录
                FTPFile[] files = ftpClient.listFiles();
                if (files.length > 0) {
                    File localdir = new File(localPath);
                    if (!localdir.exists()) {
                        localdir.mkdir();
                    }
                }
                for (FTPFile ff : files) {
                    if (!downLoadFile(ff, localPath)) {
                        return false;
                    }
                }
                return files.length > 0;
            }
        } catch (IOException e) {
            logger.error("", e);
            throw new FtpException("FTP下载[" + localPath + "]出错!", e);
        }
        return false;
    }
}

项目：automat 文件：FtpClient.java

/** 获得目录下最大文件名 */
public String getMaxFileName(String remotePath) {
    try {
        ftpClient.changeWorkingDirectory(remotePath);
        FTPFile[] files = ftpClient.listFiles();
        Arrays.sort(files, new Comparator<FTPFile>() {
            public int compare(FTPFile o1, FTPFile o2) {
                return o2.getName().compareTo(o1.getName());
            }
        });
        return files[0].getName();
    } catch (IOException e) {
        logger.error("", e);
        throw new FtpException("FTP访问目录[" + remotePath + "]出错!", e);
    }
}

项目：easyfilemanager 文件：NetworkFile.java

public NetworkFile(NetworkFile dir, FTPFile file) {
    String name = file.getName();
    String dirPath = dir.getPath();
    host = dir.host;
    this.file = file;
    if (name == null) {
        throw new NullPointerException("name == null");
    }
    if (dirPath == null || dirPath.isEmpty()) {
        this.path = fixSlashes(name);
    } else if (name.isEmpty()) {
        this.path = fixSlashes(dirPath);
    } else {
        this.path = fixSlashes(join(dirPath, name));
    }
}

项目：mumu 文件：FtpClient.java

/**
 * 下载
 * 
 * @param remotePath 下载目录
 * @param localPath 本地目录
 * @return
 * @throws Exception
 */
public boolean downLoadFile(String remotePath, String localPath) throws FtpException {
    synchronized (LOCK) {
        try {
            if (ftpClient.changeWorkingDirectory(remotePath)) {// 转移到FTP服务器目录
                FTPFile[] files = ftpClient.listFiles();
                if (files.length > 0) {
                    File localdir = new File(localPath);
                    if (!localdir.exists()) {
                        localdir.mkdir();
                    }
                }
                for (FTPFile ff : files) {
                    if (!downLoadFile(ff, localPath)) {
                        return false;
                    }
                }
                return files.length > 0;
            }
        } catch (IOException e) {
            logger.error("", e);
            throw new FtpException("FTP下载[" + localPath + "]出错!", e);
        }
        return false;
    }
}