首页 > 代码库 > Retrofit+RxJava(2)-基本使用
Retrofit+RxJava(2)-基本使用
首先是抽象的基类
public abstract class BaseApi { public static final String API_SERVER = "服务器地址" private static final OkHttpClient mOkHttpClient = new OkHttpClient(); private static Retrofit mRetrofit; protected static Retrofit getRetrofit() { if (Retrofit == null) { Context context = Application.getInstance().getApplicationContext(); //设定30秒超时 mOkHttpClient.setConnectTimeout(30, TimeUnit.SECONDS); //设置拦截器,以用于自定义Cookies的设置 mOkHttpClient.networkInterceptors() .add(new CookiesInterceptor(context)); //设置缓存目录 File cacheDirectory = new File(context.getCacheDir() .getAbsolutePath(), "HttpCache"); Cache cache = new Cache(cacheDirectory, 20 * 1024 * 1024); mOkHttpClient.setCache(cache); //构建Retrofit mRetrofit = new Retrofit.Builder() //配置服务器路径 .baseUrl(API_SERVER + "/") //设置日期解析格式,这样可以直接解析Date类型 .setDateFormat("yyyy-MM-dd HH:mm:ss") //配置转化库,默认是Gson .addConverterFactory(ResponseConverterFactory.create()) //配置回调库,采用RxJava .addCallAdapterFactory(RxJavaCallAdapterFactory.create()) //设置OKHttpClient为网络客户端 .client(mOkHttpClient) .build(); } return mRetrofit; } }
然后是Cookies拦截器
public class CookiesInterceptor implements Interceptor{ private Context context; public CookiesInterceptor(Context context) { this.context = context; } //重写拦截方法,处理自定义的Cookies信息 @Override public Response intercept(Chain chain) throws IOException { Request request = chain.request(); Request compressedRequest = request.newBuilder() .header("cookie", CookieUtil.getCookies(context)) .build(); Response response = chain.proceed(compressedRequest); CookieUtil.saveCookies(response.headers(), context); return response; } }
CookieUtil则是一些自定义解析和生成方法以及SharedPreferences的存取,代码略
然后是Api类
public class UserApi extends BaseApi{ //定义接口 private interface UserService { //GET注解不可用@FormUrlEncoded,要用@Query注解引入请求参数 @GET("user/user_queryProfile") Observable<UserProfileResp> queryProfile(@Query("userId") int userId); //POST方法没有缓存,适用于更新数据 @FormUrlEncoded @POST("user/user_updateUserName") Observable<BaseResp> updateUserName(@Field("userName") String userName); } protected static final UserService service = getRetrofit().create(UserService.class); //查询用户信息接口 public static Observable<UserProfileResp> queryProfile(int userId){ return service.queryProfile(userId); } //更新用户名接口 public static Observable<BaseResp> updateUserName(String userName){ return service.updateUserName(userName); } }
再就是将Retrofit的响应消息经过Gson解析成期望的数据结构,称之为Model类
上文的BaseResp和UserProfileResp则是自定义的Model
假定服务器约定返回的Json格式为
{ "result":"结果代号,0表示成功", "msg":"异常信息,仅在失败时返回数据", "userInfo": { "id":"用户id", "userName":"用户名名字" } }
那么UserProfileResp可以写成
public class UserProfileResp { //@SerializedName是指定Json格式中的Key名 //可以不写,则默认采用与变量名一样的Key名 @SerializedName("userInfo") private UserProfileModel userInfo; public UserProfileModel getUserInfo() { return userInfo; } }
UserProfileModel则是具体的数据结构
public class UserProfileModel { private int userId; private String userName; public String getUserName(){ return userName; } }
需要注意的是,如果没有使用@SerializedName指定Key名,当工程被混淆时,变量名会被混淆得与期望的Key名不符。因此需要将这类Model类统一放到一个工程目录,再在proguard-project文件中加入排除项
//不混淆Model类 -keep class com.xxx.model.xxx.** { *; }
最后是实际调用
public void getProfile(int userId){ UserApi.queryProfile(userId) .subscribeOn(Schedulers.io()) .subscribe(new Subscriber<UserProfileResp>(){ @Override public void onCompleted() { } @Override public void one rror(Throwable e) { } @Override public void onNext(UserProfileResp userProfileResp) { } }); }
Retrofit+RxJava(2)-基本使用
声明:以上内容来自用户投稿及互联网公开渠道收集整理发布,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任,若内容有误或涉及侵权可进行投诉: 投诉/举报 工作人员会在5个工作日内联系你,一经查实,本站将立刻删除涉嫌侵权内容。