GT4 开发：将 GridFTP 与 Jakarta Commons Virtual File System 集成在一起

<providers>
    <!--  Vladimir GsiFTP aka GridFTP -->
    <provider 
      class-name="org.apache.commons.vfs.provider.gsiftp.GsiFtpFileProvider">
        <scheme name="gsiftp"/>
    </provider>
</providers>

package org.apache.commons.vfs.provider.gsiftp;

import org.apache.commons.vfs.FileSystemException;
import org.apache.commons.vfs.FileSystemOptions;
import org.globus.ftp.GridFTPClient;

import java.io.IOException;

/**
 * Create a GridFtpClient instance
 *
 * @author Mario Ivankovits
 * @author Vladimir Silva
 * @version $Revision$ $Date: 2005-10-14 10:59:47 -0700 (Fri, 14 Oct 2005) $
 */
public class GsiFtpClientFactory
{
    static String Host; 
    static int Port;
	
    private GsiFtpClientFactory()
    {
    }

    /**
     * Creates a new connection to the server.
     */
    public static GridFTPClient createConnection(String hostname
, int port
	, String username, String password
	, FileSystemOptions fileSystemOptions) 

    throws FileSystemException
    {
    	Host = hostname;
    	Port = port;
    	
        try
        {
            if ( password == null)
        		throw new Exception("Password cannot be null");
        	
            // Create a proxy cert (if missing)
            new ProxyTool().createProxy(password);
        	
	        final GridFTPClient client = 
				new GridFTPClient(hostname, port);

            try
            {
            	// Authenticate w/ user credentials 
			// defined in $HOME/.globus/cog.properties
                	client.authenticate(null);

            }
            catch (final IOException e)
            {
                if (client != null ) 
                    client.close();
                throw e;
            }

            return client;
        }
        catch (final Exception exc)
        {
            throw new FileSystemException(
				"vfs.provider.gsiftp/connect.error"
				, new Object[]{hostname}, exc);
        }
    }
}

/*
 * Load a cert from a given path
 */
private void loadCertificates(String path)
        throws GeneralSecurityException, IOException
{
      certificates = new X509Certificate[] { CertUtil
                      .loadCertificate(path) };
}

/**
 * Load user key and decrypt it
 * @param keyPath path to the private key ($HOME/.globus/userkey.pem)
 * @param pwd User key decryption passphrase
 * @throws GeneralSecurityException
 */
private void loadKey(String keyPath, String pwd)
        throws GeneralSecurityException
{
    try {
        OpenSSLKey key = new BouncyCastleOpenSSLKey(keyPath);

        if (key.isEncrypted()) {
                    key.decrypt(pwd);
        }

        userKey = key.getPrivateKey();

    } catch (IOException e) {
        throw new GeneralSecurityException
			("Error: Failed to load key: " + keyPath);
    } catch (GeneralSecurityException e) {
          throw new GeneralSecurityException
			("Error: Wrong pass phrase");
    }
}

/*
 * Verify proxy by comparing the modulus of the public and
 * private keys
 */
private void verify() throws GeneralSecurityException 
{
     RSAPublicKey pkey = (RSAPublicKey)
		this.certificates[0].getPublicKey();

     RSAPrivateKey prkey = (RSAPrivateKey) userKey;

     if (!pkey.getModulus().equals(prkey.getModulus())) {
         throw new GeneralSecurityException(
            "Certificate and private key specified do not match");
     }
}

/**
 * Check for expired proxy
 * @return true if expired proxy
 * @throws GlobusCredentialException if no proxy found
 */
public boolean proxyExpired() 
{
    try {
        long t = new GlobusCredential(
                CoGProperties.getDefault().getProxyFile()).
					getTimeLeft();
        return (t == 0) ? true : false;	
    } catch (GlobusCredentialException e) {
            return true;
    }
}

/**
 * Grid Security Infrastructure (GSI) Authentication tokens
 */
String user = "vsilva";  	// user name
String pwd = "2p2dkdt";  	// user key pass phrase (used to decrypt it)
String path = "";        		// Server Path
String host = "ebony";   	// GridFTP host name
int port = 2811;         		// default port


/*
 * Obtain a FileSystem Manager: used o resolve URIs or
 * create file systems
 */
FileSystemManager fsManager = VFS.getManager();

//
// Build a VFS GSIFTP URI
//
String uri = "gsiftp://" + user + ":" + pwd + "@" + host 
        + ":" + port + "/" + path;

//
// A File Object for the GsiFTP server
//
FileObject fo = fsManager.resolveFile(uri);

// List the contents of the file object
FileObject[] children = fo.getChildren();
FileObject f = null;
FileContent c = null;

System.out.println( "Children of " + fo.getName() );

for ( int i = 0; i < children.length; i++ )
{
    f = children[ i ];
    c = f.getContent();

    final long size = ( f.getType() == FileType.FILE ) ? c.getSize() : -1;
    final long date = ( f.getType() == FileType.FILE ) ? c.getLastModifiedTime() : -1;
    System.out.println( f.getName().getPath() 
                + " date:" + date 
                + " Size:" + size  );
}