Howto: VFSLib - Apache Commons VFS Reloaded

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36

 // We use the default file system manager here
 DefaultFileSystemManager fsmanager = (DefaultFileSystemManager) VFS.getManager();

 // Connect to anonymous FTP server, copy file over to SFTP server
 String ftpuri = "ftp://kernel.org/pub/site/README";
 String sftpuri = "sftp://scott:tiger@mycompany.com:22/mydir/README";

 // SFTP needs a little configuring
 FileSystemOptions options = new FileSystemOptions();
 SftpFileSystemConfigBuilder builder = SftpFileSystemConfigBuilder.getInstance();
 builder.setStrictHostKeyChecking(options, "no"); // Loose checking
 builder.setUserDirIsRoot(options, false); // "/" is root

 try {
 // Open input stream for FTP file (read from)
 FileObject ftpobj = fsmanager.resolveFile(ftpuri); // Throws
 InputStream istream = ftpobj.getContent().getInputStream();

 // Open output stream for SFTP file (write into)
 FileObject sftpobj = fsmanager.resolveFile(sftpuri, options); // Throws
 OutputStream ostream = sftpobj.getContent().getOutputStream();

 // Copy bytes
 int len;
 byte[] buffer = new byte[1024];
 while ((len = istream.read(buffer)) != -1) {
 ostream.write(buffer, 0, len);
 }
 ostream.flush();
 ostream.close();
 istream.close();

 long size = sftpobj.getContent().getSize();
 boolean success = sftpobj.exists() && size == ftpobj.getContent().getSize();
 }
 catch (Exception e) { e.printStackTrace(); }

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31

// Setup the main VFSLib instance, get evaluation license key from Leisenfels website
VFSLib vfslib = new VFSLib();
vfslib.setLicenseFile(licensefile); // Import from file

// We use an optimized file system manager here
VFSFileSystemManager vfsmanager = new VFSFileSystemManager();

// Add Dropbox provider to VFS
DbxFileProvider provider = vfslib.addProviderDropbox(vfsmanager, appkey, appsecret, 
 clientidentifier, language);
String scheme = vfslib.getSchemeDropbox();

// Pass access token over to VFSLib to access the Dropbox account
FileSystemOptions options = new FileSystemOptions();
DbxFileSystemConfigBuilder builder = new DbxFileSystemConfigBuilder();
builder.setAccessToken(options, token);
builder.setChunkSize(options, 4096); // Allow data portions being transferred

// Setup proper account name, the user name for Dropbox URLs (default: anonymous)
// dropbox://[name]:[token]@dropbox.com
String username = "johndoe";
builder.setAccountDisplayName(options, username);

// Configure a VFSConnection based on these parameters (optimization, non-standard VFS)
Configuration config = new Configuration();
config.setObject(VFSConnection.VAR_PROTOCOL, scheme);
config.setObject(VFSConnection.PARAM_HOST, "dropbox.com");
config.setObject(VFSConnection.PARAM_USER, username);
config.setObject(VFSConnection.PARAM_USER_PASSWORD, token);
VFSConnection vfsconn = new VFSConnection(vfsmanager, "myconn", config, options);
vfsmanager.addConnection(vfsconn);

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15

String uri = scheme + "://" + username + "@dropbox.com";
try {
 FileObject fileobj = vfsmanager.resolveFile(uri); // Determines best VFSConnection to use
 if (VFSUtils.isDirectory(fileobj, false)) { // Non-standard VFS
 FileObject[] childs = fileobj.getChildren();
 for (FileObject next : childs) {
 if (VFSUtils.isDirectory(next, false)) { // Do not print the cleartext token
 System.out.println(" DIR: " + VFSUtils.getDisplayURIObfuscated(next, vfsconn));
 }
 else System.out.println(" FILE: " + VFSUtils.getDisplayURIObfuscated(next, vfsconn));
 }
 }
 else System.out.println(" Entry " + uri + " is not a folder");
}
catch (Exception e) { e.printStackTrace(); }

1
2
3
4
5
6
7
8
9
10
11

String tempfolder = scheme + "://" + username + "@dropbox.com/0123456789abcdefghijklmnopqrstuvwxyz";
boolean success = false;
try {
 FileObject fileobj = vfsmanager.resolveFile(tempfolder);
 if (!VFSUtils.exists(fileobj, false)) { // Non-standard VFS
 fileobj.createFolder();
 success = fileobj.exists();
 }
}
catch (Exception e) { e.printStackTrace(); }

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

String content = "Hello world!";
String encoding = "ISO-8859-1";

// Upload a file to Dropbox. Get file type, last modified, and size.
String tempfile = tempfolder + "/readme.txt";
try {
 FileObject fileobj = fsmanager.resolveFile(tempfile);
 fileobj.getContent().setAttribute(VFSLibConstants.ATTR_CONTENT_LENGTH, content.getBytes(encoding).length);
 OutputStream ostream = fileobj.getContent().getOutputStream();
 ostream.write(content.getBytes(encoding));
 ostream.flush();
 ostream.close();

 success = fileobj.exists();

 System.out.println(" TYPE: " + fileobj.getType().getName());
 System.out.println(" MOD: " + new Date(fileobj.getContent().getLastModifiedTime()));
 System.out.println(" SIZE: " + fileobj.getContent().getSize());
}
catch (Exception e) { e.printStackTrace(); }

1
2
3
4
5
6
7
8
9

String tempfilerenamed = tempfolder + "/README";
try {
 FileObject fileobj = fsmanager.resolveFile(tempfile);
 FileObject fileobjrenamed = fsmanager.resolveFile(tempfilerenamed);
 fileobj.moveTo(fileobjrenamed);
 success = fileobjrenamed.exists();
 if (success) tempfile = tempfilerenamed;
}
catch (Exception e) { e.printStackTrace(); }

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17

try {
 FileObject fileobj = fsmanager.resolveFile(tempfile);
 ByteArrayOutputStream bostream = new ByteArrayOutputStream();
 InputStream istream = fileobj.getContent().getInputStream();
 int len;
 byte[] buffer = new byte[1024];
 while ((len = istream.read(buffer)) != -1) {
 bostream.write(buffer, 0, len);
 }
 istream.close();
 bostream.flush();
 bostream.close();
 String loaded = new String(bostream.toByteArray(), encoding);

 success = loaded.equals(content);
}
catch (Exception e) { e.printStackTrace(); }

1
2
3
4
5
6
7
8
9
10

try {
 // Remove file
 FileObject fileobj = fsmanager.resolveFile(tempfile);
 success = fileobj.delete();

 // Remove folder
 fileobj = fsmanager.resolveFile(tempfolder);
 success = fileobj.delete();
}
catch (Exception e) { e.printStackTrace(); }

1
2
3
4
5
6
7

 try {
 ClientPool pool = ClientPool.getSharedInstance();
 System.out.println(pool.debugPrint());
 pool.releaseForced(); // All connections
 System.out.println(pool.debugPrint());
 }
 catch (Exception e) { e.printStackTrace(); }