diff options
| author | tspitzer | 2013-09-17 15:38:08 +0200 |
|---|---|---|
| committer | tspitzer | 2013-09-17 15:38:08 +0200 |
| commit | 205f059ec5df1a24daa87f8563d2bbb99344ecf9 (patch) | |
| tree | 4f37a93f4224a5f37adb6e6477e65ce9e983febe /Dozentenmodul/src/downloader/UploadTask.java | |
| parent | neue Version (diff) | |
| download | tutor-module-205f059ec5df1a24daa87f8563d2bbb99344ecf9.tar.gz tutor-module-205f059ec5df1a24daa87f8563d2bbb99344ecf9.tar.xz tutor-module-205f059ec5df1a24daa87f8563d2bbb99344ecf9.zip | |
g
Diffstat (limited to 'Dozentenmodul/src/downloader/UploadTask.java')
| -rw-r--r-- | Dozentenmodul/src/downloader/UploadTask.java | 91 |
1 files changed, 91 insertions, 0 deletions
diff --git a/Dozentenmodul/src/downloader/UploadTask.java b/Dozentenmodul/src/downloader/UploadTask.java new file mode 100644 index 00000000..691a31bb --- /dev/null +++ b/Dozentenmodul/src/downloader/UploadTask.java @@ -0,0 +1,91 @@ +package downloader;
+
+import java.io.File;
+import java.io.FileInputStream;
+
+import javax.swing.JOptionPane;
+import javax.swing.SwingWorker;
+
+/**
+ * Executes the file upload in a background thread and updates progress to
+ * listeners that implement the java.beans.PropertyChangeListener interface.
+ * @author www.codejava.net
+ *
+ */
+public class UploadTask extends SwingWorker<Void, Void> {
+ private static final int BUFFER_SIZE = 4096;
+
+ private String host;
+ private int port;
+ private String username;
+ private String password;
+
+ private String destDir;
+ private File uploadFile;
+
+ public UploadTask(String host, int port, String username, String password,
+ String destDir, File uploadFile) {
+ this.host = host;
+ this.port = port;
+ this.username = username;
+ this.password = password;
+ this.destDir = destDir;
+ this.uploadFile = uploadFile;
+ }
+
+ /**
+ * Executed in background thread
+ */
+ @Override
+ protected Void doInBackground() throws Exception {
+ FTPUtility util = new FTPUtility(host, port, username, password);
+ try {
+ util.connect();
+ util.uploadFile(uploadFile, destDir);
+
+ FileInputStream inputStream = new FileInputStream(uploadFile);
+ byte[] buffer = new byte[BUFFER_SIZE];
+ int bytesRead = -1;
+ long totalBytesRead = 0;
+ int percentCompleted = 0;
+ long fileSize = uploadFile.length();
+ long start=System.nanoTime();
+ final double NANOS_PER_SECOND = 1000000000.0;
+ final double BYTES_PER_MIB = 1024*1024;
+ while ((bytesRead = inputStream.read(buffer)) != -1) {
+ util.writeFileBytes(buffer, 0, bytesRead);
+ totalBytesRead += bytesRead;
+ percentCompleted = (int) (totalBytesRead * 100 / fileSize);
+ double speed = NANOS_PER_SECOND / BYTES_PER_MIB * totalBytesRead / (System.nanoTime() - start + 1);
+ setProgress(percentCompleted);
+ firePropertyChange("speed", 0, speed);
+ }
+
+ inputStream.close();
+
+ util.finish();
+ } catch (FTPException ex) {
+ JOptionPane.showMessageDialog(null, "Error uploading file: " + ex.getMessage(),
+ "Error", JOptionPane.ERROR_MESSAGE);
+ ex.printStackTrace();
+ setProgress(0);
+ cancel(true);
+ } finally {
+ util.disconnect();
+ }
+
+ return null;
+ }
+
+ /**
+ * Executed in Swing's event dispatching thread
+ */
+ @Override
+ protected void done() {
+ if (!isCancelled()) {
+ JOptionPane.showMessageDialog(null,
+ "File has been uploaded successfully!", "Message",
+ JOptionPane.INFORMATION_MESSAGE);
+ }
+ }
+}
\ No newline at end of file |