/**
* File transfer between master server and satellite server.
* The connection should always be from satellite to master, because of
* open port knowledge on master server.
*
* For uploading file to master, satellite should send a request with
* token "U" for want upload. --> start Uploader(IP, PORT).
*
* For downloading a file from master, satellite should send a request
* with token "D" for want download. --> start Downloader(IP, PORT).
*
* Means the master server has to start the opposite part:
* If master receives token "U" --> start Downloader(socket)
* If master receives token "D" --> start Uploader(socket)
*/
package org.openslx.filetransfer;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.io.RandomAccessFile;
import java.security.KeyStore;
import javax.net.ssl.KeyManager;
import javax.net.ssl.KeyManagerFactory;
import javax.net.ssl.SSLContext;
import javax.net.ssl.TrustManager;
import javax.net.ssl.TrustManagerFactory;
import org.apache.log4j.BasicConfigurator;
import org.slf4j.LoggerFactory;
public class ClassTest
{
static {
// This is a temporary workaround for this annoying log4j error msg.
// Initializing the logger before anything else is done.
BasicConfigurator.configure();
LoggerFactory.getLogger( "ROOT" );
}
public static void main( String[] args ) throws Exception
{
String pathToKeyStore =
"/home/bjoern/javadev/DataTransfer/mySrvKeyStore.jks";
char[] passphrase = "test123".toCharArray();
KeyStore keystore = KeyStore.getInstance( "JKS" );
keystore.load( new FileInputStream( pathToKeyStore ), passphrase );
KeyManagerFactory kmf = KeyManagerFactory.getInstance( KeyManagerFactory.getDefaultAlgorithm() );
kmf.init( keystore, passphrase );
SSLContext context = SSLContext.getInstance( "SSLv3" );
KeyManager[] keyManagers = kmf.getKeyManagers();
context.init( keyManagers, null, null );
Listener listener = new Listener( new Test(), context, 6789 );
listener.start();
Thread.sleep( 5000 );
String pathToTrustStore =
"/home/bjoern/javadev/DataTransfer/mySrvKeyStore.jks";
passphrase = "test123".toCharArray();
keystore = KeyStore.getInstance( "JKS" );
keystore.load( new FileInputStream( pathToTrustStore ), passphrase );
TrustManagerFactory tmf = TrustManagerFactory.getInstance( TrustManagerFactory.getDefaultAlgorithm() );
tmf.init( keystore );
context = SSLContext.getInstance( "SSLv3" );
TrustManager[] trustManagers = tmf.getTrustManagers();
context.init( null, trustManagers, null );
Downloader d = new Downloader( "localhost", 6789, context );
d.setOutputFilename( "output.txt" );
d.sendToken( "xyz" );
while ( d.readMetaData() )
d.receiveBinary();
/*
String pathToKeyStore =
"/home/bjoern/javadev/DataTransfer/mySrvKeyStore.jks";
char[] passphrase = "test123".toCharArray();
KeyStore keystore = KeyStore.getInstance("JKS");
keystore.load(new FileInputStream(pathToKeyStore), passphrase);
KeyManagerFactory kmf = KeyManagerFactory.getInstance(KeyManagerFactory.getDefaultAlgorithm());
kmf.init(keystore, passphrase);
SSLContext context = SSLContext.getInstance("SSLv3");
KeyManager[] keyManagers = kmf.getKeyManagers();
context.init(keyManagers, null, null);
Uploader u = new Uploader("localhost", 6789, context);
u.sendToken("xyz");
RandomAccessFile file = new RandomAccessFile(new File("test.txt"), "rw");
long length = file.length();
file.close();
int diff = 0;
for (int i = 0; (i + 5) < length; i += 5) {
u.sendRange(i, i + 5);
u.sendFile("test.txt");
diff = (int) (length - i);
}
u.sendRange((int)(length - diff), (int)length);
u.sendFile("test.txt");
*/
}
}
// Implementing IncomingEvent for testing case.
class Test implements IncomingEvent
{
public void incomingUploader( Uploader uploader ) throws IOException
{
RandomAccessFile file;
try {
file = new RandomAccessFile( new File( "test.txt" ), "r" );
} catch ( FileNotFoundException e ) {
e.printStackTrace();
return;
}
long length = file.length();
file.close();
int diff = 0;
for ( int i = 0; ( i + 254 ) < length; i += 254 ) {
uploader.sendRange( i, i + 254 );
uploader.sendFile( "test.txt" );
diff = (int) ( length - i );
}
uploader.sendRange( (int) ( length - diff ), (int)length );
uploader.sendFile( "test.txt" );
}
public void incomingDownloader( Downloader downloader ) throws IOException
{
downloader.setOutputFilename( "output.txt" );
while ( downloader.readMetaData() )
downloader.receiveBinary();
}
}