一些依赖包
implementation 'androidx.recyclerview:recyclerview:1.0.0'
implementation 'com.google.code.gson:gson:2.8.5'
implementation 'com.squareup.okhttp3:okhttp:3.4.1'
在Activity中调用,一般的都是异步调用,不要因为网络而卡程序运行
private List<Post> posts; private String url = "https://xyc.com"; //异步请求数据 OkHttp.getAsync(url, new OkHttp.DataCallBack() { @Override public void requestFailure(Request request, IOException e) { //这里处理异常 } @Override public void requestSuccess(String result) throws Exception { Gson gson = new Gson(); posts = gson.fromJson(result, new TypeToken<List<Post>>() { }.getType()); setRecyclerView(); } });
okhttp示例代码,直接写成一个工具类
package com.sinoll.codetest; import android.os.Handler; import android.os.Looper; import java.io.IOException; import java.util.concurrent.TimeUnit; import okhttp3.Call; import okhttp3.Callback; import okhttp3.OkHttpClient; import okhttp3.Request; import okhttp3.Response; public class OkHttp { /** * 静态实例 */ private static OkHttp sOkHttpManager; /** * okhttpclient实例 */ private OkHttpClient mClient; /** * 因为我们请求数据一般都是子线程中请求,在这里我们使用了handler */ private Handler mHandler; /** * 构造方法 */ private OkHttp() { mClient = new OkHttpClient(); /** * 在这里直接设置连接超时.读取超时,写入超时 */ mClient.newBuilder().connectTimeout(10, TimeUnit.SECONDS); mClient.newBuilder().readTimeout(10, TimeUnit.SECONDS); mClient.newBuilder().writeTimeout(10, TimeUnit.SECONDS); /** * 如果是用的3.0之前的版本 使用以下直接设置连接超时.读取超时,写入超时 */ //client.setConnectTimeout(10, TimeUnit.SECONDS); //client.setWriteTimeout(10, TimeUnit.SECONDS); //client.setReadTimeout(30, TimeUnit.SECONDS); /** * 初始化handler */ mHandler = new Handler(Looper.getMainLooper()); } /** * 单例模式 获取OkHttp实例 * * @return */ public static OkHttp getInstance() { if (sOkHttpManager == null) { sOkHttpManager = new OkHttp(); } return sOkHttpManager; } //-------------------------同步的方式请求数据-------------------------- /** * 对外提供的get方法,同步的方式 * * @param url 传入的地址 * @return */ public static Response getSync(String url) { //通过获取到的实例来调用内部方法 return sOkHttpManager.inner_getSync(url); } /** * GET方式请求的内部逻辑处理方式,同步的方式 * * @param url * @return */ private Response inner_getSync(String url) { Request request = new Request.Builder().url(url).build(); Response response = null; try { //同步请求返回的是response对象 response = mClient.newCall(request).execute(); } catch (IOException e) { e.printStackTrace(); } return response; } /** * 对外提供的同步获取String的方法 * * @param url * @return */ public static String getSyncString(String url) { return sOkHttpManager.inner_getSyncString(url); } /** * 同步方法 */ private String inner_getSyncString(String url) { String result = null; try { /** * 把取得到的结果转为字符串,这里最好用string() */ result = inner_getSync(url).body().string(); } catch (IOException e) { e.printStackTrace(); } return result; } //-------------------------异步的方式请求数据-------------------------- public static void getAsync(String url, DataCallBack callBack) { getInstance().inner_getAsync(url, callBack); } /** * 内部逻辑请求的方法 * * @param url * @param callBack * @return */ private void inner_getAsync(String url, final DataCallBack callBack) { final Request request = new Request.Builder().url(url).build(); mClient.newCall(request).enqueue(new Callback() { @Override public void onFailure(Call call, IOException e) { deliverDataFailure(request, e, callBack); } @Override public void onResponse(Call call, Response response) throws IOException { String result = null; try { result = response.body().string(); } catch (IOException e) { deliverDataFailure(request, e, callBack); } deliverDataSuccess(result, callBack); } }); } /** * 分发失败的时候调用 * * @param request * @param e * @param callBack */ private void deliverDataFailure(final Request request, final IOException e, final DataCallBack callBack) { /** * 在这里使用异步处理 */ mHandler.post(new Runnable() { @Override public void run() { if (callBack != null) { callBack.requestFailure(request, e); } } }); } /** * 分发成功的时候调用 * * @param result * @param callBack */ private void deliverDataSuccess(final String result, final DataCallBack callBack) { /** * 在这里使用异步线程处理 */ mHandler.post(new Runnable() { @Override public void run() { if (callBack != null) { try { callBack.requestSuccess(result); } catch (Exception e) { e.printStackTrace(); } } } }); } /** * 数据回调接口 */ public interface DataCallBack { void requestFailure(Request request, IOException e); void requestSuccess(String result) throws Exception; } }