中文乱码
DataOutputStream dos = new DataOutputStream(httpConn.getOutputStream());
//dos.writeBytes(jsonData); 这个方法会有中文乱码,使用下面的方法解决
dos.write(jsonData.getBytes("utf-8"));
package com.itstudy; import java.io.*; import java.net.HttpURLConnection; import java.net.URL; import java.net.URLConnection; import java.util.Iterator; import java.util.Map; import java.util.Map.Entry; /** * http 工具封装类 */ public class HttpURLConnectionUtils { /** * 发送get请求 * * @param url * @param headers * @return */ public static String get(String url, Map<String, String> headers, Map<String, String> params) { String result = ""; try { if(params!=null) { StringBuilder sbParams = new StringBuilder(); for (Entry<String, String> entry : params.entrySet()) { sbParams.append(entry.getKey()); sbParams.append("="); sbParams.append(entry.getValue()); sbParams.append("&"); } if (sbParams.length() > 0) { sbParams.deleteCharAt(sbParams.lastIndexOf("&")); if (url.indexOf("?") > 0) { url = url + "&" + sbParams.toString(); } else { url = url + "?" + sbParams.toString(); } } } URL restServiceURL = new URL(url); HttpURLConnection httpConnection = (HttpURLConnection) restServiceURL.openConnection(); httpConnection.setRequestMethod("GET"); httpConnection.setRequestProperty("Charsert", "UTF-8"); //设置请求编码 httpConnection.setRequestProperty("Accept", "*/*"); if (headers != null) { for (Entry<String, String> entry : headers.entrySet()) { httpConnection.setRequestProperty(entry.getKey(), entry.getValue().toString()); } } if (httpConnection.getResponseCode() != 200) { throw new RuntimeException("HTTP GET Request Failed with Error code : " + httpConnection.getResponseCode() + " url:" + url); } InputStream inputStream = httpConnection.getInputStream(); result = readAll(inputStream); inputStream.close(); } catch (Exception e) { e.printStackTrace(); } return result; } /** * 发送post form请求 * * @param url * @param headers * @param params * @return */ public static String postForm(String url, Map<String, String> headers, Map<String, String> params) { String result = ""; try { StringBuilder sbParams = new StringBuilder(); for (Entry<String, String> entry : params.entrySet()) { sbParams.append(entry.getKey()); sbParams.append("="); sbParams.append(entry.getValue().toString()); sbParams.append("&"); } if (sbParams.length() > 0) { sbParams.deleteCharAt(sbParams.lastIndexOf("&")); } URL reqUrl = new URL(url); HttpURLConnection httpConn = (HttpURLConnection) reqUrl.openConnection(); //设置参数 httpConn.setDoOutput(true); //需要输出 httpConn.setDoInput(true); //需要输入 httpConn.setUseCaches(false); //不允许缓存 httpConn.setRequestMethod("POST"); //设置POST方式连接 //设置请求属性 httpConn.setRequestProperty("Content-Type", "application/x-www-form-urlencoded"); httpConn.setRequestProperty("Connection", "Keep-Alive");// 维持长连接 httpConn.setRequestProperty("Charset", "UTF-8"); httpConn.setRequestProperty("accept", "*/*"); if (headers != null) { for (Entry<String, String> entry : headers.entrySet()) { httpConn.setRequestProperty(entry.getKey(), entry.getValue().toString()); } } //建立输入流，向指向的URL传入参数 DataOutputStream dos = new DataOutputStream(httpConn.getOutputStream()); //dos.writeBytes(sbParams.toString()); 这个方法会有中文乱码 dos.write(sbParams.toString().getBytes("utf-8")); //解决中文乱码 dos.flush(); dos.close(); if (httpConn.getResponseCode() != 200) { throw new RuntimeException("HTTP POST form Request Failed with Error code : " + httpConn.getResponseCode() + " url:" + url + " form:" + params.toString()); } InputStream inputStream = httpConn.getInputStream(); result = readAll(inputStream); inputStream.close(); } catch (Exception e) { e.printStackTrace(); } return result; } /** * 发送json请求 * * @param url * @param headers * @param jsonData * @return */ public static String postJSON(String url, Map<String, Object> headers, String jsonData) { String result = ""; try { URL reqUrl = new URL(url); HttpURLConnection httpConn = (HttpURLConnection) reqUrl.openConnection(); //设置参数 httpConn.setDoOutput(true); //需要输出 httpConn.setDoInput(true); //需要输入 httpConn.setUseCaches(false); //不允许缓存 httpConn.setRequestMethod("POST"); //设置POST方式连接 //设置请求属性 httpConn.setRequestProperty("Content-Type", "application/json"); httpConn.setRequestProperty("Connection", "Keep-Alive");// 维持长连接 httpConn.setRequestProperty("Charset", "UTF-8"); httpConn.setRequestProperty("accept", "*/*"); if (headers != null) { for (Entry<String, Object> entry : headers.entrySet()) { httpConn.setRequestProperty(entry.getKey(), entry.getValue().toString()); } } //建立输入流，向指向的URL传入参数 DataOutputStream dos = new DataOutputStream(httpConn.getOutputStream()); //dos.writeBytes(jsonData); 这个方法会有中文乱码,使用下面的方法解决 dos.write(jsonData.getBytes("utf-8")); dos.flush(); dos.close(); if (httpConn.getResponseCode() != 200) { throw new RuntimeException("HTTP POST json Request Failed with Error code : " + httpConn.getResponseCode() + " url:" + url + " json:" + jsonData); } InputStream inputStream = httpConn.getInputStream(); result = readAll(inputStream); inputStream.close(); } catch (Exception e) { e.printStackTrace(); } return result; } /** * 读取字节流 * * @param inputStream * @return */ private static String readAll(InputStream inputStream) { StringBuilder builder = new StringBuilder(); try { byte[] b = new byte[1024]; int length = -1; while ((length = inputStream.read(b)) != -1) { builder.append(new String(b, 0, length,"UTF-8")); } } catch (Exception ex) { ex.printStackTrace(); } return builder.toString(); } /** * formupload方式提交数据 * * @param urlPath * @param textMap * @param fileMap * @return */ public static String formUpload(String urlPath, Map<String, String> textMap, Map<String, String> fileMap) { String res = ""; HttpURLConnection conn = null; String BOUNDARY = "----lwm12345boundary"; //boundary就是request头和上传文件内容的分隔符 try { URL url = new URL(urlPath); conn = (HttpURLConnection) url.openConnection(); conn.setConnectTimeout(5000); conn.setReadTimeout(30000); conn.setDoOutput(true); conn.setDoInput(true); conn.setUseCaches(false); conn.setRequestMethod("POST"); conn.setRequestProperty("Connection", "Keep-Alive"); conn.setRequestProperty("User-Agent", "Mozilla/5.0 (Windows; U; Windows NT 6.1; zh-CN; rv:1.9.2.6)"); conn.setRequestProperty("Content-Type", "multipart/form-data; boundary=" + BOUNDARY); OutputStream out = new DataOutputStream(conn.getOutputStream()); // text if (textMap != null) { StringBuffer strBuf = new StringBuffer(); Iterator<Entry<String, String>> iter = textMap.entrySet().iterator(); while (iter.hasNext()) { Entry<String, String> entry = iter.next(); String inputName = (String) entry.getKey(); String inputValue = (String) entry.getValue(); if (inputValue == null) { continue; } strBuf.append(" ").append("--").append(BOUNDARY).append(" "); strBuf.append("Content-Disposition: form-data; name="" + inputName + "" "); strBuf.append(inputValue); } out.write(strBuf.toString().getBytes("utf-8")); } // file if (fileMap != null) { Iterator<Entry<String, String>> iter = fileMap.entrySet().iterator(); while (iter.hasNext()) { Entry<String, String> entry = iter.next(); String inputName = (String) entry.getKey(); String inputValue = (String) entry.getValue(); if (inputValue == null) { continue; } File file = new File(inputValue); String filename = file.getName(); String contentType = MimeTypeUtils.getType(filename); StringBuffer strBuf = new StringBuffer(); strBuf.append(" ").append("--").append(BOUNDARY).append(" "); strBuf.append("Content-Disposition: form-data; name="" + inputName + ""; filename="" + filename + "" "); strBuf.append("Content-Type:" + contentType + " "); out.write(strBuf.toString().getBytes("utf-8")); DataInputStream in = new DataInputStream(new FileInputStream(file)); int bytes = 0; byte[] bufferOut = new byte[1024]; while ((bytes = in.read(bufferOut)) != -1) { out.write(bufferOut, 0, bytes); } in.close(); } } byte[] endData = (" --" + BOUNDARY + "-- ").getBytes(); out.write(endData); out.flush(); out.close(); // 读取返回数据 StringBuffer strBuf = new StringBuffer(); BufferedReader reader = new BufferedReader(new InputStreamReader(conn.getInputStream())); String line = null; while ((line = reader.readLine()) != null) { strBuf.append(line).append(" "); } res = strBuf.toString(); reader.close(); reader = null; } catch (Exception e) { e.printStackTrace(); } finally { if (conn != null) { conn.disconnect(); conn = null; } } return res; } /** * 发送下载文件请求 * * @param urlPath * @param downloadDir * @return */ public static File downloadFile(String urlPath, String downloadDir) { File file = null; try { // 统一资源 URL url = new URL(urlPath); // 连接类的父类，抽象类 URLConnection urlConnection = url.openConnection(); // http的连接类 HttpURLConnection httpURLConnection = (HttpURLConnection) urlConnection; // 设定请求的方法，默认是GET httpURLConnection.setRequestMethod("POST"); // 设置字符编码 httpURLConnection.setRequestProperty("Charset", "UTF-8"); // 打开到此 URL 引用的资源的通信链接（如果尚未建立这样的连接）。 httpURLConnection.connect(); // 文件大小 int fileLength = httpURLConnection.getContentLength(); // 文件名 String filePathUrl = httpURLConnection.getURL().getFile(); String fileFullName = filePathUrl.substring(filePathUrl.lastIndexOf(File.separatorChar) + 1); System.out.println("file length---->" + fileLength); URLConnection con = url.openConnection(); BufferedInputStream bin = new BufferedInputStream(httpURLConnection.getInputStream()); String path = downloadDir + File.separatorChar + fileFullName; file = new File(path); if (!file.getParentFile().exists()) { file.getParentFile().mkdirs(); } OutputStream out = new FileOutputStream(file); int size = 0; int len = 0; byte[] buf = new byte[1024]; while ((size = bin.read(buf)) != -1) { len += size; out.write(buf, 0, size); // 打印下载百分比 // System.out.println("下载了-------> " + len * 100 / fileLength + // "% "); } bin.close(); out.close(); } catch (Exception e) { e.printStackTrace(); } finally { return file; } } /** * formupload方式提交转发文件流 * * @param urlPath * @param textMap * @param fileMap * @return */ public static String formUpload2(String urlPath, Map<String, String> textMap, Map<String, InputStream> fileMap) { String res = ""; HttpURLConnection conn = null; String BOUNDARY = "----lwm12345boundary"; //boundary就是request头和上传文件内容的分隔符 try { URL url = new URL(urlPath); conn = (HttpURLConnection) url.openConnection(); conn.setConnectTimeout(5000); conn.setReadTimeout(30000); conn.setDoOutput(true); conn.setDoInput(true); conn.setUseCaches(false); conn.setRequestMethod("POST"); conn.setRequestProperty("Connection", "Keep-Alive"); conn.setRequestProperty("User-Agent", "Mozilla/5.0 (Windows; U; Windows NT 6.1; zh-CN; rv:1.9.2.6)"); conn.setRequestProperty("Content-Type", "multipart/form-data; boundary=" + BOUNDARY); OutputStream out = new DataOutputStream(conn.getOutputStream()); // text if (textMap != null) { StringBuffer strBuf = new StringBuffer(); Iterator<Entry<String, String>> iter = textMap.entrySet().iterator(); while (iter.hasNext()) { Entry<String, String> entry = iter.next(); String inputName = (String) entry.getKey(); String inputValue = (String) entry.getValue(); if (inputValue == null) { continue; } strBuf.append(" ").append("--").append(BOUNDARY).append(" "); strBuf.append("Content-Disposition: form-data; name="" + inputName + "" "); strBuf.append(inputValue); } out.write(strBuf.toString().getBytes("utf-8")); } // file if (fileMap != null) { Iterator<Entry<String, InputStream>> iter = fileMap.entrySet().iterator(); while (iter.hasNext()) { Entry<String, InputStream> entry = iter.next(); String inputName = (String) entry.getKey(); InputStream fileStream = entry.getValue(); String contentType = MimeTypeUtils.getType(inputName); StringBuffer strBuf = new StringBuffer(); strBuf.append(" ").append("--").append(BOUNDARY).append(" "); strBuf.append("Content-Disposition: form-data; name="" + inputName + ""; filename="" + inputName + "" "); strBuf.append("Content-Type:" + contentType + " "); out.write(strBuf.toString().getBytes("utf-8")); DataInputStream in = new DataInputStream(fileStream); int bytes = 0; byte[] bufferOut = new byte[1024]; while ((bytes = in.read(bufferOut)) != -1) { out.write(bufferOut, 0, bytes); } in.close(); } } byte[] endData = (" --" + BOUNDARY + "-- ").getBytes(); out.write(endData); out.flush(); out.close(); // 读取返回数据 StringBuffer strBuf = new StringBuffer(); BufferedReader reader = new BufferedReader(new InputStreamReader(conn.getInputStream())); String line = null; while ((line = reader.readLine()) != null) { strBuf.append(line).append(" "); } res = strBuf.toString(); reader.close(); reader = null; } catch (Exception e) { e.printStackTrace(); } finally { if (conn != null) { conn.disconnect(); conn = null; } } return res; } }