模防CSDN的DBB博客系统。

package org.ponly.fs.ftp; import org.apache.commons.net.ftp.FTP; import org.apache.commons.net.ftp.FTPClient; import org.apache.commons.net.ftp.FTPFile; import org.apache.commons.net.ftp.FTPReply; import org.ponly.fs.FileSystemException; import org.ponly.fs.FileView; import org.ponly.fs.FileSystem; import org.ponly.fs.util.MonitorInputStream; import org.ponly.fs.util.Path; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import java.io.*; import java.net.SocketException; import static org.ponly.fs.FileSystemException.rethrowFileSystemException; import static org.ponly.fs.FileView.*; /** * 基于 FTP 的文件系统实现 * * @author vacoor */ public class FtpFileSystem implements FileSystem { private static final Logger LOG = LoggerFactory.getLogger(FtpFileSystem.class); private static final String CURRENT_DIR = "."; // 当前目录 private static final String PARENT_DIR = ".."; // 上级目录 private static final String DEFAULT_CONTROL_ENCODING = "utf-8"; private static final int DEFAULT_BUFFER_SIZE = 1024 * 1024; public static final int DEFAULT_PORT = FTP.DEFAULT_PORT; private String host; // FTP host private int port; // FTP port private String username; // FTP username private String password; // FTP password private String chroot; /** * {@inheritDoc} */ @Override public boolean exists(String path) throws FileSystemException { return null != stat(path); } /** * {@inheritDoc} */ @Override public FileView stat(String path) throws FileSystemException { try { final FTPClient ftp = connect(); try { return stat(ftp, path); } finally { disconnect(ftp); } } catch (Throwable ex) { return rethrowFileSystemException(ex); } } /** * {@inheritDoc} */ @Override public FileView[] ls(String path) throws FileSystemException { try { final FTPClient ftp = connect(); try { return ls(ftp, path); } finally { disconnect(ftp); } } catch (Throwable ex) { return rethrowFileSystemException(ex); } } /** * {@inheritDoc} */ @Override public boolean mkdirs(String path) throws FileSystemException { try { final FTPClient ftp = connect(); try { return mkdirs(ftp, path); } finally { disconnect(ftp); } } catch (Throwable ex) { return rethrowFileSystemException(ex); } } /** * {@inheritDoc} */ @Override public InputStream open(String file) throws FileSystemException { return open(file, DEFAULT_BUFFER_SIZE); } /** * 打开给定路径的文件, 如果给定路径不存在返回null, 如果不是文件将抛出异常 * <p/> * 注: 关闭输入流时才会关闭相关资源, 因此读取完毕后务必关闭输入流 * * @param file 文件路径 * @param bufferSize 缓冲区大小 * @return 文件输入流或null * @throws FileSystemException */ public InputStream open(String file, int bufferSize) throws FileSystemException { try { final FTPClient ftp = connect(); String absolutePath = resolveRemoteAbsolutePath(ftp, file); try { FileView stat = stat(ftp, absolutePath); if (null == stat) { disconnect(ftp); return null; } if (stat.isDirectory()) { disconnect(ftp); throw new FileSystemException("Path " + file + " is a directory."); } ftp.allocate(bufferSize); Path absPath = Path.get(absolutePath); String pathName = absPath.getName(); String absoluteParent = absPath.getParent().getPath(); // Change to parent directory on the // server. Only then can we read the // file // on the server by opening up an InputStream. As a side effect the working // directory on the server is changed to the parent directory of the file. // The FTP client connection is closed when close() is called on the // FSDataInputStream. ftp.changeWorkingDirectory(absoluteParent); InputStream is = ftp.retrieveFileStream(pathName); InputStream fis = new MonitorInputStream(is) { @Override protected void onClosed() throws IOException { if (!ftp.isConnected()) { throw new IOException("FTPClient not connected"); } boolean completed = ftp.completePendingCommand(); disconnect(ftp); if (!completed) { throw new IOException("Could not complete transfer, Reply Code - " + ftp.getReplyCode()); } } }; if (!FTPReply.isPositivePreliminary(ftp.getReplyCode())) { // The ftpClient is an inconsistent state. Must close the stream // which in turn will logout and disconnect from FTP server fis.close(); throw new FileSystemException("Unable to open file: " + file + ", Aborting"); } return fis; } catch (IOException ex) { disconnect(ftp); throw ex; } } catch (Throwable ex) { return rethrowFileSystemException(ex); } } /** * {@inheritDoc} */ @Override public OutputStream create(String file, boolean override) throws FileSystemException { return create(file, null, override); } /** * {@inheritDoc} */ @Override public OutputStream create(String file, String contentType, boolean override) throws FileSystemException { return create(file, override, DEFAULT_BUFFER_SIZE); } /** * 获取一个创建文件的输出流并自动创建相关目录, 当 override = false, 如果文件已经存在则抛出异常 * * @param file 文件路径 * @param override 是否覆盖 * @param bufferSize 缓冲区大小 * @throws FileSystemException */ public OutputStream create(String file, boolean override, int bufferSize) throws FileSystemException { try { final FTPClient ftp = connect(); String absolutePath = resolveRemoteAbsolutePath(ftp, file); if (null != stat(ftp, absolutePath)) { if (!override) { disconnect(ftp); throw new FileSystemException("File already exists: " + file); } try { rm(ftp, absolutePath, true, true); } catch (IOException ex) { disconnect(ftp); throw new FileSystemException("Can't override file: " + file); } } Path absPath = Path.get(absolutePath); String pathName = absPath.getName(); String absoluteParent = absPath.getParent().getPath(); if (null == absoluteParent || !mkdirs(ftp, absoluteParent)) { absoluteParent = (absoluteParent == n