1.导入依赖
//网络请求okhttp3
implementation 'com.squareup.okhttp3:okhttp:3.12.0'
//日志的拦截器
implementation 'com.squareup.okhttp3:logging-interceptor:3.6.0'
//Retrofit2库
implementation 'com.squareup.retrofit2:retrofit:2.3.0'
implementation 'com.squareup.retrofit2:adapter-rxjava2:2.3.0'
//gson解析
implementation 'com.squareup.retrofit2:converter-gson:2.3.0'
//rxjava2库
implementation 'io.reactivex.rxjava2:rxjava:2.0.1'
implementation 'io.reactivex.rxjava2:rxandroid:2.0.1'
2.创建工具类
创建BaseRequest类：这个类属于网络请求工具类，用于初始化Retrofit，okhttp连接的一些设置，设置请求API的baseUrl、gson解析方式等。还有通过接口对象,调用接口类中的方法也写在这个里面了。
import java.util.concurrent.TimeUnit;
import okhttp3.OkHttpClient;
import retrofit2.Retrofit;
import retrofit2.adapter.rxjava2.RxJava2CallAdapterFactory;
import retrofit2.converter.gson.GsonConverterFactory;
public class BaseRequest {
//初始化Okhttp,绑定拦截器事件
OkHttpClient client=new OkHttpClient.Builder().
connectTimeout(20, TimeUnit.SECONDS). //设置请求超时时间
readTimeout(20,TimeUnit.SECONDS). //设置读取数据超时时间
writeTimeout(20,TimeUnit.SECONDS). //设置写入数据超时时间
addInterceptor(InterceptorUtil.LogInterceptor()). //绑定日志拦截器
addNetworkInterceptor(InterceptorUtil.HeaderInterceptor()) //绑定header拦截器
.build();
Retrofit retrofit=new Retrofit.Builder().
addConverterFactory(GsonConverterFactory.create()). //设置gson转换器,将返回的json数据转为实体
addCallAdapterFactory(RxJava2CallAdapterFactory.create()). //设置CallAdapter
baseUrl(ApiServise.HOST).
client(client) //设置客户端okhttp相关参数
.build();
public static BaseRequest instance;
public ApiServise apiServise=retrofit.create(ApiServise.class); //通过retrofit的实例,获取ApiServise接口的实例
private BaseRequest(){
}
public static BaseRequest getInstance(){
if(instance==null){
synchronized (BaseRequest.class){
if(instance==null){
instance=new BaseRequest();
}
}
}
return instance;
}
public ApiServise getApiServise(){
return apiServise;
}
}
3.创建日志拦截器
import android.util.Log;
import java.io.IOException;
import okhttp3.Interceptor;
import okhttp3.Request;
import okhttp3.Response;
import okhttp3.logging.HttpLoggingInterceptor;
public class InterceptorUtil {
public static final String TAG="------";
public static HttpLoggingInterceptor LogInterceptor() { //日志拦截器,用于打印返回请求的结果
return new HttpLoggingInterceptor(new HttpLoggingInterceptor.Logger() {
@Override
public void log(String message) {
Log.w(TAG,"log:"+message);
}
}).setLevel(HttpLoggingInterceptor.Level.BODY);
}
public static Interceptor HeaderInterceptor(){ //头部添加请求头信息
return new Interceptor() {
@Override
public Response intercept(Chain chain) throws IOException {
Request request=chain.request().newBuilder().
addHeader("Content-Type","application/json;charSet=UTF-8").build();
return chain.proceed(request);
}
};
}
}
4.管理Retrofit的各种数据请求(post、get)的类
import com.google.gson.JsonObject;
import java.util.Map;
import io.reactivex.Observable;
import retrofit2.http.Field;
import retrofit2.http.FormUrlEncoded;
import retrofit2.http.GET;
import retrofit2.http.POST;
import retrofit2.http.Query;
import retrofit2.http.QueryMap;
public interface ApiServise {
/**
* 注意：1.Observable<JsonObject>中JsonObject是返回数据的json串格式
* 2. Observable<UpdateBean>中UpdateBean是返回封装后的实体类 根据自己喜好选择返回方式
* 3.路径中的变量用 @Path注解来拼接的，不能使用使用@Query或者@QueryMap注解
* 如/xxx/{index}/xxx.do中的index变量替换必须使用 @Path("index") String index
* 4.路径后面拼接参数中的变量不能用@Path注解来拼接的，使用@Query或者@QueryMap注解
* 如/xxx/{index}/xxx.do?a=xxxx&b=xxxx&c=xxxx”的urla、b、c赋值是【不能】用@Path注解来拼接的，应该【使用】@Query或者@QueryMap注解
*/
String HOST = "http://192.168.xx.xx:xxxx"; //接口地址
@GET("/xxx/xxx/xxx.do")
Observable<UpdateBean> update(@Query("type") String type);
@GET("/xxx/xxx/xxx.do")
Observable<JsonObject> update2(@QueryMap Map<String,String> params);
@FormUrlEncoded
@POST("/xxx/xxx/xxx.do")
Observable<UpdateBean> update1(@Field("type") String type);
@Multipart//文件上传
@POST("/xxx/xxxx/upFile.do")
Observable<JsonObject> uploadfile(@Part List<MultipartBody.Part> parts);
}
5.请求示例
Map<String,String> params = new HashMap<>();
params.put("type","1");
BaseRequest.getInstance().getApiServise()
.update2(params)//请求参数
.subscribeOn(Schedulers.io())// 在io线程进行网络请求
.observeOn(AndroidSchedulers.mainThread())// 在主线程处理获取请求结果
.subscribe(new Observer<JsonObject>() {
@Override
public void onComplete() {
}
@Override
public void onSubscribe(Disposable d) {
}
@Override
public void onError(Throwable e) {
}
@Override
public void onNext(JsonObject updateBean) {
//获取结果 主线程
Log.e("rewr","werewre==="+updateBean.toString());
}
});
//文件上传
BaseRequest.getInstance().getApiServise()
.uploadfile(ContentType.filesToMultipartBodyParts("files",files))//请求参数 key value
.subscribeOn(Schedulers.io())// 在io线程进行网络请求
.observeOn(AndroidSchedulers.mainThread())// 在主线程处理获取请求结果
.subscribe(new Observer<JsonObject>() {
@Override
public void onSubscribe(Disposable d) {
}
@Override
public void onNext(JsonObject value) {
}
@Override
public void onError(Throwable e) {
}
@Override
public void onComplete() {
Log.e("dsds","dsds=="+"Complete");
}
});
}
import java.io.File;
import java.net.FileNameMap;
import java.net.URLConnection;
import java.net.URLEncoder;
import java.util.ArrayList;
import java.util.List;
import okhttp3.MediaType;
import okhttp3.MultipartBody;
import okhttp3.RequestBody;
public class ContentType {
/** 根据文件名获取MIME类型 */
public static MediaType guessMimeType(String fileName) {
FileNameMap fileNameMap = URLConnection.getFileNameMap();
fileName = fileName.replace("#", ""); //解决文件名中含有#号异常的问题
String contentType = fileNameMap.getContentTypeFor(fileName);
if (contentType == null) {
return MediaType.parse("application/octet-stream");
}
return MediaType.parse(contentType);
}
public static List<MultipartBody.Part> filesToMultipartBodyParts(String key, List<File> files) {
List<MultipartBody.Part> parts = new ArrayList<>(files.size());
try {
for (File filebean : files) {
RequestBody requestBody = RequestBody.create(guessMimeType(filebean.getName()), filebean);
MultipartBody.Part part = MultipartBody.Part.createFormData(key, URLEncoder.encode(filebean.getName(), "UTF-8"), requestBody);
parts.add(part);
}
}catch (Exception e){
e.printStackTrace();
}
return parts;
}
}
