[置顶] Retrofit项目封装使用
android2016-07-15
- [POST] http://test.net/users // 新增
- [GET] http://test.net/users/1 // 查询
- [PATCH] http://test.net/users/1 // 更新
- [PUT] http://test.net/users/1 // 覆盖,全部更新
- [DELETE] http://test.net/users/1 // 删除
[scheme:][//authority][path][?query]
http://www.java2s.com:8080/yourpath/fileName.htm?stove=10&path=32&id=4
Retrofit retrofit = new Retrofit.Builder()
.baseUrl("https://api.github.com/")
.build();
@Headers("Cache-Control: max-age=640000")
@GET("widget/list")
Call<List<Widget>> widgetList();
@Headers({
"Accept: application/vnd.github.v3.full+json",
"User-Agent: Retrofit-Sample-App"
})
@GET("users/{username}")
Call<User> getUser(@Path("username") String username);
@GET("user")
Call<User> getUser(@Header("Authorization") String authorization)
@GET("user")
Call<User> getUser(@HeaderMap Map<String, String> headerMap)
private static void initHttpClient() {
OkHttpClient.Builder httpClientBuilder = new OkHttpClient.Builder();
if (httpClientBuilder.interceptors() != null) {
httpClientBuilder.interceptors().clear();
}
httpClientBuilder.addInterceptor(new Interceptor() {
@Override
public Response intercept(Chain chain) throws IOException {
//这里可以获取到请求的request所有数据
Request request = chain.request();
String path = request.url().encodedPath();
Log.d("AppClient", path + ">>>path");
String query = request.url().query();
if (BuildConfig.DEBUG){
Log.d("AppClient", query + ">>>query");
}
//这里设置成你的全局header
Request interRequest = chain.request().newBuilder()
.headers(Headers.of(Map yourHeader))
.build();
return chain.proceed(interRequest);
}
})
.connectTimeout(10, TimeUnit.SECONDS)
.readTimeout(10, TimeUnit.SECONDS);
mOkHttpClient = httpClientBuilder.build();
}
@GET("widget/list")
Call<List<Widget>> widgetList();
@GET("users/{user}/repos")
Call<List<Repo>> listRepos(@Path("user") String user);
@GET("group/{id}/users")
Call<List<User>> groupList(@Path("id") int groupId, @Query("sort") String sort);
@GET("group/{id}/users")
Call<List<User>> groupList(@Path("id") int groupId, @QueryMap Map<String, String> options);
@POST("users/new")
Call<User> createUser(@Body User user);
compile 'com.squareup.retrofit2:retrofit:2.1.0'
compile 'com.squareup.retrofit2:converter-gson:2.1.0'
compile 'com.squareup.okhttp3:logging-interceptor:3.4.0-RC1'
private static void initHttpClient() {
OkHttpClient.Builder httpClientBuilder = new OkHttpClient.Builder();
httpClientBuilder.hostnameVerifier(new HostnameVerifier() {
@Override
public boolean verify(String hostname, SSLSession session) {
return true;
}
});
//处理拦截器,主要是做了个header和连接超时、读取超时设置,我项目里header放了些签名信息,主要是这里能拿到整个请求的所有参数,做任何想做的事,而且是全局动态处理
if (httpClientBuilder.interceptors() != null) {
httpClientBuilder.interceptors().clear();
}
httpClientBuilder.addInterceptor(new Interceptor() {
@Override
public Response intercept(Chain chain) throws IOException {
Request request = chain.request();
String path = request.url().encodedPath();
Log.d("AppClient", path + ">>>path");
String query = request.url().query();
if (BuildConfig.DEBUG){
Log.d("AppClient", query + ">>>query");
}
Map<String, Object> queryParam = null;
if (query != null){
queryParam = new HashMap();
String queryEntries[] = query.split("&");
for (int i = 0; i < queryEntries.length; i ++){
queryParam.put(queryEntries[i].split("=")[0], queryEntries[i].split("=")[1]);
}
}
if (BuildConfig.DEBUG){
Log.d("AppClient", "queryParam:" + queryParam + ">>>queryParam");
}
String signature = makeSignature_v3(path, queryParam);
Request interRequest = chain.request().newBuilder()
.headers(Headers.of(getHeaders(signature)))
.build();
return chain.proceed(interRequest);
}
})
.connectTimeout(10, TimeUnit.SECONDS)
.readTimeout(10, TimeUnit.SECONDS);
//在debug模式下我使用了一个他家公司的一个log拦截器
if (BuildConfig.DEBUG) {
HttpLoggingInterceptor loggingInterceptor = new HttpLoggingInterceptor();
loggingInterceptor.setLevel(HttpLoggingInterceptor.Level.BODY);
httpClientBuilder.addInterceptor(loggingInterceptor);
}
//通过build模式构建实例
mOkHttpClient = httpClientBuilder.build();
}
httpClientBuilder.hostnameVerifier
这里是针对我公司的Https证书问题,详情看这里:https证书问题.connectTimeout(10, TimeUnit.SECONDS)
.readTimeout(10, TimeUnit.SECONDS);
public static Retrofit retrofit() {
if (mRetrofit == null) {
initHttpClient();
mRetrofit = new Retrofit.Builder()
.baseUrl(BASE_URL)
.client(mOkHttpClient)
.addConverterFactory(GsonConverterFactory.create()) .addCallAdapterFactory(RxJavaCallAdapterFactory.create())
.build();
}
return mRetrofit;
}
public interface ApiStores {
//POST登录
String RES_USERS_LOGIN = "users/login";
//POST注册
String RES_USERS_REGISTER = "users";
@POST(RES_USERS_LOGIN)
Observable<Map> login(@Body Map<String, String> body);
@POST(RES_USERS_REGISTER)
Observable<Map> register(@Body Map<String, String> body);
}
public void login(String cityId, final String cityName, final String mobile, String password, final OnLoginListener listener) {
Map<String, String> body = new HashMap<>();
body.put("mobile", mobile);
body.put("password", password);
body.put("city", cityId);
body.put("embed", "home");
ApiStores apiStores = AppClient.retrofit().create(ApiStores.class);
//这里通过指定Map泛型集合上面的Gson转换工厂实现返回数据json转换成Map
Call<Map> call = apiStores.login(body);
call.enqueue(new Callback<Map>() {
@Override
public void onResponse(Call<Map> call, Response<Map> response) {
//请求成功做的事情,这里两个参数:call是请求时候的call实例,可以拿到请求的request实例,response是服务端返回的参数,里面包含了code和body(这里的body类型是通过call指定的泛型和Gson转换工厂实现的),message一系列数据。
}
@Override
public void onFailure(Call<Map> call, Throwable t) {
//请求失败做的事情,call和上面一样,外加一个Throwable
}
});