MarvelNetwork
如何使用
app gradle 中添加以下代码
apply plugin: 'com.android.application'
android {
// 略...
}
repositories {
maven { url "https://github.com/ywqln/marvel-network/raw/master" }
}
dependencies {
// 略...
implementation 'com.marvel:network:1.0.1'
}
认识 marvel network
项目中难免会有多方接口，那就意味着多种baseUrl，多种Header，多种数据结构。而我们在使用过程中对Retrofit切换baseUrl，Header频繁起来，会觉得不那么舒服，所以这方面需要设计下
marvel network使用注解的方式来描述接口的interface声明文件，统一来管理一个interface下的所有接口都使用同一个baseUrl，同一个Header。
在项目中，baseUrl也可能是从一个接口中获取到的，注解上要求字符串的值是常量，考虑到这种情况，marvel network提供了动态的baseUrl设置，设置方式如下：
@BaseUrl(dynamic = NewsBaseUrlInterceptor.class)
public interface NewsApi {
// 略...
}
NewsBaseUrlInterceptor文件，NewsBaseUrlInterceptor必须是一个实现BaseUrlInterceptor接口的类，并实现void getBaseUrl()方法
public class NewsBaseUrlInterceptor implements BaseUrlInterceptor {
@Override
public String getBaseUrl() {
return "http://toutiao-ali.juheapi.com";
}
}
如果你想直接设置baseUrl，不需要动态，可以按以下方式设置：
@BaseUrl("http://toutiao-ali.juheapi.com")
public interface NewsApi {
// 略...
}
默认提供的一些工具
-
ApiThreadTransformer线程切换，在io线程发起请求，在main线程处理数据。 -
ResponseObserver继承Observer后重写了onError，对错误做了重新定义，通过网络状态码来转为中文消息，且不吞没状态码。对于成功响应定义为数据返回且业务处理正常，失败定义为网络层出错或服务器处理出错。 -
SimpleObserver继承自ResponseObserver，但无需实现onSubscribe和onComplete。当无需在发起请求和完成请求时处理的时候，可选择。
如何定义一个api
@BaseUrl用在整个interface，表示但凡是在整个interface中声明的接口，他们的baseUrl都是一样的。同理，@Interceptors也是一样。
/**
* 描述:新闻相关接口.
* <p>
*
* @author yanwenqiang.
* @date 2019/1/21
*/
@BaseUrl(value = "http://toutiao-ali.juheapi.com")
@Interceptors(NewsHeaderInterceptor.class)
public interface NewsApi {
/**
* 获取新闻列表
*
* @param type 可选参数：top(头条，默认),shehui(社会),guonei(国内),guoji(国际),yule(娱乐),
* tiyu(体育)junshi(军事),keji(科技),caijing(财经),shishang(时尚)
*/
@GET("/toutiao/index")
Observable<NewsResp<NewsResult>> getNews(@Query("type") String type);
}
如何发起网络请求
Requestor.instance()
.getApi(NewsApi.class)
.getNews("yule")
.compose(new ApiThreadTransformer<>())
.compose(new NewsTransformer<>())
.subscribe(new ResponseObserver<NewsResult>() {
@Override
protected void onSuccess(NewsResult result) {
NetLog.json(new Gson().toJson(result.getData()));
}
@Override
protected void onFail(ResponseException responseException) {
NetLog.e(responseException.message);
}
@Override
public void onSubscribe(Disposable d) {
NetLog.p("开始发送请求...");
}
@Override
public void onComplete() {
NetLog.p("请求处理完成...");
}
});
