之前使用Retrofit都是將JSON串轉(zhuǎn)化為POJO對(duì)象袋狞,針對(duì)不同的業(yè)務(wù)協(xié)議忆嗜,定義相應(yīng)的接口和參數(shù)列表吓笙。但是此種方式一般用在自己內(nèi)部協(xié)議基礎(chǔ)上淑玫,具體大的項(xiàng)目中,有些第三方的集成功能面睛,一般都采用統(tǒng)一的方式即請(qǐng)求JSON和回應(yīng)JSON進(jìn)行數(shù)據(jù)交互絮蒿,不可能每個(gè)第三方協(xié)議都會(huì)去定義與協(xié)議相應(yīng)的POJO對(duì)象。
HTTP肯定有GET和POST方法叁鉴,先定義Retrofit Api的interface:
package com.hdnetworklib.network.http;
import java.util.Map;
import okhttp3.RequestBody;
import okhttp3.ResponseBody;
import retrofit2.Call;
import retrofit2.http.Body;
import retrofit2.http.GET;
import retrofit2.http.POST;
import retrofit2.http.QueryMap;
import retrofit2.http.Url;
/**
* Created by wangyuhang@evergrande.cn on 2017/8/23 0023.
*/
public interface RetrofitServiceApi {
@POST
Call<ResponseBody> reqPost(@Url String url, @Body RequestBody requestBody);
@GET
Call<ResponseBody> reqGet(@Url String url, @QueryMap Map<String, String> options);
@GET
Call<ResponseBody> reqGet(@Url String url);
}
1土涝、POST方式,采用指定完整的URL幌墓,reqeustBody就是后面業(yè)務(wù)要傳入的完整JSON串
2但壮、GET方式,后面的options就是一個(gè)Map常侣,業(yè)務(wù)參數(shù)鍵值就存在這個(gè)里面蜡饵,URL里面不需要帶值。
3胳施、GET方式溯祸,與2不同的是沒(méi)有options,這樣就鍵值對(duì)全部帶在URL里面舞肆,類(lèi)似于這樣的格式:http://112.124.22.238:8081/course_api/wares/hot?pageSize=1&curPage=1
接下來(lái)就是具體對(duì)業(yè)務(wù)的接口了焦辅,提供POST和GET兩個(gè)請(qǐng)求接口調(diào)用:
package com.hdnetworklib.network.http;
import android.util.Log;
import java.io.IOException;
import java.util.Map;
import okhttp3.MediaType;
import okhttp3.RequestBody;
import okhttp3.ResponseBody;
import retrofit2.Call;
import retrofit2.Callback;
import retrofit2.Response;
import retrofit2.Retrofit;
import retrofit2.converter.gson.GsonConverterFactory;
/**
* Created by wangyuhang@evergrande.cn on 2017/7/12 0012.
*/
public class HttpClient {
private static final String TAG = "HttpClient";
private static volatile HttpClient instance;
private HttpClient() {
}
public static HttpClient getInstance() {
if (instance == null) {
synchronized (HttpClient.class) {
if (instance == null) {
instance = new HttpClient();
}
}
}
return instance;
}
/**
* Http Post請(qǐng)求
*
* @param req_id 請(qǐng)求編號(hào)
* @param method 請(qǐng)求業(yè)務(wù)方法
* @param url 請(qǐng)求的URL
* @param jsonData POST需要所帶參數(shù)(JSON串格式)
* @param callback 回調(diào)接口
*/
public void reqPostHttp(final int req_id, final String method, String url, String jsonData, final HttpCallback callback) {
Retrofit retrofit = new Retrofit.Builder()
.baseUrl("http://www.what.com/")
.addConverterFactory(GsonConverterFactory.create())
.build();
RetrofitServiceApi retrofitServiceApi = retrofit.create(RetrofitServiceApi.class);
RequestBody body = RequestBody.create(MediaType.parse("application/json; charset=utf-8"), jsonData);
Call<ResponseBody> call = retrofitServiceApi.reqPost(url, body);
call.enqueue(new Callback<ResponseBody>() {
@Override
public void onResponse(Call<ResponseBody> call, Response<ResponseBody> response) {
try {
String result = response.body().string();
Log.i(TAG, "reqPostHttp onResponse: " + result);
if (callback != null) {
callback.onSuccess(new HttpResMsg(req_id, method, result));
}
} catch (IOException e) {
e.printStackTrace();
Log.e(TAG, "reqPostHttp onResponse exception: " + e.toString());
if (callback != null) {
callback.onError(e.toString());
}
}
}
@Override
public void onFailure(Call<ResponseBody> call, Throwable t) {
Log.e(TAG, "reqPostHttp onFailure: " + t.toString());
if (callback != null) {
callback.onError(t.toString());
}
}
});
}
/**
* Http Get請(qǐng)求
*
* @param req_id 請(qǐng)求編號(hào)
* @param method 請(qǐng)求業(yè)務(wù)方法
* @param url 請(qǐng)求的URL
* @param options GET需要所帶參數(shù)鍵值(如果URL里帶有則不需要在此添加)
* @param callback 回調(diào)接口
*/
public void reqGetHttp(final int req_id, final String method, String url,
Map<String, String> options, final HttpCallback callback) {
Retrofit retrofit = new Retrofit.Builder()
.baseUrl("http://www.what.com/")
.addConverterFactory(GsonConverterFactory.create())
.build();
RetrofitServiceApi retrofitServiceApi = retrofit.create(RetrofitServiceApi.class);
Call<ResponseBody> call = null;
if (options == null) {
call = retrofitServiceApi.reqGet(url);
} else {
call = retrofitServiceApi.reqGet(url, options);
}
call.enqueue(new Callback<ResponseBody>() {
@Override
public void onResponse(Call<ResponseBody> call, Response<ResponseBody> response) {
try {
String result = response.body().string();
Log.i(TAG, "reqPostHttp onResponse: " + result);
if (callback != null) {
callback.onSuccess(new HttpResMsg(req_id, method, result));
}
} catch (IOException e) {
e.printStackTrace();
Log.e(TAG, "reqPostHttp onResponse exception: " + e.toString());
if (callback != null) {
callback.onError(e.toString());
}
}
}
@Override
public void onFailure(Call<ResponseBody> call, Throwable t) {
Log.e(TAG, "reqPostHttp onFailure: " + t.toString());
if (callback != null) {
callback.onError(t.toString());
}
}
});
}
}
需要注意的是:
baseUrl("http://www.what.com/")
這里的這個(gè)baseUrl是我瞎掰的一個(gè)地址,因?yàn)镽etrofit的限制:如果baseUrl不是以 / 結(jié)尾就會(huì)報(bào)異常:
Caused by: java.lang.IllegalArgumentException: baseUrl must end in /
當(dāng)我們需要完整的指定URL的時(shí)候椿胯,特別是上面列出的第二種GET方式筷登,我們的URL是http://112.124.22.238:8081/course_api/wares/hot?pageSize=1&curPage=1襟士,如果我們直接通過(guò)接口傳參把這個(gè)URL直接傳入baseUrl中艘绍,如下(注意最后沒(méi)有/結(jié)尾):
Retrofit retrofit = new Retrofit.Builder()
.baseUrl("http://112.124.22.238:8081/course_api/wares/hot?pageSize=1&curPage=1")
.addConverterFactory(GsonConverterFactory.create())
.build();
這樣運(yùn)行時(shí)就會(huì)報(bào)錯(cuò)。那如果我們手工在最后面加上一個(gè)/呢密浑?如下(注意最后有/結(jié)尾):
Retrofit retrofit = new Retrofit.Builder()
.baseUrl("http://112.124.22.238:8081/course_api/wares/hot?pageSize=1&curPage=1/")
.addConverterFactory(GsonConverterFactory.create())
.build();
這樣運(yùn)行時(shí)仍然報(bào)錯(cuò)种冬,而且你把這個(gè)鏈接復(fù)制到瀏覽器中看看就知道肯定不行的:http://112.124.22.238:8081/course_api/wares/hot?pageSize=1&curPage=1/
我一開(kāi)始遇到這個(gè)問(wèn)題的時(shí)候也是第一反應(yīng)去查Retrofit的官方文檔和說(shuō)明镣丑,或者讓第三方的開(kāi)發(fā)人員采用第二種GET請(qǐng)求方式,用一個(gè)以 / 結(jié)尾的URL娱两,然后把URL中?后面帶的那些值放到一個(gè)Map里傳進(jìn)來(lái)莺匠。首先官方說(shuō)明和Api用法沒(méi)找到,而且這個(gè)baseUrl還必須調(diào)用十兢,其次趣竣,別的開(kāi)發(fā)人員不愿意弄,好好的辛辛苦苦把URL都組裝好了旱物,沒(méi)啥事讓我傳Map啊遥缕,肯定也不行。后面在這里找到了答案:https://stackoverflow.com/questions/36736854/retrofit2-how-do-i-put-the-at-the-end-of-the-dynamic-baseurl
所以既然你后面會(huì)完整指定URL宵呛,那么一開(kāi)始的baseUrl就無(wú)關(guān)緊要单匣,隨便寫(xiě)一個(gè)以/結(jié)尾的Http地址就可以了。
剩下的的就是回調(diào)和消息的組裝了宝穗,各位可以根據(jù)自己的業(yè)務(wù)需求進(jìn)行組裝和調(diào)整户秤,我這里就只貼出代碼不做過(guò)多解析了。
回調(diào)接口:
package com.hdnetworklib.network.http;
/**
* Created by wangyuhang@evergrande.cn on 2017/8/23 0023.
*/
public interface HttpCallback {
void onSuccess(HttpResMsg httpResMsg);
void onError(String errorMsg);
}
消息結(jié)構(gòu)的組裝:
package com.hdnetworklib.network.http;
/**
* Created by wangyuhang@evergrande.cn on 2017/8/23 0023.
*/
public class HttpResMsg {
private Integer req_id;
private String method;
private String data;
public HttpResMsg() {
}
public HttpResMsg(int req_id, String method, String data) {
this.req_id = req_id;
this.method = method;
this.data = data;
}
public Integer getReq_id() {
return req_id;
}
public void setReq_id(Integer req_id) {
this.req_id = req_id;
}
public String getMethod() {
return method;
}
public void setMethod(String method) {
this.method = method;
}
public String getData() {
return data;
}
public void setData(String data) {
this.data = data;
}
}