forked from onlyliuxin/coding2017
-
Notifications
You must be signed in to change notification settings - Fork 13
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge pull request #3 from zavier/master
sync
- Loading branch information
Showing
44 changed files
with
2,416 additions
and
7 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,39 @@ | ||
package week3_0312; | ||
|
||
import java.io.IOException; | ||
import java.io.RandomAccessFile; | ||
|
||
import week3_0312.api.Connection; | ||
|
||
public class DownloadThread extends Thread{ | ||
|
||
Connection conn; | ||
int startPos; | ||
int endPos; | ||
|
||
public DownloadThread( Connection conn, int startPos, int endPos){ | ||
|
||
this.conn = conn; | ||
this.startPos = startPos; | ||
this.endPos = endPos; | ||
} | ||
public void run(){ | ||
byte[] data = new byte[endPos - startPos]; | ||
try { | ||
data = conn.read(startPos, endPos); | ||
} catch (IOException e) { | ||
e.printStackTrace(); | ||
} | ||
writeToFile(data); | ||
} | ||
public void writeToFile(byte[] data) { | ||
RandomAccessFile file; | ||
try { | ||
file = new RandomAccessFile("downloadTest.jpg","rw"); | ||
file.seek(startPos); | ||
file.write(data, 0, data.length); | ||
} catch (IOException e) { | ||
e.printStackTrace(); | ||
} | ||
} | ||
} |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,87 @@ | ||
package week3_0312; | ||
|
||
import java.io.IOException; | ||
|
||
import week3_0312.api.Connection; | ||
import week3_0312.api.ConnectionException; | ||
import week3_0312.api.ConnectionManager; | ||
import week3_0312.api.DownloadListener; | ||
|
||
|
||
public class FileDownloader { | ||
|
||
String url; | ||
|
||
DownloadListener listener; | ||
|
||
ConnectionManager cm; | ||
|
||
|
||
public FileDownloader(String _url) { | ||
this.url = _url; | ||
|
||
} | ||
|
||
public void execute(){ | ||
// 在这里实现你的代码, 注意: 需要用多线程实现下载 | ||
// 这个类依赖于其他几个接口, 你需要写这几个接口的实现代码 | ||
// (1) ConnectionManager , 可以打开一个连接,通过Connection可以读取其中的一段(用startPos, endPos来指定) | ||
// (2) DownloadListener, 由于是多线程下载, 调用这个类的客户端不知道什么时候结束,所以你需要实现当所有 | ||
// 线程都执行完以后, 调用listener的notifiedFinished方法, 这样客户端就能收到通知。 | ||
// 具体的实现思路: | ||
// 1. 需要调用ConnectionManager的open方法打开连接, 然后通过Connection.getContentLength方法获得文件的长度 | ||
// 2. 至少启动3个线程下载, 注意每个线程需要先调用ConnectionManager的open方法 | ||
// 然后调用read方法, read方法中有读取文件的开始位置和结束位置的参数, 返回值是byte[]数组 | ||
// 3. 把byte数组写入到文件中 | ||
// 4. 所有的线程都下载完成以后, 需要调用listener的notifiedFinished方法 | ||
|
||
// 下面的代码是示例代码, 也就是说只有一个线程, 你需要改造成多线程的。 | ||
Connection conn = null; | ||
try { | ||
|
||
conn = cm.open(this.url); | ||
|
||
int length = conn.getContentLength(); | ||
DownloadThread downloadThread1 = new DownloadThread(conn,0,length/3); | ||
downloadThread1.start(); | ||
DownloadThread downloadThread2 = new DownloadThread(conn, length/3+1, length/3 *2); | ||
downloadThread2.start(); | ||
DownloadThread downloadThread3 = new DownloadThread(conn, length/3*2 +1, length -1); | ||
downloadThread3.start(); | ||
try { | ||
downloadThread1.join(); | ||
downloadThread2.join(); | ||
downloadThread3.join(); | ||
listener.notifyFinished(); | ||
} catch(InterruptedException e) { | ||
e.printStackTrace(); | ||
} | ||
|
||
} catch (ConnectionException e) { | ||
e.printStackTrace(); | ||
}finally{ | ||
if(conn != null){ | ||
conn.close(); | ||
} | ||
} | ||
|
||
|
||
|
||
|
||
} | ||
|
||
public void setListener(DownloadListener listener) { | ||
this.listener = listener; | ||
} | ||
|
||
|
||
|
||
public void setConnectionManager(ConnectionManager ucm){ | ||
this.cm = ucm; | ||
} | ||
|
||
public DownloadListener getListener(){ | ||
return this.listener; | ||
} | ||
|
||
} |
Oops, something went wrong.