我建議直接起飛扑庞，不用往下看了
一总滩、引入相關(guān)的包
api 'com.squareup.retrofit2:retrofit:2.5.0'
api 'com.squareup.retrofit2:converter-scalars:2.5.0'
api 'com.squareup.retrofit2:adapter-rxjava2:2.5.0'
api 'com.squareup.retrofit2:converter-gson:2.5.0'
api 'com.squareup.okhttp3:okhttp:3.12.8'
api 'com.squareup.okhttp3:logging-interceptor:3.12.8'
api 'io.reactivex.rxjava2:rxandroid:2.0.2'
二延都、創(chuàng)建api（service）
這是與服務(wù)器的對(duì)應(yīng)的接口聲明节猿。IApi
public interface IApi {
/**
* 登錄
*
* @param loginBody 請(qǐng)求體
* @return Observable
*/
@POST ( "/api/login" )
Observable< BaseBean< LoginResult > > login ( @Body LoginBody loginBody );
}
三骂铁、接收數(shù)據(jù)
BaseBean是服務(wù)器約定嚴(yán)格按照某種格式返回的實(shí)體類(lèi)吹零，具體如下，可根據(jù)實(shí)際項(xiàng)目做出修整拉庵。
public class BaseBean< T > {
private int code;
private String message;
private T data;
//忽略get()和set()
}
T是泛型灿椅，可以接收任意類(lèi)型的返回值。如
1.操作型名段，只返回code阱扬，message。
{
"code": 200,
"message": "提交成功"
}
那么IApi可以這么寫(xiě)
Observable< BaseBean< Void > > submit( @Body UserBody body );
2.當(dāng)服務(wù)器直接返回列表的查詢(xún)結(jié)果伸辟。如
{
"code": 200,
"message": "",
"data": [
{
"name": "a",
"age": 18
},
{
"name": "b",
"age": 19
}
]
}
那么IApi可以這么寫(xiě)
Observable< BaseBean< List < User > > > query( @Body QueryBody body );
3.如果返回的data是分頁(yè)數(shù)據(jù)麻惶，那么直接新建一個(gè)bean去接收就好了，這個(gè)比較簡(jiǎn)單就不說(shuō)了信夫。
四窃蹋、開(kāi)始封裝
RetrofitManager.class
public class RetrofitManager {
private IApi iApi;
private static RetrofitManager instance;
public static RetrofitManager getInstance ( ) {
if ( instance == null ) {
synchronized ( RetrofitManager.class ) {
if ( instance == null ) {
instance = new RetrofitManager ( );
}
}
}
return instance;
}
private RetrofitManager ( ) {
OkHttpClient.Builder okBuilder = new OkHttpClient.Builder ( );
okBuilder.addInterceptor ( new MyLogInterceptor ( ) );
Retrofit retrofit = new Retrofit.Builder ( )
.client ( okBuilder.build ( ) )
.baseUrl ( HttpApp.baseUrl )
.addConverterFactory ( GsonConverterFactory.create ( ) )
.addCallAdapterFactory ( RxJava2CallAdapterFactory.create ( ) )
.build ( );
iApi = retrofit.create ( IApi.class );
}
public IApi service ( ) {
return iApi;
}
}
接下來(lái)就可以整合起來(lái)了
HttpClient.class
ublic class HttpClient implements IApi {
private IApi api;
private HttpClient ( ) {
api = RetrofitManager.getInstance ( ).service ( );
}
private static HttpClient instance;
public static HttpClient getInstance ( ) {
if ( instance == null ) {
synchronized ( HttpClient.class ) {
if ( instance == null ) {
instance = new HttpClient ( );
}
}
}
return instance;
}
@Override
public Observable< BaseBean< LoginResult > > login ( LoginBody loginBody ) {
return api.login ( loginBody ).subscribeOn ( Schedulers.io ( ) )
.observeOn ( AndroidSchedulers.mainThread ( ) );
}
}
五卡啰、開(kāi)始使用
在你需要的地方，這樣用
HttpModel.getInstance ( ).login ( loginBody ) .subscribe ( observer );
附：
1.定義一個(gè)BaseObserver為了方便給回調(diào)做簡(jiǎn)單的處理
public abstract class BaseObserver< T > extends ResourceObserver< T > {
protected BaseObserver ( ) {
}
@Override
public void onNext ( @NonNull T value ) {
onAccept ( value, "" );
}
@Override
public void onError ( Throwable e ) {
if ( e instanceof HttpException ) {
HttpException httpException = ( HttpException ) e;
switch ( httpException.code ( ) ) {
case UNAUTHORIZED:
onAccept ( null, "登錄驗(yàn)證已過(guò)期" );
break;
case INTERNAL_SERVER_ERROR:
onAccept ( null, "服務(wù)器錯(cuò)誤" );
break;
case FORBIDDEN:
case NOT_FOUND:
onAccept ( null, "無(wú)效的請(qǐng)求" );
break;
case REQUEST_TIMEOUT:
case GATEWAY_TIMEOUT:
case BAD_GATEWAY:
case SERVICE_UNAVAILABLE:
default:
onAccept ( null, httpException.getMessage ( ) );
break;
}
} else if ( e instanceof ConnectException ) {
onAccept ( null, "網(wǎng)絡(luò)連接異常警没，請(qǐng)檢查您的網(wǎng)絡(luò)狀態(tài)" );
} else if ( e instanceof SocketTimeoutException ) {
onAccept ( null, "網(wǎng)絡(luò)連接超時(shí)匈辱，請(qǐng)檢查您的網(wǎng)絡(luò)狀態(tài)，稍后重試" );
} else if ( e instanceof UnknownHostException ) {
onAccept ( null, "網(wǎng)絡(luò)異常杀迹，請(qǐng)檢查您的網(wǎng)絡(luò)狀態(tài)" );
} else if ( e instanceof JsonParseException
|| e instanceof JSONException
|| e instanceof ParseException ) {
onAccept ( null, "數(shù)據(jù)解析錯(cuò)誤" );
} else if ( e instanceof SSLHandshakeException ) {
onAccept ( null, "證書(shū)驗(yàn)證失敗" );
} else if ( e instanceof RuntimeException ) {
onAccept ( null, "運(yùn)行時(shí)異常" );
} else {
onAccept ( null, e.toString ( ) );
}
}
@Override
public void onComplete ( ) {
}
public abstract void onAccept ( T t, String error );
public static final int UNAUTHORIZED = 401;
private static final int FORBIDDEN = 403;
private static final int NOT_FOUND = 404;
private static final int REQUEST_TIMEOUT = 408;
private static final int INTERNAL_SERVER_ERROR = 500;
private static final int BAD_GATEWAY = 502;
private static final int SERVICE_UNAVAILABLE = 503;
private static final int GATEWAY_TIMEOUT = 504;
}
2.MyLogInterceptor 是一個(gè)監(jiān)聽(tīng)類(lèi)亡脸，可以不要的。但為了方便開(kāi)發(fā)树酪，還是建議加上浅碾。
MyLogInterceptor.class
public class MyLogInterceptor implements Interceptor {
private static final Charset UTF8 = StandardCharsets.UTF_8;
@Override
public Response intercept ( Chain chain ) throws IOException {
Request request = chain.request ( );
RequestBody requestBody = request.body ( );
String body = null;
if ( requestBody != null ) {
Buffer buffer = new Buffer ( );
requestBody.writeTo ( buffer );
Charset charset = UTF8;
MediaType contentType = requestBody.contentType ( );
if ( contentType != null ) {
charset = contentType.charset ( UTF8 );
}
body = buffer.readString ( charset );
}
Response response = chain.proceed ( request );
ResponseBody responseBody = response.body ( );
String rBody;
BufferedSource source = responseBody.source ( );
source.request ( Long.MAX_VALUE );
Buffer buffer = source.buffer ( );
Charset charset = UTF8;
MediaType contentType = responseBody.contentType ( );
if ( contentType != null ) {
try {
charset = contentType.charset ( UTF8 );
} catch ( UnsupportedCharsetException e ) {
e.printStackTrace ( );
}
}
rBody = buffer.clone ( ).readString ( charset );
Logger.d ( "├─────────────────────────────────────────────────────────────────" );
Logger.d ( "│【請(qǐng)求響應(yīng)碼】" + response.code ( ) );
Logger.d ( "│【請(qǐng)求頭】：" + request.headers ( ) );
Logger.d ( "│【請(qǐng)求方法】：" + request.method ( ) );
Logger.d ( "│【請(qǐng)求參數(shù)】：" + body );
Logger.d ( "│【請(qǐng)求路徑】：" + response.request ( ).url ( ) );
Logger.d ( "│【請(qǐng)求回調(diào)】：" + rBody );
Logger.d ( "├─────────────────────────────────────────────────────────────────" );
return response;
}
}
注：關(guān)于轉(zhuǎn)換失敗的問(wèn)題，可參考
http://www.reibang.com/p/d882ffae1853
