import org.apache.commons.vfs.FileSystemOptions; //导入依赖的package包/类
public void init(ServletConfig servletConfig) throws ServletException {
  super.init(servletConfig);
  String rootUri = servletConfig.getInitParameter("vfs.uri");
  String authDomain = servletConfig.getInitParameter("vfs.auth.domain");
  String authUser = servletConfig.getInitParameter("vfs.auth.user");
  String authPass = servletConfig.getInitParameter("vfs.auth.password");
  try {
    StaticUserAuthenticator userAuthenticator =
            new StaticUserAuthenticator(authDomain, authUser, authPass);
    FileSystemOptions options = new FileSystemOptions();
    DefaultFileSystemConfigBuilder.getInstance().setUserAuthenticator(options, userAuthenticator);

    VFSBackend.initialize(rootUri, options);
  } catch (FileSystemException e) {
    LOG.error(String.format("can't create file system backend for '%s'", rootUri));
  }
}
 

import org.apache.commons.vfs.FileSystemOptions; //导入依赖的package包/类
public void setParameter(FileSystemOptions opts, String name, String value, String fullParameterName, String vfsUrl) throws IOException {
  // Use the DelgatingFileSystemOptionsBuilder to insert generic parameters
  // This must be done to assure the correct VFS FileSystem drivers will process the parameters
  String scheme = extractScheme(fullParameterName);
  try {
    DelegatingFileSystemOptionsBuilder delegateFSOptionsBuilder = new DelegatingFileSystemOptionsBuilder(KettleVFS.getInstance().getFileSystemManager());
    if(scheme != null) {
      delegateFSOptionsBuilder.setConfigString(opts, scheme, name, value);
    } else {
  	  log.logMinimal("Warning: Cannot process VFS parameters if no scheme is specified: " + vfsUrl); //$NON-NLS-1$
    }
  } catch (FileSystemException e) {
    if(e.getCode().equalsIgnoreCase("vfs.provider/config-key-invalid.error")) { //$NON-NLS-1$
      // This key is not supported by the default scheme config builder. This may be a custom key of another config builder
      log.logMinimal("Warning: The configuration parameter [" + name + "] is not supported by the default configuration builder for scheme: " + scheme);  //$NON-NLS-1$//$NON-NLS-2$
    } else {
      // An unexpected error has occurred loading in parameters
      throw new IOException(e.getLocalizedMessage());
    }
  }
}
 

import org.apache.commons.vfs.FileSystemOptions; //导入依赖的package包/类
private static FileSystemOptions buildFsOptions(VariableSpace varSpace, FileSystemOptions sourceOptions, String vfsFilename, String scheme) throws IOException {
  if(varSpace == null || vfsFilename == null) {
    // We cannot extract settings from a non-existant variable space
    return null;
  }
  
  IKettleFileSystemConfigBuilder configBuilder = KettleFileSystemConfigBuilderFactory.getConfigBuilder(varSpace, scheme);
  
  FileSystemOptions fsOptions = (sourceOptions == null) ? new FileSystemOptions() : sourceOptions;

  String[] varList = varSpace.listVariables();
  
  for(String var : varList) {
    if(var.startsWith("vfs.")) { //$NON-NLS-1$
      String param = configBuilder.parseParameterName(var, scheme);
      if(param != null) {
        configBuilder.setParameter(fsOptions, param, varSpace.getVariable(var), var, vfsFilename);
      } else {
        throw new IOException("FileSystemConfigBuilder could not parse parameter: " + var); //$NON-NLS-1$
      }
    }
  }
  return fsOptions;
}
 

import org.apache.commons.vfs.FileSystemOptions; //导入依赖的package包/类
public ZipFileSystem( final FileName rootName,
                      final FileObject parentLayer,
                      final FileSystemOptions fileSystemOptions )
  throws FileSystemException {
  super( rootName, parentLayer, fileSystemOptions );

  // Make a local copy of the file
  file = parentLayer.getFileSystem().replicateFile( parentLayer, Selectors.SELECT_SELF );

  // Open the Zip file
  if ( !file.exists() ) {
    // Don't need to do anything
    zipFile = null;
    return;
  }

  // zipFile = createZipFile(this.file);
}
 

import org.apache.commons.vfs.FileSystemOptions; //导入依赖的package包/类
/**
 * Locates a file object, by absolute URI.
 * @param baseFile The base FileObject.
 * @param uri The name of the file to locate.
 * @param properties The FileSystemOptions.
 * @return The FileObject if it is located, null otherwise.
 * @throws FileSystemException if an error occurs.
 */
public FileObject findFile(final FileObject baseFile,
                           final String uri,
                           final FileSystemOptions properties) throws FileSystemException
{
    // Split the URI up into its parts
    final LayeredFileName name = (LayeredFileName) parseUri(baseFile != null ? baseFile.getName() : null, uri);

    // Make the URI canonical

    // Resolve the outer file name
    final FileName fileName = name.getOuterName();
    final FileObject file = getContext().resolveFile(baseFile, fileName.getURI(), properties);

    // Create the file system
    final FileObject rootFile = createFileSystem(name.getScheme(), file, properties);

    // Resolve the file
    return rootFile.resolveFile(name.getPath());
}
 

import org.apache.commons.vfs.FileSystemOptions; //导入依赖的package包/类
/**
 * Locates a file object, by absolute URI.
 *
 * @param baseFile The base file object.
 * @param uri The URI of the file to locate
 * @param fileSystemOptions The FileSystem options.
 * @return The located FileObject
 * @throws FileSystemException if an error occurs.
 */
public FileObject findFile(final FileObject baseFile,
                           final String uri,
                           final FileSystemOptions fileSystemOptions) throws FileSystemException
{
    // Parse the URI
    final FileName name;
    try
    {
        name = parseUri(baseFile != null ? baseFile.getName() : null, uri);
    }
    catch (FileSystemException exc)
    {
        throw new FileSystemException("vfs.provider/invalid-absolute-uri.error", uri, exc);
    }

    // Locate the file
    return findFile(name, fileSystemOptions);
}
 

import org.apache.commons.vfs.FileSystemOptions; //导入依赖的package包/类
/**
 * Locates a file object, by absolute URI.
 * @param baseFile The base FileObject.
 * @param uri The file to find.
 * @param fileSystemOptions The options for the FileSystem.
 * @return A FileObject for the located file.
 * @throws FileSystemException if an error occurs.
 */
public FileObject findFile(final FileObject baseFile,
                           final String uri,
                           final FileSystemOptions fileSystemOptions)
    throws FileSystemException
{
    StringBuffer buf = new StringBuffer(INITIAL_BUFSZ);

    UriParser.extractScheme(uri, buf);

    String[] schemes = getSchemes();
    for (int iterSchemes = 0; iterSchemes < schemes.length; iterSchemes++)
    {
        buf.insert(0, ":");
        buf.insert(0, schemes[iterSchemes]);
    }

    FileObject fo = getContext().getFileSystemManager().resolveFile(buf.toString(), fileSystemOptions);
    return fo;
}
 

import org.apache.commons.vfs.FileSystemOptions; //导入依赖的package包/类
/**
 * Locates a file object, by absolute URI.
 */
public FileObject findFile(final FileObject baseFile,
                           final String uri,
                           final FileSystemOptions fileSystemOptions)
    throws FileSystemException
{
    StringBuffer buf = new StringBuffer(80);
    UriParser.extractScheme(uri, buf);
    String resourceName = buf.toString();

    ClassLoader cl = ResourceFileSystemConfigBuilder.getInstance().getClassLoader(fileSystemOptions);
    if (cl == null)
    {
        cl = getClass().getClassLoader();
    }
    final URL url = cl.getResource(resourceName);

    if (url == null)
    {
        throw new FileSystemException("vfs.provider.url/badly-formed-uri.error", uri);
    }

    FileObject fo = getContext().getFileSystemManager().resolveFile(url.toExternalForm());
    return fo;
}
 

import org.apache.commons.vfs.FileSystemOptions; //导入依赖的package包/类
protected TarFileSystem( final FileName rootName,
                         final FileObject parentLayer,
                         final FileSystemOptions fileSystemOptions )
  throws FileSystemException {
  super( rootName, parentLayer, fileSystemOptions );

  // Make a local copy of the file
  file = parentLayer.getFileSystem().replicateFile( parentLayer, Selectors.SELECT_SELF );

  // Open the Tar file
  if ( !file.exists() ) {
    // Don't need to do anything
    tarFile = null;
    return;
  }

  // tarFile = createTarFile(this.file);
}
 

import org.apache.commons.vfs.FileSystemOptions; //导入依赖的package包/类
/**
 * Create a file system with the S3 root provided.
 * 
 * @param fileName
 *          the S3 file name that defines the root (bucket)
 * @param fileSystemOptions
 *          file system options
 * @return an S3 file system
 * @throws FileSystemException
 *           if the file system cannot be created
 */
protected FileSystem doCreateFileSystem(FileName fileName, FileSystemOptions fileSystemOptions) throws FileSystemException {
	FileSystemOptions fsOptions = fileSystemOptions != null ? fileSystemOptions : getDefaultFileSystemOptions();
	
	// Initialize S3 service.
	UserAuthenticationData authData = null;

	try {
		// Read authData from file system options
		authData = UserAuthenticatorUtils.authenticate(fsOptions, AUTHENTICATOR_TYPES);

		// Fetch AWS key-id and secret key from authData
		String keyId 	= UserAuthenticatorUtils.toString(UserAuthenticatorUtils.getData(authData, UserAuthenticationData.USERNAME, null));
		String secret	= UserAuthenticatorUtils.toString(UserAuthenticatorUtils.getData(authData, UserAuthenticationData.PASSWORD, null));
		String domain = UserAuthenticatorUtils.toString(UserAuthenticatorUtils.getData(authData, UserAuthenticationData.DOMAIN, null));

		if (keyId.length() + secret.length() == 0) {
			throw new FileSystemException("Empty AWS credentials");
		}
		
		// Construct S3 file system
		return new S3FileSystem( (S3FileName)fileName, new S3AwImpl(keyId,secret,domain), fsOptions);
	} finally {
		UserAuthenticatorUtils.cleanup(authData);
	}

}
 

import org.apache.commons.vfs.FileSystemOptions; //导入依赖的package包/类
private Context(final FileSystemOptions fso, final String scheme, final String name, final Object[] values)
{
    this.fso = fso;
    this.scheme = scheme;
    this.name = name;
    this.values = values;
}
 

import org.apache.commons.vfs.FileSystemOptions; //导入依赖的package包/类
/**
    * Creates the filesystem.
    */
   protected FileSystem doCreateFileSystem(String scheme, final FileObject file, final FileSystemOptions fileSystemOptions)
       throws FileSystemException
{
	final FileName name =
		new LayeredFileName(scheme, file.getName(), FileName.ROOT_PATH, FileType.FOLDER);
       return new MimeFileSystem(name, file, fileSystemOptions);
   }
 

import org.apache.commons.vfs.FileSystemOptions; //导入依赖的package包/类
/**
 * Creates a layered file system.  This method is called if the file system
 * is not cached.
 *
 * @param scheme The URI scheme.
 * @param file   The file to create the file system on top of.
 * @return The file system.
 */
protected FileSystem doCreateFileSystem(final String scheme,
                                        final FileObject file,
                                        final FileSystemOptions fileSystemOptions)
    throws FileSystemException
{
    final FileName rootName =
        new LayeredFileName(scheme, file.getName(), FileName.ROOT_PATH, FileType.FOLDER);
    return new ZipFileSystem(rootName, file, fileSystemOptions);
}
 

import org.apache.commons.vfs.FileSystemOptions; //导入依赖的package包/类
/**
 * Creates a layered file system.  This method is called if the file system
 * is not cached.
 *
 * @param scheme The URI scheme.
 * @param file   The file to create the file system on top of.
 * @return The file system.
 */
protected FileSystem doCreateFileSystem(final String scheme,
                                        final FileObject file,
                                        final FileSystemOptions fileSystemOptions)
    throws FileSystemException
{
    final FileName name =
        new LayeredFileName(scheme, file.getName(), FileName.ROOT_PATH, FileType.FOLDER);
    return new JarFileSystem(name, file, fileSystemOptions);
}
 

import org.apache.commons.vfs.FileSystemOptions; //导入依赖的package包/类
public LocalFileSystem(final FileName rootName,
                       final String rootFile,
                       final FileSystemOptions opts)
{
    super(rootName, null, opts);
    this.rootFile = rootFile;
}
 

import org.apache.commons.vfs.FileSystemOptions; //导入依赖的package包/类
/**
 * Creates the filesystem.
 */
protected FileSystem doCreateFileSystem(final FileName name, final FileSystemOptions fileSystemOptions)
    throws FileSystemException
{
    // Create the file system
    final LocalFileName rootName = (LocalFileName) name;
    return new LocalFileSystem(rootName, rootName.getRootFile(), fileSystemOptions);
}
 

import org.apache.commons.vfs.FileSystemOptions; //导入依赖的package包/类
/**
 * Locate a file by name.
 */
public FileObject resolveFile(final FileObject baseFile, final String name,
                              final FileSystemOptions fileSystemOptions)
    throws FileSystemException
{
    return manager.resolveFile(baseFile, name, fileSystemOptions);
}
 

import org.apache.commons.vfs.FileSystemOptions; //导入依赖的package包/类
/**
 * @param rootName
 * @param fileSystemOptions
 */
protected RamFileSystem(FileName rootName,
        FileSystemOptions fileSystemOptions)
{
    super(rootName, null, fileSystemOptions);
    this.cache = Collections.synchronizedMap(new HashMap());
    // create root
    RamFileData rootData = new RamFileData(rootName) ;
    rootData.setType(FileType.FOLDER);
    rootData.setLastModified(System.currentTimeMillis());
    this.cache.put(rootName, rootData);
}
 

import org.apache.commons.vfs.FileSystemOptions; //导入依赖的package包/类
@Override
public FileObject resolveFile(FileObject baseFile, String uri) throws FileSystemException {
    final FileSystemOptions options;
    if (baseFile == null)
        options = defaultOptions;
    else
        options = baseFile.getFileSystem().getFileSystemOptions();
    return resolveFile(baseFile, uri, options);
}
 

import org.apache.commons.vfs.FileSystemOptions; //导入依赖的package包/类
/**
 * Returns the base folder for tests.
 */
public FileObject getBaseTestFolder(final FileSystemManager manager)
    throws Exception
{
    WebdavFileSystemConfigBuilder builder =
        (WebdavFileSystemConfigBuilder)manager.getFileSystemConfigBuilder("webdav");
    final String uri = System.getProperty(TEST_URI);
    FileSystemOptions opts = new FileSystemOptions();
    builder.setRootURI(opts, uri);
    return manager.resolveFile(uri, opts);
}