andriod中對(duì)OkhttpClient請(qǐng)求的封裝及

為了不重復(fù)去寫(xiě)代碼，對(duì)okhttpClient請(qǐng)求做封裝，包含了如何跳過(guò)請(qǐng)求證書(shū)驗(yàn)證，以及請(qǐng)求攔截器中對(duì)報(bào)文加密，響應(yīng)攔截器中報(bào)文解密的實(shí)現(xiàn)如下：
1、modle的build.gradle添加依賴
implementation 'com.squareup.okhttp3:okhttp:3.7.0'
implementation 'com.squareup.retrofit2:retrofit:2.9.0'
implementation "com.squareup.retrofit2:converter-gson:2.9.0"
implementation 'com.alibaba:fastjson:1.2.4'
2、RequestService代碼如下：

import retrofit2.Call;
import okhttp3.RequestBody;
import okhttp3.ResponseBody;
import retrofit2.http.Body;
import retrofit2.http.GET;
import retrofit2.http.Headers;
import retrofit2.http.POST;
import retrofit2.http.Path;
import retrofit2.http.Streaming;
import retrofit2.http.Url;

/**
 * 作者：created by fanHongJiao
 */
public class RequestService {
    public interface commonService {
        @Headers({"Content-type:application/json;charset=UTF-8"})
        @POST("{reqPath}")
        Call<ResponseBody> createCommit(@Path(value = "reqPath", encoded = true) String path, @Body RequestBody route);

        @Headers({"Content-type:application/json;charset=UTF-8"})
        @POST("")
        Call<ResponseBody> createUilCommit(@Url String url, @Body RequestBody route);
    }

    public interface downloadFileService {
        @Streaming
        @GET
        Call<ResponseBody> downloadFileWithDynamicUrlSync(@Url String fileUrl);
    }

}

3、RequestBodyFactory代碼如下

package okhttpclientDemo.utils;
import org.json.JSONException;
import org.json.JSONObject;
import java.text.SimpleDateFormat;
import java.util.Calendar;
import java.util.Date;
import okhttp3.MediaType;
import okhttp3.RequestBody;
import okhttp3.ResponseBody;
import retrofit2.Call;

/**
 * 作者：created by fanHongJiao
 */
public class RequestBodyFactory {
    public static Call<ResponseBody> requestNet(Object body,String reqPath) throws JSONException {
        RequestService.commonService service=NetManger.getInstance().CreateService(RequestService.commonService.class);
        JSONObject jsonObject=new JSONObject();
        JSONObject heard=new JSONObject();
        Date time= Calendar.getInstance().getTime();
        SimpleDateFormat format=new SimpleDateFormat("yyyy-MM-dd hh:mm:ss");
        heard.put("time",format.format(time));
        jsonObject.put("heard",heard);
        RequestBody requestBody=RequestBody.create(MediaType.parse("Content-Type,application/json"),jsonObject.toString());
        Call<ResponseBody> commit=service.createCommit(reqPath,requestBody);
        return commit;
    }
}

4、NetManger代碼

package okhttpclientDemo.utils;

import com.google.gson.Gson;
import com.google.gson.GsonBuilder;

import java.security.KeyManagementException;
import java.security.NoSuchAlgorithmException;
import java.security.SecureRandom;
import java.security.cert.CertificateException;
import java.security.cert.X509Certificate;
import java.util.concurrent.TimeUnit;
import javax.net.ssl.HostnameVerifier;
import javax.net.ssl.SSLContext;
import javax.net.ssl.SSLSession;
import javax.net.ssl.TrustManager;
import javax.net.ssl.X509TrustManager;
import okhttp3.OkHttpClient;
import okhttpclientDemo.utils.e2ee.RequestInterceptor;
import okhttpclientDemo.utils.e2ee.ResponseInterceptor;
import retrofit2.Retrofit;
import retrofit2.converter.gson.GsonConverterFactory;

/**
 * 作者：created by fanHongJiao
 */
public class NetManger {
    private static NetManger instance;
    Retrofit retrofit;

    public static NetManger getInstance() {
        if (instance == null) {
            instance = new NetManger();
        }
        return instance;
    }

    private NetManger() {

        //跳過(guò)http驗(yàn)證
        X509TrustManager xtm = new X509TrustManager() {
            @Override
            public void checkClientTrusted(X509Certificate[] x509Certificates, String s) throws CertificateException {

            }

            @Override
            public void checkServerTrusted(X509Certificate[] x509Certificates, String s) throws CertificateException {

            }

            @Override
            public X509Certificate[] getAcceptedIssuers() {
                return new X509Certificate[0];
            }
        };

        SSLContext sslContext = null;
        try {
            sslContext = SSLContext.getInstance("SSL");
            sslContext.init(null, new TrustManager[]{xtm}, new SecureRandom());

        } catch (NoSuchAlgorithmException | KeyManagementException e) {
            e.printStackTrace();
        }

        HostnameVerifier DO_NOT_VERIFY = new HostnameVerifier() {
            @Override
            public boolean verify(String s, SSLSession sslSession) {
                return true;
            }
        };

        OkHttpClient client = new OkHttpClient().newBuilder()
                .sslSocketFactory(sslContext.getSocketFactory())//跳過(guò)hhtp驗(yàn)證
                .hostnameVerifier(DO_NOT_VERIFY)
                .addInterceptor(new RequestInterceptor())//攔截器
                .addInterceptor(new ResponseInterceptor())
                .connectTimeout(5, TimeUnit.SECONDS)//鏈接超時(shí)時(shí)間
                .readTimeout(120, TimeUnit.SECONDS)
                .callTimeout(120, TimeUnit.SECONDS)
                .build();

        //配置你的gson
        Gson gson = new GsonBuilder()
                .setDateFormat("yyyy-MM-dd hh:mm:ss")
                .create();
        retrofit = new Retrofit.Builder()
                .baseUrl(Constant.BaseUrl)//url
                .addConverterFactory(GsonConverterFactory.create(gson))
                .client(client)
                .build();
    }

    public <T> T CreateService(Class tClass) {
        T service = (T) retrofit.create(tClass);
        return service;
    }

}

5、IResponse代碼如下：

package okhttpclientDemo.utils;

import org.json.JSONObject;

/**
 *
 * 作者：created by fanHongJiao
 */
public interface IResponse {
    void success(JSONObject object);
    void failed(String code,String message,Object obj);
}

6、HttpRequestManager代碼如下：

package okhttpclientDemo.utils;

import org.json.JSONException;
import org.json.JSONObject;
import java.io.IOException;
import okhttp3.ResponseBody;
import retrofit2.Call;
import retrofit2.Callback;
import retrofit2.Response;

/**
 *
 * 作者：created by fanHongJiao
 */
public class HttpRequestManager {
    public static final void postRequestObject(JSONObject body,String path,final IResponse callBack) throws JSONException {
        Call<ResponseBody>responseBodyCall=RequestBodyFactory.requestNet(body,path);
        responseBodyCall.enqueue(new Callback<ResponseBody>() {
            @Override
            public void onResponse(Call<ResponseBody> call, Response<ResponseBody> response) {
                try {
                    String string = response.body().string();
                    callBack.success(body);
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }

            @Override
            public void onFailure(Call<ResponseBody> call, Throwable t) {
                callBack.failed("-3", t.getMessage(), t);
                //連接失敗
            }
        });
    }
}

7、Constant代碼如下：

package okhttpclientDemo.utils;

/**
 *常量定義
 * 作者：created by fanHongJiao
 */
public class Constant {
    public static  final  String BaseUrl="https://220.241.39.45/cibs/sit/";
    public static  final  String requestUrl="custpc/generateGetSessionKey.do";
}

8、E2eeUtils用于模擬加解密，具體如何加密根據(jù)需求

package okhttpclientDemo.utils.e2ee;

/**
 * 模仿加密，如何加密根據(jù)需求添加代碼
 * 作者：created by fanHongJiao
 */
public class E2eeUtils {
    public E2eeUtils() {
    }

    /**
     * 加密操作
     * @param bytes
     * @return
     */
    public String encrypt(byte[] bytes) {
        String enStr = null;
        return enStr;
    }

    /**
     * 解密
     * @param bytes
     * @return
     */
    public String decrypt(byte[] bytes){
        String decStr=null;
        return decStr;
    }
}

9、RequestInterceptor請(qǐng)求攔截器，在請(qǐng)求發(fā)出之前執(zhí)行，用于放加密，統(tǒng)一的請(qǐng)求頭參數(shù)代碼如下：

package okhttpclientDemo.utils.e2ee;
import java.io.IOException;
import java.nio.charset.Charset;
import okhttp3.MediaType;
import okhttpclientDemo.utils.e2ee.E2eeUtils;
import okio.Buffer;
import okhttp3.Interceptor;
import okhttp3.Request;
import okhttp3.RequestBody;
import okhttp3.Response;
/**
 * 請(qǐng)求攔截器,可對(duì)報(bào)文加密， 或者添加公共參數(shù)等
 * 作者：created by fanHongJiao
 */
public class RequestInterceptor implements Interceptor {
    private static boolean isE2ee = false;//是否加密，true表示需要加密
    private static final String CHARSET = "UTF-8";

    @Override
    public Response intercept(Chain chain) throws IOException {
        Request request = chain.request();
        RequestBody requestBody = request.body();
        String requestUrl = request.url().toString();
        //判斷是否需要加密
        if (isE2ee) {
            Buffer buffer = new Buffer();
            //做加密，以簡(jiǎn)單的md5加密為例
            E2eeUtils e2eeUtils = new E2eeUtils();
            requestBody.writeTo(buffer);
            Charset charset;
            MediaType contentType = requestBody.contentType();
            charset = contentType.charset(Charset.forName("UTF-8"));
            String requestString = buffer.readString(charset);//讀取請(qǐng)求體
            String encrytParams = null;
            encrytParams = e2eeUtils.encrypt(requestString.getBytes(CHARSET));//加密

            RequestBody body = chain.request().body();
            MediaType contentType1 = body.contentType();
            if(encrytParams!=null){
            requestBody = RequestBody.create(contentType1, encrytParams.trim());}
            request = chain.request()
                    .newBuilder()
                    .header("Accept-Language", "en")//okhttp請(qǐng)求頭提交語(yǔ)言
                    .post(requestBody)
                    .build();
        }
        return chain.proceed(request);
    }
}

10、ResponseInterceptor請(qǐng)求數(shù)據(jù)返回時(shí)執(zhí)行，可處理報(bào)文解密，代碼如下：

package okhttpclientDemo.utils.e2ee;

import java.io.IOException;
import java.nio.charset.Charset;
import okhttp3.Interceptor;
import okhttp3.MediaType;
import okhttp3.Request;
import okhttp3.Response;
import okhttp3.ResponseBody;
import okhttpclientDemo.utils.e2ee.E2eeUtils;
import okio.Buffer;
import okio.BufferedSource;
/**
 * 請(qǐng)求響應(yīng)攔截器，處理返回的加密報(bào)文得解密
 * 作者：created by fanHongJiao
 */
public class ResponseInterceptor implements Interceptor {
    private static boolean isE2ee = false;//是否解密，true表示需要解密
    private static final String CHARSET = "UTF-8";

    @Override
    public Response intercept(Chain chain) throws IOException {
        Request request=chain.request();
        Response response=chain.proceed(request);
        ResponseBody responseBody=response.body();
        if(responseBody!=null){
            //獲取響應(yīng)body
            BufferedSource source=responseBody.source();
            source.request(Long.MAX_VALUE);
            Buffer buffer=source.buffer();
            Charset charset=Charset.forName("UTF-8");
            MediaType contentType=responseBody.contentType();
            charset=contentType.charset(charset);
            String bodyString=buffer.clone().readString(charset);
            String responseData=null;
            if(isE2ee){
                E2eeUtils e2eeUtils=new E2eeUtils();
                responseData=e2eeUtils.decrypt(bodyString.getBytes(CHARSET));//解密
                if(responseData!=null) {
                    ResponseBody newResponseBody = ResponseBody.create(contentType, responseData);

                response=response
                        .newBuilder()
                        .body(newResponseBody)
                        .build();
                return response;
                }

            }
        }
        return response;
    }
}

11、OkHttpClientActivity，測(cè)試請(qǐng)求頁(yè)面代碼如下：

package okhttpclientDemo;

import androidx.appcompat.app.AppCompatActivity;
import android.os.Bundle;
import android.util.Log;
import com.example.viewpaerdemo.R;
import org.json.JSONException;
import org.json.JSONObject;
import okhttpclientDemo.utils.Constant;
import okhttpclientDemo.utils.HttpRequestManager;
import okhttpclientDemo.utils.IResponse;
public class OkHttpClientActivity extends AppCompatActivity {

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_ok_http_client);
        JSONObject body=new JSONObject();
        try {
            body.put("heard","heard");
        } catch (JSONException e) {
            e.printStackTrace();
        }
        try {
            HttpRequestManager.postRequestObject(body, Constant.requestUrl, new IResponse() {
                @Override
                public void success(JSONObject object) {
                    Log.e("success:",object.toString());
                }

                @Override
                public void failed(String code, String message, Object obj) {
                    Log.e("failed:",obj.toString());
                }
            });
        } catch (JSONException e) {
            e.printStackTrace();
        }
    }
}

完結(jié)。

?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成，瀏覽時(shí)請(qǐng)結(jié)合常識(shí)與多方信息審慎甄別。
平臺(tái)聲明：文章內(nèi)容（如有圖片或視頻亦包括在內(nèi)）由作者上傳并發(fā)布，文章內(nèi)容僅代表作者本人觀點(diǎn)，簡(jiǎn)書(shū)系信息發(fā)布平臺(tái)，僅提供信息存儲(chǔ)服務(wù)。

相關(guān)閱讀更多精彩內(nèi)容

友情鏈接更多精彩內(nèi)容