apache commons-vfs简单用法

andyyuduo

这段时间又开始忙起来了，所以apache commons-vfs源码赏析就暂时搁置起来了，在这里先写一下apache commons-vfs的一些简单的用法，也可以去参考apache commons-vfs源文件中自己提供的一些demo.废话不多说，直接上代码

package com.zzg.util;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import org.apache.commons.lang.StringUtils;
import org.apache.commons.vfs.FileObject;
import org.apache.commons.vfs.FileSystemException;
import org.apache.commons.vfs.FileSystemManager;
import org.apache.commons.vfs.FileType;
import org.apache.commons.vfs.Selectors;
import org.apache.commons.vfs.VFS;
public class FileUtil {
private static FileSystemManager fsm = null;
static {
try {
fsm = VFS.getManager();
} catch (FileSystemException e) {
e.printStackTrace();
}
}
public static FileObject getFile(String path){
try {
return fsm.resolveFile(path);
} catch (FileSystemException e) {
e.printStackTrace();
return null;
}
}
public static void delete(String path) {
try {
FileObject fo = fsm.resolveFile(path);
fo.delete();
} catch (FileSystemException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
public static boolean isDirectory(String path) {
try {
FileObject fo = fsm.resolveFile(path);
return fo.getType().equals(FileType.FOLDER);
} catch (FileSystemException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return false;
}
public static InputStream getInputStream(String path){
try {
FileObject fo = fsm.resolveFile(path);
return fo.getContent().getInputStream();
} catch (FileSystemException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return null;
}
public static OutputStream getOutputStream(String path){
try {
FileObject fo = fsm.resolveFile(path);
return fo.getContent().getOutputStream();
} catch (FileSystemException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return null;
}
public static boolean isFile(String path) {
try {
FileObject fo = fsm.resolveFile(path);
return fo.getType().equals(FileType.FILE);
} catch (FileSystemException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return false;
}
/**
* 函数描述：根据传入的文件路径创建文件夹(包括各级父文件夹)。如果路径中有文件，会自动去掉文件名。 （文件的判断是
* 以最后一个"/"之后是否有"."为标识的，）
*
* @param path
* @return 如果创建成功，返回true；否则，返回false;
*/
public static boolean mkdirs(String path) {
String realPath = "";
path = path.replaceAll("\\\\", "/");
// 如果该路径已"/"结尾，则整个字符串都是路径
if (path.endsWith("/")) {
realPath = path;
} else {
int fileNamePoint = path.lastIndexOf("/");
// 获取真正的路径
if (fileNamePoint >= 0) {
realPath = path.substring(0, fileNamePoint);
}
// 读取文件名
String fileName = path.substring(fileNamePoint + 1);
// 如果读取的文件名中没有"."，说明整个字符串都是路径
if (fileName.indexOf(".") < 0) {
realPath = path;
}
}
try {
FileObject fo = fsm.resolveFile(realPath);
fo.createFolder();
return true;
} catch (Exception e) {
return false;
}
}
/**
* 函数描述：对文件进行copy
*
* @param sourceFilePath
*            源文件的全部路径+文件名
* @param targetFilePath
*            目标文件的全部路径+文件名
* @param overWrite
*            如果目标文件存在，是否覆盖。true:覆盖；false:不覆盖(当源文件和目标文件都存在并且不覆盖时,返回true)。
* @return true:成功；false:失败; (当源文件和目标文件都存在并且不覆盖时,返回true)。
*/
public static boolean copyFile(String sourceFilePath, String targetFilePath, boolean overWrite) throws IOException {
if (StringUtils.isBlank(sourceFilePath) || StringUtils.isBlank(targetFilePath)) {
throw new IOException("源文件或者目标文件为空");
}
FileObject from = fsm.resolveFile(sourceFilePath);
FileObject to = fsm.resolveFile(targetFilePath);
if (to.exists()) {
if (to.getType() == FileType.FILE) {
if (overWrite && !to.delete()) {
throw new IOException("目标文件[" + targetFilePath + "]被保护，不能被覆盖！");
} else if (!overWrite) {
throw new IOException("目标文件[" + targetFilePath + "]已经存在！");
}
}
}
to.copyFrom(from, Selectors.SELECT_ALL);
return true;
}
/**
* 函数描述：
*
* @param args
* @throws IOException
*/
public static void main(String[] args) throws IOException {
//copyFile("e:/crpt.txt","e:/crpt",true);
moveFile("M:/u-dsm/store/store/enterprise/a9845232-bea2-4d9e-92be-d16cfcdcea01/ad5b00475fd0408aaed2eb195bf90913.docx","M:/u-dms/a9845232-bea2-4d9e-92be-d16cfcdcea01/ad5b00475fd0408aaed2eb195bf90913.docx", true);
// copyFile("ftp://zzg:zzg@192.168.1.100/test/teeee/fff","smb://user:user@192.168.1.100/共享/1.txt",true);
// copyFile("smb://user:user@192.168.1.100/共享/1.txt","file://e:/ffff",true);
//moveFile("ftp://zzg:zzg@192.168.1.100/test1/teeee2/fff1", "ftp://unis:unis@192.168.1.100/test/teeee/fff", true);
// copyFile("file://e:/crpt.txt","file://e:/crpt",true);
}
/**
* Moving a File to Another File ,没有进行磁盘空间大小的判断
*
* @param srcFile
*            源文件 eg: c:\windows\abc.txt
* @param targetFile
*            目标文件 eg: c:\temp\abc.txt
* @param overwrite
*            如果目标文件存在，是否覆盖
* @return success
*/
public static boolean moveFile(String srcFile, String targetFile, boolean overWrite) throws IOException {
if (srcFile.equals(targetFile)) {
return true;
}
FileObject src = fsm.resolveFile(srcFile);
// File (or directory) to be moved
if (StringUtils.isNotBlank(srcFile) && !src.exists()) {
throw new IOException("源文件[" + srcFile + "]不存在");
}
// Destination directory
FileObject to = fsm.resolveFile(targetFile);
if (to.exists()) {
if (to.getType() == FileType.FILE) {
if (overWrite && !to.delete()) {
throw new IOException("目标文件[" + targetFile + "]被保护，不能被覆盖！");
} else if (!overWrite) {
throw new IOException("目标文件[" + targetFile + "]已经存在！");
}
}
}
src.moveTo(to);
return true;
}