本文实例为大家分享了retrofit rxjava实现下载文件的具体代码，供大家参考，具体内容如下
本文采用 :retrofit + rxjava
1.引入：
|
1
2
3
4
5
6
7
8
|
//rxjava compile 'io.reactivex:rxjava:latest.release' compile 'io.reactivex:rxandroid:latest.release' //network - squareup compile 'com.squareup.retrofit2:retrofit:latest.release' compile 'com.squareup.retrofit2:adapter-rxjava:latest.release' compile 'com.squareup.okhttp3:okhttp:latest.release' compile 'com.squareup.okhttp3:logging-interceptor:latest.release' |
2.增加下载进度监听：
|
1
2
3
|
public interface downloadprogresslistener { void update(long bytesread, long contentlength, boolean done);} |
|
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
|
public class downloadprogressresponsebody extends responsebody { private responsebody responsebody; private downloadprogresslistener progresslistener; private bufferedsource bufferedsource; public downloadprogressresponsebody(responsebody responsebody, downloadprogresslistener progresslistener) { this.responsebody = responsebody; this.progresslistener = progresslistener; } @override public mediatype contenttype() { return responsebody.contenttype(); } @override public long contentlength() { return responsebody.contentlength(); } @override public bufferedsource source() { if (bufferedsource == null) { bufferedsource = okio.buffer(source(responsebody.source())); } return bufferedsource; } private source source(source source) { return new forwardingsource(source) { long totalbytesread = 0l; @override public long read(buffer sink, long bytecount) throws ioexception { long bytesread = super.read(sink, bytecount); // read() returns the number of bytes read, or -1 if this source is exhausted. totalbytesread += bytesread != -1 ? bytesread : 0; if (null != progresslistener) { progresslistener.update(totalbytesread, responsebody.contentlength(), bytesread == -1); } return bytesread; } }; }} |
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
|
public class downloadprogressinterceptor implements interceptor { private downloadprogresslistener listener; public downloadprogressinterceptor(downloadprogresslistener listener) { this.listener = listener; } @override public response intercept(chain chain) throws ioexception { response originalresponse = chain.proceed(chain.request()); return originalresponse.newbuilder() .body(new downloadprogressresponsebody(originalresponse.body(), listener)) .build(); }} |
3.创建下载进度的元素类：
|
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
|
public class download implements parcelable { private int progress; private long currentfilesize; private long totalfilesize; public int getprogress() { return progress; } public void setprogress(int progress) { this.progress = progress; } public long getcurrentfilesize() { return currentfilesize; } public void setcurrentfilesize(long currentfilesize) { this.currentfilesize = currentfilesize; } public long gettotalfilesize() { return totalfilesize; } public void settotalfilesize(long totalfilesize) { this.totalfilesize = totalfilesize; } @override public int describecontents() { return 0; } @override public void writetoparcel(parcel dest, int flags) { dest.writeint(this.progress); dest.writelong(this.currentfilesize); dest.writelong(this.totalfilesize); } public download() { } protected download(parcel in) { this.progress = in.readint(); this.currentfilesize = in.readlong(); this.totalfilesize = in.readlong(); } public static final parcelable.creator<download> creator = new parcelable.creator<download>() { @override public download createfromparcel(parcel source) { return new download(source); } @override public download[] newarray(int size) { return new download[size]; } };} |
4.下载文件网络类：
|
1
2
3
4
5
6
|
public interface downloadservice { @streaming @get observable<responsebody> download(@url string url);} |
注：这里@url是传入完整的的下载url；不用截取
|
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
|
public class downloadapi { private static final string tag = "downloadapi"; private static final int default_timeout = 15; public retrofit retrofit; public downloadapi(string url, downloadprogresslistener listener) { downloadprogressinterceptor interceptor = new downloadprogressinterceptor(listener); okhttpclient client = new okhttpclient.builder() .addinterceptor(interceptor) .retryonconnectionfailure(true) .connecttimeout(default_timeout, timeunit.seconds) .build(); retrofit = new retrofit.builder() .baseurl(url) .client(client) .addcalladapterfactory(rxjavacalladapterfactory.create()) .build(); } public void downloadapk(@nonnull string url, final file file, subscriber subscriber) { log.d(tag, "downloadapk: " + url); retrofit.create(downloadservice.class) .download(url) .subscribeon(schedulers.io()) .unsubscribeon(schedulers.io()) .map(new func1<responsebody, inputstream>() { @override public inputstream call(responsebody responsebody) { return responsebody.bytestream(); } }) .observeon(schedulers.computation()) .doonnext(new action1<inputstream>() { @override public void call(inputstream inputstream) { try { fileutils.writefile(inputstream, file); } catch (ioexception e) { e.printstacktrace(); throw new customizeexception(e.getmessage(), e); } } }) .observeon(androidschedulers.mainthread()) .subscribe(subscriber); }} |
然后就是调用了：
该网络是在service里完成的
|
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
|
public class downloadservice extends intentservice { private static final string tag = "downloadservice"; private notificationcompat.builder notificationbuilder; private notificationmanager notificationmanager; private string apkurl = "http://download.fir.im/v2/app/install/595c5959959d6901ca0004ac?download_token=1a9dfa8f248b6e45ea46bc5ed96a0a9e&source=update"; public downloadservice() { super("downloadservice"); } @override protected void onhandleintent(intent intent) { notificationmanager = (notificationmanager) getsystemservice(context.notification_service); notificationbuilder = new notificationcompat.builder(this) .setsmallicon(r.mipmap.ic_download) .setcontenttitle("download") .setcontenttext("downloading file") .setautocancel(true); notificationmanager.notify(0, notificationbuilder.build()); download(); } private void download() { downloadprogresslistener listener = new downloadprogresslistener() { @override public void update(long bytesread, long contentlength, boolean done) { download download = new download(); download.settotalfilesize(contentlength); download.setcurrentfilesize(bytesread); int progress = (int) ((bytesread * 100) / contentlength); download.setprogress(progress); sendnotification(download); } }; file outputfile = new file(environment.getexternalstoragepublicdirectory (environment.directory_downloads), "file.apk"); string baseurl = stringutils.gethostname(apkurl); new downloadapi(baseurl, listener).downloadapk(apkurl, outputfile, new subscriber() { @override public void oncompleted() { downloadcompleted(); } @override public void onerror(throwable e) { e.printstacktrace(); downloadcompleted(); log.e(tag, "onerror: " + e.getmessage()); } @override public void onnext(object o) { } }); } private void downloadcompleted() { download download = new download(); download.setprogress(100); sendintent(download); notificationmanager.cancel(0); notificationbuilder.setprogress(0, 0, false); notificationbuilder.setcontenttext("file downloaded"); notificationmanager.notify(0, notificationbuilder.build()); } private void sendnotification(download download) { sendintent(download); notificationbuilder.setprogress(100, download.getprogress(), false); notificationbuilder.setcontenttext( stringutils.getdatasize(download.getcurrentfilesize()) + "/" + stringutils.getdatasize(download.gettotalfilesize())); notificationmanager.notify(0, notificationbuilder.build()); } private void sendintent(download download) { intent intent = new intent(mainactivity.message_progress); intent.putextra("download", download); localbroadcastmanager.getinstance(downloadservice.this).sendbroadcast(intent); } @override public void ontaskremoved(intent rootintent) { notificationmanager.cancel(0); }} |
mainactivity代码：
|
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
|
public class mainactivity extends appcompatactivity { public static final string message_progress = "message_progress"; private appcompatbutton btn_download; private progressbar progress; private textview progress_text; private broadcastreceiver broadcastreceiver = new broadcastreceiver() { @override public void onreceive(context context, intent intent) { if (intent.getaction().equals(message_progress)) { download download = intent.getparcelableextra("download"); progress.setprogress(download.getprogress()); if (download.getprogress() == 100) { progress_text.settext("file download complete"); } else { progress_text.settext(stringutils.getdatasize(download.getcurrentfilesize()) +"/"+ stringutils.getdatasize(download.gettotalfilesize())); } } } }; @override protected void oncreate(bundle savedinstancestate) { super.oncreate(savedinstancestate); setcontentview(r.layout.activity_main); btn_download = (appcompatbutton) findviewbyid(r.id.btn_download); progress = (progressbar) findviewbyid(r.id.progress); progress_text = (textview) findviewbyid(r.id.progress_text); registerreceiver(); btn_download.setonclicklistener(new view.onclicklistener() { @override public void onclick(view view) { intent intent = new intent(mainactivity.this, downloadservice.class); startservice(intent); } }); } private void registerreceiver() { localbroadcastmanager bmanager = localbroadcastmanager.getinstance(this); intentfilter intentfilter = new intentfilter(); intentfilter.addaction(message_progress); bmanager.registerreceiver(broadcastreceiver, intentfilter); }} |
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持服务器之家。
原文链接：https://blog.csdn.net/a1018875550/article/details/51832700
