Android OkHttp + Retrofit 使用示例¶

更新日期：2022-8-1

2022-8-1 更新用法和错误示例
2021-11-29 更新说明
2019-05-17 创建文档

OkHttp是一款HTTP客户端。它使用连接池减少请求延迟，能在传输GZIP时减少下载体积，还有缓存相同请求的回复的特点。可以单独使用OkHttp，也可以结合Retrofit，打造一个适合自己业务需求的工具。

本文介绍OkHttp + Retrofit使用示例。从引入依赖，编写接口，到发起网络请求。

简单使用¶

引入依赖¶

引入依赖，使用Retrofit2。

implementation 'com.squareup.retrofit2:retrofit:2.1.0'
implementation 'com.squareup.retrofit2:converter-gson:2.1.0'
implementation 'com.squareup.retrofit2:adapter-rxjava:2.1.0'

然后新建一个接口（interface）CfgService，在这里面定义我们需要用到的服务。

public interface CfgService { /* 具体的方法 */ }

后面会用到一些注解。

查询 `@Query`¶

例如URL https://rustfisher.com/api/config?env=dev，问号后面属于查询内容。不论是GET或POST，都要用@Query这个注解。否则会报异常。

URL填充与拼接¶

单纯URL填充可以用@Path注解。例如下面这个post请求。

@POST("api/user/{uid}/token/refresh")
Call<RefreshTokenResp> refreshToken(@Path("uid") String uid, @Query("token") String token);

GET带有查询的参数¶

使用GET注解

public interface CfgService {
    @GET("api/config")
    Call<ServerCfgResp> getServerCfg(@Query("env") String env);
}

POST，带有查询的参数和body¶

使用POST注解，传参使用@Body RequestBody

public interface UserService {

    @POST("user-service/login")
    Call<LoginResp> login(@Query("lenovoST") String token, @Query("realm") String realm,
                            @Body RequestBody body);

    @POST("user-service/logout")
    Call<CommonEntity> logout(@Query("token") String token, @Body RequestBody body);
}

调用的时候要创建RequestBody；先调查好后台接受的body类型。

Map<String, String> map = new HashMap<>();
map.put("system", "Android");
map.put("phoneBrand", Build.BRAND);
map.put("modelNum", Build.MODEL);
Gson gson = new Gson();
String bodyJson = gson.toJson(map);
RequestBody requestBody = RequestBody.create(MediaType.parse("application/json"), bodyJson);
// 类似这样的请求，需要传入requestBody
ReqCtrl.getCtrl().getUserService().login(token, realm, requestBody)
    // .....

HTTP 400 Bad Request¶

retrofit2.adapter.rxjava2.HttpException: HTTP 400 Bad Request

如果接口需要一个json body，而POST方法用的是@FormUrlEncoded与@FieldMap，则会报错 HTTP 400 Bad Request

错误示例

curl接口例子
curl -X 'POST' \
'http://1.2.3.4:8080/api/v1/login' \
-H 'accept: */*' \
-H 'Content-Type: application/json' \
-d '{
"account": "an.rustfisher.com",
"secret": "RustFisher"
}'

错误用法
@POST("login")
@FormUrlEncoded
Observable<Resp<LwUserData>> login(@FieldMap Map<String, Object> map);

传参应该使用@Body RequestBody，并且不要 ~~@FormUrlEncoded~~

调用网络请求¶

mNetworkManager.getUserApi().login(mLenovoToken, ServerCfg.RID, requestBody).enqueue(new Callback<LoginResp>() {
    @Override
    public void onResponse(Call<LoginResp> call, final Response<LoginResp> response) {
        // 服务器有回复 ...
    }

    @Override
    public void onFailure(Call<LoginResp> call, final Throwable t) {
        // 访问失败 ...
    }
});

信任所有服务器的ssl¶

并不推荐这么做

历史原因，有的项目里对测试站会信任所有的ssl证书。

信任所有SSL的方法

public class SSLUtils {
    /**
    * @return 信任所有服务器
    */
    public static SSLSocketFactory getSSLSocketFactory() throws Exception {
        SSLSocketFactory sslSocketFactory = null;
        SSLContext sslContext = SSLContext.getInstance("TLS");
        sslContext.init(null, new TrustManager[]{createTrustAllManager()}, new SecureRandom());
        sslSocketFactory = sslContext.getSocketFactory();
        return sslSocketFactory;
    }

    public static X509TrustManager createTrustAllManager() {
        X509TrustManager tm = null;
        try {
            tm = new X509TrustManager() {
                public void checkClientTrusted(X509Certificate[] chain, String authType)
                        throws CertificateException {
                    //do nothing，接受任意客户端证书
                }

                public void checkServerTrusted(X509Certificate[] chain, String authType)
                        throws CertificateException {
                    //do nothing，接受任意服务端证书
                }

                public X509Certificate[] getAcceptedIssuers() {
                    return new X509Certificate[0];
                }
            };
        } catch (Exception e) {

        }
        return tm;
    }

}

使用io.reactivex.Observable¶

import的时候注意一下，使用rx2的包。

import io.reactivex.Observable; // 这个是rx2的包
// ...

    /**
     * 用户反馈接口
     *
     * @param content 用户输入的反馈内容
     */
    @POST("feedbackAction")
    Observable<UserFeedback> userFeedback(@Query("appVersion") String appVersion,
                                          @Query("phoneModel") String phoneModel,
                                          @Query("phoneOsVersion") String osVersion,
                                          @Query("submitContent") String content);

示例 - Retrofit2，RxJava2¶

接下来是一个访问示例的部分代码

引入依赖¶

implementation 'com.squareup.retrofit2:retrofit:2.5.0'
implementation 'com.squareup.retrofit2:converter-gson:2.5.0'
implementation 'com.squareup.retrofit2:adapter-rxjava2:2.3.0'
implementation 'io.reactivex.rxjava2:rxandroid:2.1.1'
implementation 'io.reactivex.rxjava2:rxjava:2.2.8'

定义interface¶

import java.util.Map;

import io.reactivex.Observable;
import retrofit2.http.Field;
import retrofit2.http.FieldMap;
import retrofit2.http.FormUrlEncoded;
import retrofit2.http.GET;
import retrofit2.http.POST;
import retrofit2.http.Query;

/**
 * rustfisher.com 后台接口
 * Created on 2019-5-17
 */
public interface RustDroneCommonService {

    /**
     * 用户反馈接口
     *
     * @param content 用户输入的反馈内容
     */
    @FormUrlEncoded
    @POST("feedbackAction")
    Observable<FeedbackResp> userFeedback(@Field("appVersion") String appVersion,
                                          @Field("phoneModel") String phoneModel,
                                          @Field("phoneOsVersion") String osVersion,
                                          @Field("submitContent") String content,
                                          @FieldMap Map<String, String> map);

    /**
     * 获取手机验证码
     *
     * @param mobile 手机号
     */
    @GET("verifyCode")
    Observable<PhoneCodeResp> getPhoneCode(@Query("mobile") String mobile, @Query("oprType") int type);
}

调用接口¶

import io.reactivex.Observer;
import io.reactivex.android.schedulers.AndroidSchedulers;
import io.reactivex.disposables.Disposable;
import io.reactivex.schedulers.Schedulers;

RustDroneDataCenter.getCenter().getCommonService().userFeedback(BuildConfig.VERSION_NAME,
                    Build.MODEL.replace(" ", "-"), Build.VERSION.RELEASE, fd, ext)
                    .subscribeOn(Schedulers.newThread())
                    .observeOn(AndroidSchedulers.mainThread())
                    .subscribe(new Observer<FeedbackResp>() {
                        @Override
                        public void onSubscribe(Disposable d) {
//                            LL.dn(TAG, "onSubscribe: " + d);
                        }

                        @Override
                        public void onNext(FeedbackResp feedbackResp) {
                            LL.dn(TAG, "onNext: " + feedbackResp);
                            if (feedbackResp.getCode() == 0) {
                                popSubmitSuccessDialog();
                            } else {
                                LL.e("上传用户反馈失败");
                                mPbLayout.setVisibility(View.GONE);
                                popRetryDialog();
                            }
                        }

                        @Override
                        public void onError(Throwable e) {
                            LL.e("上传用户反馈失败 code: " + e);
                            mPbLayout.setVisibility(View.GONE);
                            popRetryDialog();
                        }

                        @Override
                        public void onComplete() {
                            mPbLayout.setVisibility(View.GONE);
                            LL.dn(TAG, "onComplete: 上传结束");
                        }
                    });

GithubOnAndroid示例¶

使用的是Github的开发API。示例代码地址： https://github.com/RustFisher/GithubOnAndroid

拦截器¶

定义拦截器¶

在下面的拦截器里打log，表明拦截到了请求。但不做其它处理。

// 仅仅是示例，不做任何处理
private Interceptor doNothingInterceptor = new Interceptor() {
    @Override
    public Response intercept(Chain chain) throws IOException {
        Log.d(TAG, "Interceptor1: intercept");
        return chain.proceed(chain.request());
    }
};

添加拦截器¶

要使用拦截器，需要把拦截器添加进去addInterceptor()

href="#__codelineno-15-1">OkHttpClient okHttpClient = new OkHttpClient.Builder() .readTimeout(10, TimeUnit.SECONDS) .connectTimeout(10, TimeUnit.SECONDS) .addInterceptor(doNothingInterceptor) // 添加拦截器 .addInterceptor(new Interceptor() { @Override public Response intercept(Chain chain) throws IOException { Log.d(TAG, "Interceptor2: intercept"); return chain.proceed(chain.request()); } }) .addNetworkInterceptor(new Interceptor() { @Override public Response intercept(Chain chain) throws IOException { Log.d(TAG, "NetworkInterceptor1: intercept"); return chain.proceed(chain.request()); } }) .build();

在拦截器中我们可以进行一些操作，比如操作chain中的request添加header。

    // 添加一些公共参数
    private Interceptor mRustDroneInterceptor = new Interceptor() {
        @Override
        public Response intercept(Chain chain) throws IOException {
            Request request = chain.request().newBuilder()
                    .addHeader("token", UserCenter.getToken())
                    .build();
            return chain.proceed(request);
        }
    };

参考¶

OkHttp系列

本文也发布在

华为云社区

本站说明

一起在知识的海洋里呛水吧。广告内容与本站无关。如果喜欢本站内容，欢迎投喂作者，谢谢支持服务器。如有疑问和建议，欢迎在下方评论~

📖AndroidTutorial 📚AndroidTutorial 🙋反馈问题 🔥最近更新 🍪投喂作者

Ads

Android OkHttp + Retrofit 使用示例¶

简单使用¶

引入依赖¶

查询 @Query¶

URL填充与拼接¶

GET带有查询的参数¶

POST，带有查询的参数和body¶

HTTP 400 Bad Request¶

调用网络请求¶

信任所有服务器的ssl¶

使用io.reactivex.Observable¶

示例 - Retrofit2，RxJava2¶

引入依赖¶

定义interface¶

调用接口¶

GithubOnAndroid示例¶

拦截器¶

定义拦截器¶

添加拦截器¶

拦截器中增加header¶

参考¶

查询 `@Query`¶