背景
原本使用org.apache.commons.httpclient 方法封装进行http接口测试，由于支持异步请求和H2不易，因此研究采用 OkHttpClient方式进行替换
为了保证兼容性，采用的方法调用尽量与原来的org.apache.commons.httpclient 使用方法保持一致
OkHttpClient的强大大家大可百度瞅瞅
踩坑
1.响应结果response.body().string一直不能正常显示，后来改用原有封装的读byte流转String方式解决
封装
构造方法
/**
* 构造函数初始化
*/
private OkHttpClientMethod(){
OkHttpClient.Builder builder = new OkHttpClient.Builder();
builder.readTimeout(30, TimeUnit.SECONDS);//读取超时
builder.connectTimeout(10,TimeUnit.SECONDS);//连接超时
builder.writeTimeout(60,TimeUnit.SECONDS);//写入超时
//协议
List<Protocol> protocols = new ArrayList<Protocol>();
protocols.add(Protocol.HTTP_1_1);
protocols.add(Protocol.HTTP_2);
builder.protocols(protocols);
//ssl
HttpsUtils.SSLParams sslParams = HttpsUtils.getSslSocketFactory(null, null, null);
builder.hostnameVerifier(new HostnameVerifier() {
public boolean verify(String s, SSLSession sslSession) {
return true;
}
});
builder.sslSocketFactory(sslParams.sSLSocketFactory,sslParams.trustManager);
//cookie 自动存储
builder.cookieJar(new CookieJar() {
public void saveFromResponse(HttpUrl url, List<Cookie> cookies) {
cookieStore.put(url.host(),cookies);
}
public List<Cookie> loadForRequest(HttpUrl url) {
List<Cookie> cookies = cookieStore.get(url.host());
return cookies != null ? cookies : new ArrayList<Cookie>();
}
});
mOkHttpClient = builder.build();
}
单例实现
/**
* 单例实现
* @return
*/
public static OkHttpClientMethod getInstance(){
if(mInstance == null){
synchronized (OkHttpClientMethod.class){
if(mInstance == null){
mInstance = new OkHttpClientMethod();
}
}
}
return mInstance;
}
设置Header头
/**
* 设置Header头
* @param headersParams
* @return
*/
private Headers setHeaders(Map<String,Object> headersParams){
Headers headers = null;
Headers.Builder headerBuilder = new Headers.Builder();
if(headersParams != null){
for (String key:headersParams.keySet()){
headerBuilder.add(key,headersParams.get(key).toString());
}
}
headers = headerBuilder.build();
return headers;
}设置url参数拼接
/**
* 设置get连接拼接参数
* @param params
* @return
*/
private String setUrlParams(Map<String,Object> params){
StringBuffer param = new StringBuffer();
int i = 0;
if(params == null){
return param.toString();
}
for (String key : params.keySet()) {
if (i == 0)
param.append("?");
else
param.append("&");
try {
param.append(key).append("=").append(URLEncoder.encode(params.get(key).toString(),"UTF-8")); //字符串拼接
} catch (UnsupportedEncodingException e) {
e.printStackTrace();
}
i++;
}
return param.toString();
}
设置Post表单请求
/**
* 设置post表单请求
* @param params
* @return
*/
private RequestBody setPostBody(Map<String,Object> params){
RequestBody body = null;
FormBody.Builder formBodyBuilder = new FormBody.Builder();
if(params != null){
for (String key:params.keySet()){
formBodyBuilder.add(key,params.get(key).toString());
}
}
body = formBodyBuilder.build();
return body;
}
get方法封装
/**
* Get请求
* @param url
* @param urlParams
* @param headerParams
* @return
*/
public Object getMethod(String url,Map<String, Object> urlParams, Map<String, Object> headerParams){
Request request = new Request.Builder()
.url(url + setUrlParams(urlParams))
.headers(setHeaders(headerParams))
.get()
.build();
Call call = mOkHttpClient.newCall(request);
JSONObject jsonResult = new JSONObject();
log.info("Http info:" + request.toString());
log.info("Http Header:" + request.headers().toString());
try {
Response response = call.execute();
String result = InputStreamUtils.inputStreamTOString(response.body().byteStream(),"UTF-8");
log.info("Http Result:" + result);
if (response.isSuccessful()){
jsonResult = JSONObject.fromObject(result);
return jsonResult;
}
} catch (Exception e) {
e.printStackTrace();
}
return jsonResult;
}
异步Get方法封装
/**
* 异步Get请求
* @param url
* @param urlParams
* @param headerParams
* @return
*/
public void getAsyncMethod(String url,Map<String, Object> urlParams, Map<String, Object> headerParams,OkHttpClientCallBack okHttpRequestCallBack){
Request request = new Request.Builder()
.url(url + setUrlParams(urlParams))
.headers(setHeaders(headerParams))
.get()
.build();
Call call = mOkHttpClient.newCall(request);
log.info("Http info:" + request.toString());
log.info("Http Header:" + request.headers().toString());
try {
call.enqueue(okHttpRequestCallBack);
} catch (Exception e) {
e.printStackTrace();
}
}
异步Get原生封装
/**
* 异步Get请求 原生
* @param url
* @param urlParams
* @param headerParams
* @return
*/
public void getAsyncNativeMethod(String url,Map<String, Object> urlParams, Map<String, Object> headerParams,Callback callback){
Request request = new Request.Builder()
.url(url + setUrlParams(urlParams))
.headers(setHeaders(headerParams))
.get()
.build();
Call call = mOkHttpClient.newCall(request);
log.info("Http info:" + request.toString());
log.info("Http Header:" + request.headers().toString());
try {
call.enqueue(callback);
} catch (Exception e) {
e.printStackTrace();
}
}
异步Post请求
/**
* 异步Post请求
* @param url
* @param urlParams
* @param bodyParams
* @param headerParams
* @return
*/
public void postAsyncMethod(String url, Map<String, Object> urlParams, Map<String, Object> bodyParams, Map<String, Object> headerParams,OkHttpClientCallBack okHttpRequestCallBack){
Request request = new Request.Builder()
.url(url + setUrlParams(urlParams))
.headers(setHeaders(headerParams))
.post(setPostBody(bodyParams))
.build();
Call call = mOkHttpClient.newCall(request);
log.info("Http info:" + request.toString());
log.info("Http Header:" + request.headers().toString());
log.info("Http params:" + request.body().toString());
try {
call.enqueue(okHttpRequestCallBack);
} catch (Exception e) {
e.printStackTrace();
}
}
异步post JSON请求封装
/**
* 发送JSON 异步post请求
* @param url
* @param urlParams
* @param jsonParams
* @param headerParams
* @return
*/
public void postJsonAsyncMethod(String url,Map<String,Object> urlParams,Object jsonParams,Map<String,Object> headerParams,OkHttpClientCallBack okHttpRequestCallBack){
RequestBody requestBody = FormBody.create(MediaType.parse("application/json"),JSONObject.fromObject(jsonParams).toString());
Request request = new Request.Builder()
.url(url + setUrlParams(urlParams))
.headers(setHeaders(headerParams))
.post(requestBody)
.build();
Call call = mOkHttpClient.newCall(request);
log.info("Http info:" + request.toString());
log.info("Http Header:" + request.headers().toString());
log.info("Http params:" + request.body().toString());
try {
call.enqueue(okHttpRequestCallBack);
} catch (Exception e) {
e.printStackTrace();
}
}
调用方式
/**
* 测试 JSON 异步JSON请求
*/
@Test
public void testPostAsnycJsonHttp() throws Exception{
//设置url
String url = "http://192.168.3.14:8980/xxxxxxxxx";
Map<String,Object> headers = new HashMap<String,Object>();
headers.put("Content-Type","application/json");
headers.put("Connection","Upgrade, HTTP2-Settings");
headers.put("Upgrade","h2c");
JSONObject params = new JSONObject();
params.put("searchAll",0);
OkHttpClientCallBack okHttpClientCallBack = new OkHttpClientCallBack();
OkHttpClientMethod okHttpClientMethod = OkHttpClientMethod.getInstance();
okHttpClientMethod.postJsonAsyncMethod(url,null,params,headers,okHttpClientCallBack);
for (int i = 0; i < 10; i++) {
System.out.println("我是主线程,线程Id为:" + Thread.currentThread().getId());
try {
Thread.currentThread().sleep(100);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
Long beforeTime = System.currentTimeMillis();
System.out.println("你说啥就是啥:" + beforeTime);
System.out.println(okHttpClientCallBack.getResult());
Long afterTime = System.currentTimeMillis();
System.out.println("该干啥就干啥:" + Long.toString(afterTime - beforeTime));
}
版权声明：本文为tigereg000原创文章，遵循CC 4.0 BY-SA版权协议，转载请附上原文出处链接和本声明。