赞
踩
/** * 创建HTTPPOST请求 * * @param url * 请求接口路径 * @param headers * 待添加请求头内容 * @param reqJsonStr * 请求的JSON字符串内容 * @return */ public static Result invoke(String url, Map<String, String> headers, String reqJsonStr) throws IOException { // 创建httppost请求 CloseableHttpClient httpclient = HttpClientBuilder.create().build(); Result result = new Result(); try { HttpPost post = new HttpPost(url);// 请求方法地址 RequestConfig requestConfig = RequestConfig.custom() .setConnectTimeout(50000) // 设置连接超时时间 .setConnectionRequestTimeout(10000) // REQUEST超时时间 .setSocketTimeout(50000).build(); // 设置读取超时时间 post.setConfig(requestConfig); StringEntity s = new StringEntity(reqJsonStr, Charset.forName("UTF-8")); s.setContentEncoding("UTF-8"); s.setContentType("application/json; charset=utf-8");// 发送json数据需要设置contentType post.setEntity(s); post.setHeader("Accept", "application/json"); if (headers != null) { for (Map.Entry<String, String> entry : headers.entrySet()) { post.setHeader(entry.getKey(), entry.getValue()); } } HttpResponse response = httpclient.execute(post); // 获取请求结果信息 String content = EntityUtils.toString(response.getEntity()); result.setObj(content); if (response.getStatusLine().getStatusCode() == HttpStatus.SC_OK) {// 200时表示成功 result.setSuccess(true); } else { result.setSuccess(false); result.setMsg("HTTP请求发生错误,错误编码:" + response.getStatusLine().getStatusCode()); } } catch (Exception e) { result.setSuccess(false); result.setMsg("请求异常,请联系管理员!"); e.printStackTrace(); } finally { httpclient.close();// 用完以后释放连接 } return result; }
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。