Retrofit和Okhttp和RxJava的封裝

導(dǎo)入依賴(lài)

compile 'io.reactivex.rxjava2:rxandroid:2.0.1'

compile 'io.reactivex.rxjava2:rxjava:2.1.7'

compile 'com.squareup.retrofit2:retrofit:2.0.0-beta4'

compile 'com.squareup.retrofit2:converter-gson:2.0.0-beta4'

compile 'com.squareup.retrofit2:converter-scalars:2.0.0'

compile 'com.squareup.retrofit2:adapter-rxjava2:2.2.0'

compile 'com.google.code.gson:gson:2.8.2'

compile 'com.squareup.okhttp3:okhttp:3.9.0'加入權(quán)限

先寫(xiě)幾個(gè)公共的封裝類(lèi)

retrofit的封裝類(lèi)

public class RetrofitUtils {

private static IGetService service = null;

//http://api.tianapi.com/nba/?key=71e58b5b2f930eaf1f937407acde08fe&num=10

//單例模式

public static IGetService getInstance(){

if(service==null){

synchronized (RetrofitUtils.class){

if(service==null){

Retrofit retrofit = new Retrofit.Builder()

.baseUrl("http://api.tianapi.com")

.addConverterFactory(ScalarsConverterFactory.create())

.addCallAdapterFactory(RxJava2CallAdapterFactory.create())

.client(OkHttpUtils.getInstance())

.build();

service = retrofit.create(IGetService.class);

}

}

}

return service;

}

}okhttp的封裝類(lèi)

public class OkHttpUtils {

private static OkHttpClient client = null;

public static OkHttpClient getInstance(){

if(client==null){

synchronized (OkHttpUtils.class){

if(client==null){

client = new OkHttpClient.Builder()

.connectTimeout(2000, TimeUnit.SECONDS)

.writeTimeout(2000,TimeUnit.SECONDS)

.readTimeout(2000,TimeUnit.SECONDS)

.addInterceptor(new LoggingInterceptor())

.addInterceptor(new CommonHeaderInterceptor())

.build();

}

}

}

return client;

}

}

LoggingInterceptor日志攔截器的封裝

public class LoggingInterceptor implements Interceptor{

@Override

public Response intercept(Chain chain) throws IOException {

Request request = chain.request();

long t1 = System.nanoTime();

Response response = chain.proceed(request);

long t2 = System.nanoTime();

System.out.println(" this request url "+response.request().url()+" "+(t2-t1)/1000000);

return response;

}

}CommonHeaderInterceptor公共的請(qǐng)求頭攔截器

public class CommonHeaderInterceptor implements Interceptor{

@Override

public Response intercept(Chain chain) throws IOException {

Request request = chain.request();

Request.Builder builder = request.newBuilder();

builder.addHeader("key","aa");

builder.addHeader("User-Agent","android");

return chain.proceed(builder.build());

}

}觀察者Observer的封裝

//觀察者的封裝

public abstract class AbstractObserver implements Observer {

//不需要下面重寫(xiě)的四個(gè)方法,只需要自己寫(xiě)的兩個(gè)抽象方法

public abstract void onSuccess(T t);

public abstract void onFailure();

@Override

public void onSubscribe(Disposable d) {

}

@Override

public void onNext(String result) {

//這里的s是請(qǐng)求網(wǎng)絡(luò)傳回來(lái)的string字符串

Type type = getClass().getGenericSuperclass();

Type[] types = ((ParameterizedType) type).getActualTypeArguments();

Class clazz = (Class) types[0];//強(qiáng)轉(zhuǎn)成類(lèi)對(duì)象

//使用gson解析

Gson gson = new Gson();

T t = (T) gson.fromJson(result,clazz);

//調(diào)用抽象方法onSuccess

onSuccess(t);

}

@Override

public void onError(Throwable e) {

onFailure();

}

@Override

public void onComplete() {

}

}Retrofit的接口

public interface IGetService {

/* @GET("/nba")

Observable get(@QueryMap Map map);*/

//-----------------------下面用于封裝的請(qǐng)求

//http://api.tianapi.com/nba/?key=71e58b5b2f930eaf1f937407acde08fe&num=10

//返回string字符串的請(qǐng)求方法,傳后面整個(gè)url

@GET

Observable get1(@Url String url);//重載

@GET

Observable get1(@Url String url,@QueryMap Map map);

@FormUrlEncoded

@POST

Observable post1(@Url String url, @FieldMap Map map);

@POST

Observable post1(@Url String url);

}APIFactory.java這個(gè)類(lèi)里面有對(duì)應(yīng)的四個(gè)方法get1, post1

public class APIFactory {

//單例模式

private static APIFactory factory = null;

public static APIFactory getInstance(){

if(factory==null){

synchronized (APIFactory.class){

if(factory==null){

factory = new APIFactory();

}

}

}

return factory;

}

//這里面寫(xiě)方法.

public void get1(String url, Map map, Observer observer){

//調(diào)用retrofit工具類(lèi)的方法

RetrofitUtils.getInstance().get1(url, map)

.subscribeOn(Schedulers.io())

.observeOn(AndroidSchedulers.mainThread())

.subscribe(observer);

}

public void get1(String url,Observer observer){

RetrofitUtils.getInstance().get1(url)

.subscribeOn(Schedulers.io())

.observeOn(AndroidSchedulers.mainThread())

.subscribe(observer);

}

public void post1(String url,Map map,Observer observer){

RetrofitUtils.getInstance().post1(url,map)

.subscribeOn(Schedulers.io())

.observeOn(AndroidSchedulers.mainThread())

.subscribe(observer);

}

public void post1(String url,Observer observer){

RetrofitUtils.getInstance().post1(url)

.subscribeOn(Schedulers.io())

.observeOn(AndroidSchedulers.mainThread())

.subscribe(observer);

}

}在model層里面調(diào)用APIFactory里面的4個(gè)方法get1,post1,

//具體的model層

public class LoginModelImpl {

//model層處理數(shù)據(jù),請(qǐng)求網(wǎng)絡(luò)

public void getData(final LoginModelCallBack loginModelCallBack) {

//http://api.tianapi.com/nba/?key=71e58b5b2f930eaf1f937407acde08fe&num=10

Map map = new HashMap<>();

map.put("key","71e58b5b2f930eaf1f937407acde08fe");

map.put("num","10");

/* Retrofit retrofit = new Retrofit.Builder()

.baseUrl("http://api.tianapi.com")

.addCallAdapterFactory(RxJava2CallAdapterFactory.create())

.addConverterFactory(GsonConverterFactory.create())

.build();

IGetService service = retrofit.create(IGetService.class);

service.get(map).subscribeOn(Schedulers.io())

.observeOn(AndroidSchedulers.mainThread())

.subscribe(new Consumer() {

@Override

public void accept(Bean bean) throws Exception {

loginModelCallBack.success(bean);

}

});*/

//------------

//http://api.tianapi.com/nba/?key=71e58b5b2f930eaf1f937407acde08fe&num=10

//調(diào)用apifactory

//傳參map集合

APIFactory.getInstance().get1("/nba", map, new AbstractObserver() {

@Override

public void onSuccess(Bean bean) {

// System.out.println("beanget傳參 ="+bean.getNewslist().toString());

}

@Override

public void onFailure() {

// System.out.println("異常了");

}

});

//不傳參,直接傳路徑

APIFactory.getInstance().get1("/nba/?key=71e58b5b2f930eaf1f937407acde08fe&num=10", new AbstractObserver() {

@Override

public void onSuccess(Bean bean) {

// System.out.println("beanget不傳參 ="+bean.getNewslist().toString());

}

@Override

public void onFailure() {

// System.out.println("異常了");

}

});

//不傳參直接傳路徑post

APIFactory.getInstance().post1("/nba/?key=71e58b5b2f930eaf1f937407acde08fe&num=10", new AbstractObserver() {

@Override

public void onSuccess(Bean bean) {

System.out.println("beanpost不帶參數(shù) ="+bean.getNewslist().toString());

loginModelCallBack.success(bean);

}

@Override

public void onFailure() {

System.out.println("異常了");

}

});

/* //傳參 post路徑,不好使

APIFactory.getInstance().post1("/nba", map, new AbstractObserver() {

@Override

public void onSuccess(Bean bean) {

System.out.println("beanpost帶參數(shù) ="+bean.getNewslist().toString());

}

@Override

public void onFailure() {

System.out.println("異常了");

}

});*/

}

}

總結(jié)

以上是生活随笔為你收集整理的java封装拦截请求_Retrofit,OkHttp拦截器,RxJava封装请求网络的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。