您的位置:首頁技術文章
文章詳情頁

用Java下載文件。多線程,這行得通嗎?

瀏覽:91日期:2024-05-04 18:34:44
如何解決用Java下載文件。多線程,這行得通嗎??

意見建議:

使用SwingWorker進行后臺線程工作。在您的SwingWorker內部,通過設置其進度“ bound”屬性setProgress(int progress)。該值應在1到100之間。不要讓您的SwingWorker /文件下載器擁有JProgressBar或任何Swing組件。將Propertychangelistener添加到您的SwingWorker,并監視progress屬性中的更改。切勿將您的Swing字段(或大多數和所有字段)公開。限制訪問,而是通過方法更改對象狀態。閱讀Swing中的并發教程以獲取必要的詳細信息。

例如,下面的代碼是一個簡單的簡化,不下載任何文件,但是應該可以使您了解:

import java.awt.*;import java.beans.PropertyChangeEvent;import java.beans.Propertychangelistener;import java.util.Random;import javax.swing.*;public class Initial { static AtomFrame atomLauncher; public static void main(String[] args) { atomLauncher = new AtomFrame(); atomLauncher.start(); System.out.println(Integer.MAX_VALUE); final Download theDownload = new Download(); theDownload.addPropertychangelistener(new Propertychangelistener() { @Override public void propertyChange(PropertyChangeEvent pcEvt) { if ('progress'.equals(pcEvt.getPropertyName())) { int progress = theDownload.getProgress(); atomLauncher.setProgress(progress); } } }); theDownload.execute(); }}class AtomFrame extends JFrame { // ********* should be private! private JProgressBar progressBar; private static final long serialVersionUID = 4010489530693307355L; public static void main(String[] args) { AtomFrame testFrame = new AtomFrame(); testFrame.start(); } public void setProgress(int progress) { progressBar.setValue(progress); } public AtomFrame() { initializeComponents(); } public void initializeComponents() { this.setSize(400, 400); this.setLocationRelativeto(null); this.setDefaultCloSEOperation(JFrame.EXIT_ON_CLOSE); this.setTitle('Atom Launcher'); this.setLayout(new FlowLayout(FlowLayout.CENTER, 5, 5)); progressBar = new JProgressBar(); this.add(progressBar); // this.pack(); } public void start() { this.setVisible(true); } public void close() { this.dispose(); }}class Download extends SwingWorker<Void, Void> { private static final long SLEEP_TIME = 300; private Random random = new Random(); @Override protected Void doInBackground() throws Exception { int myProgress = 0; while (myProgress < 100) { myProgress += random.nextInt(10); setProgress(myProgress); try { Thread.sleep(SLEEP_TIME); } catch (InterruptedException e) {} } return null; }}解決方法

首先,每個人都需要知道我對Java編碼還比較陌生。更準確地說,我是面向對象編程的新手。

問題。

我試圖創建一個下載類來更新進度條,以顯示其進度??赡苓€有其他決定,我決定在以后進行更新。

目前的問題是,在我看來,這不起作用。我可以在“主要”方法上做任何我想做的事情,而且GUI仍然響應迅速。根據我過去的編程經驗,除非我對GUI進行線程化,否則這是不可能的。為什么是這樣?

既然可以了,這樣可以嗎?

主班

package atomicElectronics;import java.io.IOException;import atomicElectronics.physical.AtomFrame;import atomicElectronics.utility.Download;public class Initial { static AtomFrame atomLauncher; public static void main(String[] args) {atomLauncher = new AtomFrame();atomLauncher.start();System.out.println(Integer.MAX_VALUE);Download theDownload = new Download();theDownload.fileProgressBar(atomLauncher.progressBar);try { theDownload.exicute('http://download.videolan.org/pub/videolan/vlc/last/win64/vlc-2.1.3-win64.exe','C:UsersTrinaryAtomAppDataRoaming');} catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace();}// TODO Add Download Methods// theDownload.updateBarTotal(JProgressBar);// theDownload.updateLabelSpeed(String);// theDownload.updateLabelTotal(String);// theDownload.addFile(File);// theDownload.addFiles(Files); }}

類AtomFrame

package atomicElectronics.physical;import javax.swing.JFrame;import java.awt.FlowLayout;import javax.swing.JProgressBar;public class AtomFrame extends JFrame{ public JProgressBar progressBar; private static final long serialVersionUID = 4010489530693307355L; public static void main(String[] args){AtomFrame testFrame = new AtomFrame();testFrame.start(); } public AtomFrame(){initializeComponents(); } public void initializeComponents(){this.setSize(400,400);this.setLocationRelativeTo(null);this.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);this.setTitle('Atom Launcher');this.setLayout(new FlowLayout(FlowLayout.CENTER,5,5));progressBar = new JProgressBar();this.add(progressBar);//this.pack(); } public void start() {this.setVisible(true); } public void close() {this.dispose(); }}

類下載

package atomicElectronics.utility;import java.io.File;import java.io.FileOutputStream;import java.io.IOException;import java.io.InputStream;import java.net.HttpURLConnection;import java.net.URL;import javax.swing.JProgressBar;public class Download { private static final int BUFFER_SIZE = 4096; private JProgressBar fileProgressBar; public Download() { } public void fileProgressBar(JProgressBar fileBar) {fileProgressBar = fileBar; } public void exicute(String fileURL,String saveDir) throws IOException {URL url = new URL(fileURL);HttpURLConnection httpConn = (HttpURLConnection) url.openConnection();int responseCode = httpConn.getResponseCode();// always check HTTP response code firstif (responseCode == HttpURLConnection.HTTP_OK) { String fileName = ''; String disposition = httpConn.getHeaderField('Content-Disposition'); String contentType = httpConn.getContentType(); double contentLength = httpConn.getContentLength(); if (disposition != null) {// extracts file name from header fieldint index = disposition.indexOf('filename=');if (index > 0) { fileName = disposition.substring(index + 9,disposition.length()); }} else { // extracts file name from URL fileName = fileURL.substring(fileURL.lastIndexOf('/') + 1,fileURL.length());}System.out.println('Content-Type = ' + contentType);System.out.println('Content-Disposition = ' + disposition);System.out.println('Content-Length = ' + contentLength);System.out.println('fileName = ' + fileName);// opens input stream from the HTTP connectionInputStream inputStream = httpConn.getInputStream();String saveFilePath = saveDir + File.separator + fileName;// opens an output stream to save into fileFileOutputStream outputStream = new FileOutputStream(saveFilePath);double totalRead = 0;int bytesRead = -1;byte[] buffer = new byte[BUFFER_SIZE];while ((bytesRead = inputStream.read(buffer)) != -1) { outputStream.write(buffer,bytesRead); totalRead += bytesRead; System.out.println((totalRead / contentLength) * 100); fileProgressBar.setValue((int)((totalRead / contentLength) * 100));}outputStream.close();inputStream.close();System.out.println('File downloaded'); } else {System.out.println('No file to download. Server replied HTTP code: ' + responseCode); } httpConn.disconnect();}

}

標簽: java
国产综合久久一区二区三区