android实现okHttp的get和post请求的简单封装与使用
作者：会飞的种花家 发布时间：2023-10-06 04:20:25
标签：android,okHttp,get,post
由于Android课程项目需要，特地查阅了okHttp的使用，发现网上找的大多和自己的需求不一样。所以就着团队项目需要，自己简单封装了一个okHttp的get和post请求。
话不多说，直接看代码吧！
一、前期需要用到的属性封装
private static Request request = null;
private static Call call = null;
private static int TimeOut = 120;
//单例获取ohttp3对象
private static OkHttpClient client = null;
/**
* OkHttpClient的构造方法，通过线程锁的方式构造
* @return OkHttpClient对象
*/
private static synchronized OkHttpClient getInstance() {
if (client == null) {
client = new OkHttpClient.Builder()
.readTimeout(TimeOut, TimeUnit.SECONDS)
.connectTimeout(TimeOut, TimeUnit.SECONDS)
.writeTimeout(TimeOut, TimeUnit.SECONDS)
.build();
}
return client;
}
/**
* callback接口
* 异步请求时使用
*/
static class MyCallBack implements Callback {
private OkHttpCallback okHttpCallBack;
public MyCallBack(OkHttpCallback okHttpCallBack) {
this.okHttpCallBack = okHttpCallBack;
}
@Override
public void onFailure(Call call, IOException e) {
okHttpCallBack.onFailure(e);
}
@Override
public void onResponse(Call call, Response response) throws IOException {
okHttpCallBack.onSuccess(response);
}
}
/**
* 获得同步get请求对象Response
* @param url
* @return Response
*/
private static Response doSyncGet(String url) {
//创建OkHttpClient对象
client = getInstance();
request = new Request.Builder()
.url(url)//请求链接
.build();//创建Request对象
try {
//获取Response对象
Response response = client.newCall(request).execute();
return response;
} catch (IOException e) {
e.printStackTrace();
return null;
}
}
/**
* 获得异步get请求对象
* @param url 请求地址
* @param callback 实现callback接口
*/
private static void doAsyncGet(String url,OkHttpCallback callback) {
MyCallBack myCallback = new MyCallBack(callback);
client = getInstance();
request = new Request.Builder()
.url(url)
.get()
.build();
client.newCall(request).enqueue(myCallback);
}
其中，OKHttpCallback接口为：
import java.io.IOException;
import okhttp3.Response;
public interface OkHttpCallback {
void onFailure(IOException e);
void onSuccess(Response response);
}
二、get请求封装
1.项目需求是全程使用json格式的字符串进行交互，所以以下是针对json来封装的。
2.在这里说明一下，返回的是字符串类型，表示后台返回的json字符串，另外，为什么要用list来定义返回值result，result.get(0)为return值，因为直接用String来定义result会报错，具体原因未知。。。。
（1）同步get请求
/**
* 同步get请求
* 例如：请求的最终地址为：http://127.0.0.1:8081/user/getUser/123
* @param url 基本请求地址 例子： http://127.0.0.1:8081
* @param args 请求的参数 args[]=new String[]{"user","getUser","123"}
* @return String
*/
public static String getSyncRequest(String url,String... args) {
List<String> result=new ArrayList<>();//返回值
String address=url;
for(int i=0;i<args.length;i++){
address=address+"/"+args[i];
}
final String finalAddress = address;
new Thread(new Runnable() {
@Override
public void run() {
Response finalResponse = doSyncGet(finalAddress);
String res = null;
try {
Log.d("同步get请求请求地址：",finalAddress);
if (finalResponse.isSuccessful()) {//请求成功
ResponseBody body = finalResponse.body();//拿到响应体
res = body.string();
result.add(res);
Log.d("HttpUtil", "同步get请求成功！");
Log.d("请求对象：", res);
} else {
Log.d("HttpUtil", "同步get请求失败！");
}
} catch (IOException e) {
e.printStackTrace();
}
}
}).start();
/**因为函数返回是立刻执行的，而result要在请求完成之后才能获得
* 所以需要等待result获得返回值之后再执行return*/
while(result.size()==0){
try {
TimeUnit.MILLISECONDS.sleep(10);//等待xx毫秒
} catch (InterruptedException e) {
e.printStackTrace();
}
}
return result.get(0);
}
（2）异步get请求
/**
* 异步get请求
* 例如：请求的最终地址为：http://127.0.0.1:8081/user/getUser/123
* @param url 基本请求地址 例子： http://127.0.0.1:8081
* @param args 请求的参数 args[]=new String[]{"user","getUser","123"}
* @return String
*/
public static String getAsyncRequest(String url,String... args){
List<String> result=new ArrayList<>();
String address=url;
for(int i=0;i<args.length;i++){
address=address+"/"+args[i];
}
final String finalAddress = address;
doAsyncGet(finalAddress, new OkHttpCallback() {
@Override
public void onFailure(IOException e) {
Log.d("异步get请求地址：",finalAddress);
Log.d("HttpUtil", "异步get请求失败！");
}
@Override
public void onSuccess(Response response) {
Log.d("异步get请求地址：",finalAddress);
String res = null;
try {
res = response.body().string();
} catch (IOException e) {
e.printStackTrace();
}
result.add(res);
Log.d("HttpUtil", "异步get请求成功！");
Log.d("请求对象：", res);
}
});
/**因为函数返回是立刻执行的，而result要在请求完成之后才能获得
* 所以需要等待result获得返回值之后再执行return*/
while(result.size()==0){
try {
TimeUnit.MILLISECONDS.sleep(10);//等待xx毫秒
} catch (InterruptedException e) {
e.printStackTrace();
}
}
return result.get(0);
}
三、post请求
在此说明一下，后端接收的是一个name为“json”的字符串，实际就是传了个json字符串作为请求表单中的数据，后端通过解析这个json字符串进行下一步的操作
（1）同步post请求
/**
* 同步post请求
* 例如：请求的最终地址为：http://127.0.0.1:8081/user/getUser/123
* @param url 基本请求地址 例子： http://127.0.0.1:8081
* @param json 提交的json字符串
* @param args 请求的参数 args[]=new String[]{"user","getUser","123"}
* @return
*/
public static String postSyncRequest(String url,String json,String... args){
List<String> result=new ArrayList<>();
String address=url;
for(int i=0;i<args.length;i++){
address=address+"/"+args[i];
}
final String finalAddress = address;
new Thread(new Runnable() {
@Override
public void run() {
client=getInstance();
Log.d("同步post请求地址：",finalAddress);
FormBody.Builder formBody = new FormBody.Builder();
formBody.add("json",json);
request=new Request.Builder()
.url(finalAddress)
.post(formBody.build())
.addHeader("device-platform", "android")
.build();
try{
Response response=client.newCall(request).execute();
String res=response.body().string();
result.add(res);
Log.d("HttpUtil", "同步post请求成功！");
Log.d("请求对象：", res);
}catch (Exception e){
Log.d("HttpUtil", "同步post请求失败！");
e.printStackTrace();
}
}
}).start();
/**因为函数返回是立刻执行的，而result要在请求完成之后才能获得
* 所以需要等待result获得返回值之后再执行return*/
while(result.size()==0){
try {
TimeUnit.MILLISECONDS.sleep(10);//等待xx毫秒
} catch (InterruptedException e) {
e.printStackTrace();
}
}
return result.get(0);
}
（2）异步post请求
/**
* 异步post请求
* 例如：请求的最终地址为：http://127.0.0.1:8081/user/getUser/123
* @param url 基本请求地址 例子： http://127.0.0.1:8081
* @param json 提交的json字符串
* @param args 请求的参数 args[]=new String[]{"user","getUser","123"}
* @return
*/
public static String postAsyncRequest(String url,String json,String... args){
List<String> result=new ArrayList<>();
String address=url;
for(int i=0;i<args.length;i++){
address=address+"/"+args[i];
}
final String finalAddress = address;
Log.d("同步post请求地址：",finalAddress);
client=getInstance();
FormBody.Builder formBody = new FormBody.Builder();//创建表单请求体
formBody.add("json",json);
request = new Request.Builder()
.url(finalAddress)
.post(formBody.build())
.addHeader("device-platform", "android")
.build();
Call call=client.newCall(request);
call.enqueue(new Callback() {
@Override
public void onFailure(@NotNull Call call, @NotNull IOException e) {
new Thread(new Runnable() {
@Override
public void run() {
Log.d("HttpUtil","异步post请求失败！");
}
}).start();
}
@Override
public void onResponse(@NotNull Call call, @NotNull Response response) throws IOException {
new Thread(new Runnable() {
@Override
public void run() {
String res = null;
try {
res = response.body().string();
} catch (IOException e) {
e.printStackTrace();
}
result.add(res);
Log.d("HttpUtil","异步post请求成功！");
Log.d("请求对象",res);
}
}).start();
}
});
/**因为函数返回是立刻执行的，而result要在请求完成之后才能获得
* 所以需要等待result获得返回值之后再执行return*/
while(result.size()==0){
try {
TimeUnit.MILLISECONDS.sleep(10);//等待xx毫秒
} catch (InterruptedException e) {
e.printStackTrace();
}
}
return result.get(0);
}
四、依赖以及相关说明
相关依赖为：（okHttp和Gson）
implementation 'com.squareup.okhttp3:okhttp:4.2.2'
implementation 'com.google.code.gson:gson:2.7'
由于取消掉延时会导致result还没有被赋值就已经进行到return这里了，所以在每个请求方法中在return之前都加了个延时，直到result被赋值了再执行return
下一篇是讲android是如何通过okHttp跟后端交互起来的，以及相关例子。
来源：https://blog.csdn.net/weixin_47062406/article/details/116330158
0
投稿猜你喜欢
- 本文为大家介绍了java图片添加水印实例代码，java实现水印还是非常方便的，水印可以是图片或者文字，具体内容如下package micha
前言前面我们已经实现了服务的注册与发现（请戳：SpringCloud系列——Eureka 服务注册与发现），并且在注册中心注册了一个服务my- 本文实例为大家分享了Java实现超市会员管理系统的具体代码，供大家参考，具体内容如下要求：借助集合框架及实用类实现该系统1、积分累计2、积分
- 上一篇说的CountDownLatch是一个计数器，类似线程的join方法，但是有一个缺陷，就是当计数器的值到达0之后，再调用CountDo
- 1.创建一个带Mesh的物体Unity中的网格作为组件不能脱离物体单独存在新建脚本CreateMeshpublic class Create
- 使用maven的profile功能，我们可以实现多环境配置文件的动态切换，可参考我的上一篇博客。但随着SpringBoot项目越来越火，越来
- 在开发中，我们经常使用到ListView这个控件。Android的API也提供了许多创建ListView适配器的快捷方式。例如A
- 前提前段时间在做一个对外的网关项目，涉及到加密和解密模块，这里详细分析解决方案和适用的场景。为了模拟真实的交互场景，先定制一下整个交互流程。
- 将DataGrid中上面这个表头变成下面的两行表头，你会怎么实现？很巧妙地截断和补充td tr来实现来源：http://www.cnsend
- 目录1、一个抽象类并不需要其中所有的方法都是抽象的。（ ）2、下列程序的运行结果3、在Java中，关于HashMap类的描述，以下错误的是（
- 本文实例为大家分享了Android实现背景图片轮播的具体代码，供大家参考，具体内容如下点击按钮实现图片轮播效果实践案例：xml<?xm
- 本文为大家分享了实现断点续传下载的具体代码，供大家参考，具体内容如下1、基于Ok+Rxjava实现断点续传下载2、基于Ok+Rxjava+R
- 使用ExecutorService来停止线程服务之前的文章中我们提到了ExecutorService可以使用shutdown和shutdow
- 前言J.U.C是java包java.util.concurrent的简写，中文简称并发包，是jdk1.5新增用来编写并发相关的基础api。j
- 把char数组转换成String调用reverseStr()传入一个字符串"let’s"
- 1.什么是PDF/UA文件PDF/UA，即Universally Accessible PDF，该格式的PDF文件是于2012年8月以ISO
- Mybatis是业界非常流行的持久层框架，轻量级、易用，在金融IT领域完全是领军地位，比Hibernate更受欢迎，优势非常多，也是非常值得
- 本文实例讲述了Android编程实现动态支持多语言的方法。分享给大家供大家参考，具体如下：资源文件values/strings.xml中添加
- FilterInputStream 介绍FilterInputStream 的作用是用来“封装其它的输入流，并为它们提供额外的功能”。它的常
- 1. 概述官方JavaDocsApi: javax.swing.JTextAreaJTextArea，文本区域。JTextArea 用来编辑
