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
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
|
import net.sf.jftp.net.ConnectionHandler;
import net.sf.jftp.net.ConnectionListener;
import net.sf.jftp.net.DataConnection;
import net.sf.jftp.net.FtpConnection;
import net.sf.jftp.net.BasicConnection;
import net.sf.jftp.system.logging.Log;
import net.sf.jftp.system.logging.Logger;
import net.sf.jftp.config.Settings;
import java.io.*;
// this class download a file via anonymous ftp and shows output.
//
// if you want to use the api in a more complex way, please do at least take a look at the
// FtpConnection, FtpTransfer, ConnectionHandler, DirPanel (blockedTransfer, transfer)
// and ConnectionListener sourcecode.
public class FtpDownload implements Logger, ConnectionListener
{
// is the connection established?
private boolean isThere = false;
public static long time = 0;
// connection pool, not necessary but you should take a look at this class
// if you want to use multiple event based ftp transfers.
private ConnectionHandler handler = new ConnectionHandler();
//creates a FtpConnection and downloads a file
public FtpDownload(String host, String file)
{
// the ftp client default is very small, you may want to increase this
Settings.bufferSize = 16384;
long current = System.currentTimeMillis();
//System.out.println("1) "+(System.currentTimeMillis()-current)+"ms.");
// register app as Logger, debug() and debugRaw below are from now on called by
// FtpConnection
Log.setLogger(this);
// create a FtpConnection - note that it does *not* connect instantly
FtpConnection con = new FtpConnection(host);
//System.out.println("2) "+(System.currentTimeMillis()-current)+"ms.");
// set updatelistener, interface methods are below
con.addConnectionListener(this);
// set handler
con.setConnectionHandler(handler);
// connect and login. this is from where connectionFailed() may be called for example
con.login("anonymous","........");
//System.out.println("3) "+(System.currentTimeMillis()-current)+"ms.");
// login calls connectionInitialized() below which sets isThere to true
while(!isThere)
{
try { Thread.sleep(10); }
catch(Exception ex) { ex.printStackTrace(); }
}
//System.out.println("4) "+(System.currentTimeMillis()-current)+"ms.");
// download the file - this method blocks until the download has finished
// if you want non-blocking, multithreaded io, just use
//
// con.handleDownload(file);
//
// which spawns a new thread for the download
con.chdir("pub/linux/kernel");
con.download(file);
time = (System.currentTimeMillis()-current);
System.out.println("Download took "+time+"ms.");
}
// download welcome.msg from sourceforge or any other given file
public static void main(String argv[])
{
if(argv.length < 2)
{
FtpDownload f = new FtpDownload("ftp.kernel.org", "CREDITS");
}
else
{
FtpDownload f = new FtpDownload(argv[0], argv[1]);
}
System.exit(0);
}
// ------------------ needed by ConnectionListener interface -----------------
// called if the remote directory has changed
public void updateRemoteDirectory(BasicConnection con)
{
System.out.println("new path is: " + con.getPWD());
}
// called if a connection has been established
public void connectionInitialized(BasicConnection con)
{
isThere = true;
}
// called every few kb by DataConnection during the trnsfer (interval can be changed in Settings)
public void updateProgress(String file, String type, long bytes) {}
// called if connection fails
public void connectionFailed(BasicConnection con, String why) {System.out.println("connection failed!");}
// up- or download has finished
public void actionFinished(BasicConnection con) {}
// ------------ needed by Logger interface --------------
// main log method
public void debug(String msg) {} //{System.out.println(msg);}
// rarely used
public void debugRaw(String msg) {}//System.out.print(msg);}
// methods below are not used yet.
public void debug(String msg, Throwable throwable) {}
public void warn(String msg) {}
public void warn(String msg, Throwable throwable) {}
public void error(String msg) {}
public void error(String msg, Throwable throwable) {}
public void info(String msg) {}
public void info(String msg, Throwable throwable) {}
public void fatal(String msg) {}
public void fatal(String msg, Throwable throwable) {}
}
|
