okhttp 使用 post-低调大师

okhttp 使用 post

2018-02-04 618

java okhttp maven pom

<dependency>
<groupId>com.squareup.okhttp3</groupId>
<artifactId>okhttp</artifactId>
<version>3.2.0</version>
</dependency>
<dependency>
<groupId>com.squareup.okio</groupId>
<artifactId>okio</artifactId>
<version>1.7.0</version>
</dependency>

OkhttpUtils.java

import java.io.File;
import java.io.IOException;
import java.util.HashMap;
import java.util.Map;
import java.util.Map.Entry;

import okhttp3.Call;
import okhttp3.Callback;
import okhttp3.FormBody;
import okhttp3.FormBody.Builder;
import okhttp3.MediaType;
import okhttp3.MultipartBody;
import okhttp3.OkHttpClient;
import okhttp3.Request;
import okhttp3.RequestBody;
import okhttp3.Response;
import okio.BufferedSink;

import com.curiousby.baoyou.cn.showandshare.application.otherapplicaition.springbootdubboconsumer.common.RespEntity;
import com.curiousby.baoyou.cn.showandshare.application.otherapplicaition.springbootdubboconsumer.common.RespEnums;
import com.curiousby.baoyou.cn.showandshare.application.otherapplicaition.springbootdubboconsumer.common.ValidatorUtil;
 
public class OkhttpUtils { 

	public static RespEntity postPipe(String url,   Map<String, Object> params) {
		RespEntity entity = new RespEntity("");
		  RequestBody requestBody = new RequestBody( ) {
				@Override
				public MediaType contentType() { 
					return  MediaType.parse("application/json;charset:UTF-8");
				}

				@Override
				public void writeTo(BufferedSink sink) throws IOException {
					sink.writeUtf8(FastJsonUtils.toJSONString(params));
				}
				  
			  };
			  
			  Request request = new Request.Builder()
		        .url(url)
		        .post(requestBody)
		        .build();
			  OkHttpClient client = new OkHttpClient();
			  Response response  = null;
			  try {
				  response = client.newCall(request).execute();
			} catch (IOException e) { 
				e.printStackTrace();
				entity.setCode(RespEnums.RESP_EXCEPTION.getCode());
				entity.setMsg(e.getMessage());
			}
			  
			  if (!response.isSuccessful()) {
				  entity.setCode(RespEnums.RESP_OTHER_RESP_CODE.getCode()); 
				}
				String result = null;
				try {
					result = response.body().string();
					entity.setData(result);
				} catch (IOException e) {
					e.printStackTrace();
					entity.setCode(RespEnums.RESP_EXCEPTION.getCode());
					entity.setMsg(e.getMessage());
				} 
		return entity;
	}
	
	public static RespEntity post(String url, Map<String, Object> headers, Map<String, Object> params) {
		RespEntity entity = new RespEntity("");
		OkHttpClient client = new OkHttpClient();
		FormBody.Builder formBuilder = new FormBody.Builder();
		if (!ValidatorUtil.isEmpty(params)) {
			for (Entry<String, Object> entry : params.entrySet()) {
				formBuilder.add(entry.getKey(), ValidatorUtil.getObjOrEmpty(entry.getValue()).toString());
				
			}
		}
		
		FormBody form = formBuilder.build();
		
		Request.Builder requestBuilder = new Request.Builder();
		//requestBuilder.addHeader("content-type", "application/json;charset:UTF-8") ;
		if (!ValidatorUtil.isEmpty(headers)) {
			for (Entry<String, Object> entry : headers.entrySet()) {
				requestBuilder.addHeader(entry.getKey(), ValidatorUtil.getObjOrEmpty(entry.getValue()).toString());
			}
		}
		requestBuilder.url(url);
		requestBuilder.post(form);
		Request request = requestBuilder.build();

		Response response = null;
		try {
			response = client.newCall(request).execute();
		} catch (IOException e) {
			e.printStackTrace();
			entity.setCode(RespEnums.RESP_EXCEPTION.getCode());
			entity.setMsg(e.getMessage());
		}
		if (!response.isSuccessful()) {
			entity.setCode(RespEnums.RESP_OTHER_RESP_CODE.getCode());
			entity.setMsg("error code : "+response.code());
		}
		String result = null;
		try {
			result = response.body().string();
			entity.setData(result);
		} catch (IOException e) {
			e.printStackTrace();
			entity.setCode(RespEnums.RESP_EXCEPTION.getCode());
			entity.setMsg(e.getMessage());
		}
		
		return entity;
	}
	
	
	

	public static void postAsynchronize(String url, Map<String, Object> params) {
		OkHttpClient client = new OkHttpClient();
		Builder builder = new FormBody.Builder();
		for (Entry<String, Object> entry : params.entrySet()) {
			builder.add(entry.getKey(),
					ValidatorUtil.getObjOrEmpty(entry.getValue()).toString());
		}
		FormBody form = builder.build();

		Request request = new Request.Builder().url(url).post(form).build();

		Call call = client.newCall(request);
		call.enqueue(new Callback() {
			@Override
			public void onFailure(Call call, IOException e) {
				// 访问失败, 打印访问地址
				Request r = call.request();
				System.out.println("请求失败: " + r.url());
				System.out.println(r.body());
			}

			@Override
			public void onResponse(Call call, Response response)
					throws IOException {
				System.out.println("请求有响应" + call.request().url());
				System.out.println("响应码: " + response.code());
				System.out.println("请求内容: " + response.body().string());
			}
		});
	}

	public static void postSynchronize(String url, Map<String, Object> params) {
		OkHttpClient client = new OkHttpClient();
		Builder builder = new FormBody.Builder();
		for (Entry<String, Object> entry : params.entrySet()) {
			builder.add(entry.getKey(), ValidatorUtil.getObjOrEmpty(entry.getValue()).toString());
			
		}
		FormBody form = builder.build();

		Request request = new Request.Builder().url(url).post(form).build();

		Response response = null;
		try {
			response = client.newCall(request).execute();
		} catch (IOException e) {
			e.printStackTrace();
		}
		if (!response.isSuccessful()) {

		}
		String result = null;
		try {
			result = response.body().string();
		} catch (IOException e) {
			e.printStackTrace();
		}
	}

	
	
	public static void uploadFile(String url,File file, Map<String, Object> params) {
		  //还是先创建客户端
        OkHttpClient client = new OkHttpClient();
        //待上传文件
      //  MultipartBody.Part part = MultipartBody.Part .createFormData("upload", file.getName(), RequestBody.create(MultipartBody.FORM, file));
        MultipartBody multipartBody = new MultipartBody.Builder()
                .setType(MultipartBody.FORM)
                .addFormDataPart("username", "lulu")//这个参数在服务器端可以接收到
                .addFormDataPart("upload", file.getName(), RequestBody.create(MultipartBody.FORM, file))
                .build();

        Request request = new Request.Builder()
                .url("http://127.0.0.1:8080/test")
                .post(multipartBody)
                .build();
        Call call = client.newCall(request);

        try {
            Response response = call.execute();
            if (response.isSuccessful()) {
                System.out.println(response.body().string());
            } else {
                System.out.println("访问失败:" + response.code());
            }

        } catch (IOException e) {
            e.printStackTrace();
        }


	}
	
	
}

RespEntity .java

public class RespEntity implements Serializable{

	 private int code;
	 private String msg;
	 private Object data;
	 private long timestamp ;
	
	 public RespEntity() {  }
	 
	 
	 public RespEntity(Object data ) {
		this.code = RespEnums.RESP_HTTP_SUCCESS.getCode();
		this.msg = RespEnums.RESP_HTTP_SUCCESS.getDesc();
		this.data = data;
		this.timestamp = System.currentTimeMillis();
	 }


	public int getCode() {
		return code;
	}
	public void setCode(int code) {
		this.code = code;
	}
	public String getMsg() {
		return msg;
	}
	public void setMsg(String msg) {
		this.msg = msg;
	}
	public Object getData() {
		return this.data;
	}
	public void setData(Object data) {
		this.data = data;
	}
	public long getTimestamp() {
		return timestamp;
	}
	public void setTimestamp(long timestamp) {
		this.timestamp = timestamp;
	}
}

RespEnums .java

public enum RespEnums {
	
	RESP_HTTP_SUCCESS(0,"000","HTTP SUCCESS")
	,RESP_HTTP_ERROR(100,"100","HTTP ERROR")
	
	,RESP_SUCCESS(200,"200","SUCCESS")
	,RESP_VALID_SUCCESS(210,"210","VALID SUCCESS")
	,RESP_VALID_FAIL(211,"211","VALID FAIL")
	,RESP_ERROR(400,"400","ERROR")
	
	,RESP_ERROR_PARAMS_NULL(401,"401","param is null")
	,RESP_ERROR_AUTH_FAIL(402,"402","auth fail")
	,RESP_ERROR_PARAMS_FAIL(403,"403","param fail")
	
	,RESP_OTHER_RESP_CODE(499,"499","OTHER_RESP_CODE")
	,RESP_EXCEPTION(500,"500","EXCEPTION")
	
	
	
	;

	private int code;
    private String sourceCode;
    private String desc;
    
    
    private RespEnums(int code, String sourceCode, String desc){
        this.setCode(code);
        this.setSourceCode(sourceCode);
        this.setDesc(desc);
    }


    /**
     * 根据编码获得基础编码对象
     * @param sourceCode
     * @return
     */
    public static RespEnums getBaseBySourceCode(String sourceCode){
    	RespEnums bc = null;
        for(RespEnums baseCodeEnum : RespEnums.values()){
            if (baseCodeEnum.sourceCode.equals(sourceCode)){
                bc = baseCodeEnum;
                break;
            }
        }
        return  bc;
    }

    /**
     * 根据编码获得基础编码对象
     * @param code
     * @return
     */
    public static RespEnums getBaseByCode(int code){
    	RespEnums bc = null;
        for(RespEnums baseCodeEnum : RespEnums.values()){
            if (baseCodeEnum.code == code ){
                bc = baseCodeEnum;
                break;
            }
        }
        return  bc;
    }


	public int getCode() {
		return code;
	}


	public void setCode(int code) {
		this.code = code;
	}


	public String getSourceCode() {
		return sourceCode;
	}


	public void setSourceCode(String sourceCode) {
		this.sourceCode = sourceCode;
	}


	public String getDesc() {
		return desc;
	}


	public void setDesc(String desc) {
		this.desc = desc;
	}

}

捐助开发者

在兴趣的驱动下,写一个免费的东西，有欣喜，也还有汗水，希望你喜欢我的作品，同时也能支持一下。当然，有钱捧个钱场（支持支付宝和微信以及扣扣群），没钱捧个人场，谢谢各位。

个人主页：http://knight-black-bob.iteye.com/

谢谢您的赞助，我会做的更好！

微信关注我们

原文链接：https://yq.aliyun.com/articles/642956

转载内容版权归作者及来源网站所有！

低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。

2月05日云栖精选夜读：阿里巴巴将入股并获得蚂蚁金服33%股权

北京时间2月1日晚间，阿里巴巴与蚂蚁金服联合宣布，根据2014年双方签署的战略协议，并经阿里巴巴董事会批准，阿里巴巴将通过一家中国子公司入股并获得蚂蚁金服33%的股权。 2014年8月，阿里巴巴发布的招股书中公开披露了这一潜在的交易安排。热点热议阿里巴巴将入股并获得蚂蚁金服33%股权作者：技术小能手发表在：天下网商阿里巴巴公布2018财年Q3业绩：持续强劲增长再次上调全年收入指引，新零售主引擎推动力全面爆发作者：技术小能手发表在：天下网商菲律宾五位部长来阿里巴巴“取经”，原来是为了这个！作者：技术小能手发表在：天下网商知识整理 Java自定义注解和运行时靠反射获取注解作者：小黒糖【云计算的1024种玩法】搭建一个兼容任意面板、一键包的图形化备份环境作者：妙正灰机器学习入门|决策树（二）作者：kissjz 手把手教你如何部署深度学习模型作者：【方向】发表在：翻译小组机器学习基础知识！(ML,DL,SL相关知识整理) 作者：秦玉坤美文回顾盘点机器学习过程中的弯路，带你避坑！作者：秦玉坤 JDK线程池的ThreadFactory 作者：wbf96...

2018-02-05

621

dubbo java 发布订阅（非spring配置）发布 service ApplicationConfig config=new ApplicationConfig("springboot-dubbo-productor"); RegistryConfig reg=new RegistryConfig("localhost:2181"); reg.setProtocol("zookeeper"); ProtocolConfig protocol = new ProtocolConfig(); protocol.setName("dubbo"); protocol.setPort(20880); ServiceConfig<CoreService> service=new ServiceConfig<CoreService>(); service.setApplication(config); service.setRegistry(reg); service.setProtocol(protocol); service.setInterface(Core...

2018-02-05

537

资源下载

更多资源

Mario

马里奥是站在游戏界顶峰的超人气多面角色。马里奥靠吃蘑菇成长，特征是大鼻子、头戴帽子、身穿背带裤，还留着胡子。与他的双胞胎兄弟路易基一起，长年担任任天堂的招牌角色。

腾讯云软件源

为解决软件依赖安装时官方源访问速度慢的问题，腾讯云为一些软件搭建了缓存服务。您可以通过使用腾讯云软件源站来提升依赖包的安装速度。为了方便用户自由搭建服务架构，目前腾讯云软件源站支持公网访问和内网访问。

Nacos

Nacos /nɑ:kəʊs/ 是 Dynamic Naming and Configuration Service 的首字母简称，一个易于构建 AI Agent 应用的动态服务发现、配置管理和AI智能体管理平台。Nacos 致力于帮助您发现、配置和管理微服务及AI智能体应用。Nacos 提供了一组简单易用的特性集，帮助您快速实现动态服务发现、服务配置、服务元数据、流量管理。Nacos 帮助您更敏捷和容易地构建、交付和管理微服务平台。

Rocky Linux

Rocky Linux（中文名：洛基）是由Gregory Kurtzer于2020年12月发起的企业级Linux发行版，作为CentOS稳定版停止维护后与RHEL（Red Hat Enterprise Linux）完全兼容的开源替代方案，由社区拥有并管理，支持x86_64、aarch64等架构。其通过重新编译RHEL源代码提供长期稳定性，采用模块化包装和SELinux安全架构，默认包含GNOME桌面环境及XFS文件系统，支持十年生命周期更新。