オリジナルjava書き込みのシミュレーションHTTPリクエストHttpsMethod
11753 ワード
オリジナルjava書き込みのシミュレーションHTTPリクエスト
package com.fc.utility;
import java.awt.image.BufferedImage;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.ByteArrayOutputStream;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.HttpURLConnection;
import java.net.MalformedURLException;
import java.net.URL;
import java.nio.CharBuffer;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Enumeration;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.UUID;
import javax.imageio.ImageIO;
import javax.imageio.ImageReader;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpSession;
import org.apache.commons.lang.ArrayUtils;
import org.apache.commons.lang.StringUtils;
import org.b3log.latke.Keys;
import org.b3log.latke.model.User;
import org.b3log.latke.util.CollectionUtils;
import org.b3log.latke.util.Sessions;
import org.dom4j.Document;
import org.dom4j.Element;
import org.dom4j.io.SAXReader;
import org.json.JSONException;
import org.json.JSONObject;
/**
* the https method
*
* */
public class HttpsMethod {
/**
* post
*
* @param url
* String URL
* @param param
* String
* @param repType
*
* @return String
* */
public static String postRequest(String url, String param, String repType) {
PrintWriter out = null;
BufferedReader in = null;
String result = "";
try {
/**
*
*/
URL urlObj = new URL(url);
HttpURLConnection con = (HttpURLConnection) urlObj.openConnection();
/**
*
*/
con.setRequestMethod("POST"); // Post ， get
con.addRequestProperty("Accept-Language", "zh-cn");
con.addRequestProperty("Content-type", repType);
con.addRequestProperty(
"User-Agent",
"Mozilla/4.0 (compatible; MSIE 8.0; Windows NT 5.1; Trident/4.0; .NET CLR 2.0.50727)");
con.setDoInput(true);
con.setDoOutput(true);
con.setUseCaches(false); // post
//
con.setRequestProperty("Connection", "Keep-Alive");
con.setRequestProperty("Charset", "UTF-8");
// URLConnection
out = new PrintWriter(con.getOutputStream());
//
out.print(param);
// flush
out.flush();
// BufferedReader URL
in = new BufferedReader(new InputStreamReader(con.getInputStream()));
String line;
while ((line = in.readLine()) != null) {
result += line;
}
} catch (Exception e) {
System.out.println(" POST ！" + e);
e.printStackTrace();
}
// finally 、
finally {
try {
if (out != null) {
out.close();
}
if (in != null) {
in.close();
}
} catch (IOException ex) {
ex.printStackTrace();
}
}
return result;
}
/**
* get
*
* @param url
* String URL
* @param param
* String
* @param repType
*
* @return String
* */
public static byte[] getRequest(String url, String repType) {
String result = "";
byte[] resByt = null;
try {
URL urlObj = new URL(url);
HttpURLConnection conn = (HttpURLConnection) urlObj
.openConnection();
//
conn.setDoInput(true);
conn.setDoOutput(true);
conn.setConnectTimeout(25000);
// -- ,
conn.setReadTimeout(25000);
conn.setRequestMethod("GET");
conn.addRequestProperty("Accept-Language", "zh-cn");
conn.addRequestProperty("Content-type", repType);
conn.addRequestProperty(
"User-Agent",
"Mozilla/4.0 (compatible; MSIE 8.0; Windows NT 5.1; Trident/4.0; .NET CLR 2.0.50727)");
conn.connect();
PrintWriter out = new PrintWriter(new OutputStreamWriter(
conn.getOutputStream(), "UTF-8"), true);
if ("image/jpeg".equals(repType)) {
ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
BufferedImage bufImg = ImageIO.read(conn.getInputStream());
ImageIO.write(bufImg, "jpg", outputStream);
resByt = outputStream.toByteArray();
outputStream.close();
} else {
// ， Reader
System.out.println("set utf-8 decode...");
BufferedReader reader = new BufferedReader(
new InputStreamReader(conn.getInputStream(), "utf-8"));
System.out.println("=============================");
System.out.println("Contents of get request");
System.out.println("=============================");
String lines = null;
while ((lines = reader.readLine()) != null) {
System.out.println(lines);
result += lines;
result += "\r";
}
resByt = result.getBytes();
reader.close();
}
out.print(resByt);
out.flush();
out.close();
//
conn.disconnect();
System.out.println("=============================");
System.out.println("Contents of get request ends");
System.out.println("=============================");
} catch (MalformedURLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return resByt;
}
public static String fileUploadReuest(String url, String filePath,
String repType) {
String result = "";
File file = new File(filePath);
try {
/**
*
*/
URL urlObj = new URL(url);
HttpURLConnection con = (HttpURLConnection) urlObj.openConnection();
/**
*
*/
con.setRequestMethod("POST"); // Post ， get
con.setDoInput(true);
con.setDoOutput(true);
con.setUseCaches(false); // post
//
con.setRequestProperty("Connection", "Keep-Alive");
con.setRequestProperty("Charset", "UTF-8");
//
String BOUNDARY = "----------" + System.currentTimeMillis();
con.setRequestProperty("Content-Type",
"multipart/form-data; boundary=" + BOUNDARY);
//
// ：
StringBuilder sb = new StringBuilder();
sb.append("--"); // ////////
sb.append(BOUNDARY);
sb.append("\r
");
sb.append("Content-Disposition: form-data;name=\"file\";filename=\""
+ file.getName() + "\"\r
");
sb.append("Content-Type:application/octet-stream\r
\r
");
byte[] head = sb.toString().getBytes("utf-8");
//
OutputStream out = new DataOutputStream(con.getOutputStream());
out.write(head);
//
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[] foot = ("\r
--" + BOUNDARY + "--\r
").getBytes("utf-8");//
out.write(foot);
out.flush();
out.close();
/**
* ， ,
*/
// return con.getResponseCode();
/**
*
*/
// BufferedReader URL
BufferedReader reader = new BufferedReader(new InputStreamReader(
con.getInputStream()));
String line = null;
while ((line = reader.readLine()) != null) {
result += line;
}
} catch (MalformedURLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (NullPointerException e) {
// TODO: handle exception
}
return result;
}
@SuppressWarnings("unchecked")
public static Map<String, String> parseXml(HttpServletRequest req) {
Map<String, String> map = new HashMap<String, String>();
InputStream inputStream = null;
try {
inputStream = req.getInputStream();
SAXReader reader = new SAXReader();
Document document;
document = reader.read(inputStream);
Element root = document.getRootElement();
List<Element> elementList = root.elements();
for (Element e : elementList)
map.put(e.getName(), e.getText());
} catch (Exception e1) {
e1.printStackTrace();
} finally {
if (inputStream != null) {
try {
inputStream.close();
} catch (IOException e) {
}
}
}
return map;
}
public static String formatRequestToKey(HttpServletRequest req,
String templateName) {
Object[] keys = null;
Enumeration e = req.getAttributeNames();
List<String> vs = new ArrayList<String>();
while (e.hasMoreElements()) {
String key = e.nextElement().toString();
if (!StringUtils.isEmpty(key)) {
vs.add(key);
}
}
keys = vs.toArray();
Arrays.sort(keys);
String url = req.getRequestURL().toString();
String uuid = "";
for (int j = 0; j < keys.length; j++) {
uuid += keys[j] + ":" + req.getParameter(keys[j].toString()) + "-";
}
String userUUID = "";
HttpSession session = Sessions.getSession(req);
if (session != null) {
Object user = session.getAttribute(User.USER);
if (user != null) {
try {
userUUID = ((JSONObject) user).getString(Keys.OBJECT_ID);
} catch (JSONException e1) {
}
}
}
uuid = url + uuid + userUUID;
if (!StringUtils.isEmpty(templateName)) {
uuid += "/" + templateName;
}
return uuid;
}
}