Java HTTPリクエストクラスパッケージ


Java httpリクエストクラスパッケージは、もちろんapacheのhttpclientも参照できますが、パッケージの目的はjarパッケージの参照を減らすことです.
package com.wiker;

import java.io.BufferedReader;
import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.HttpURLConnection;
import java.net.InetAddress;
import java.net.Socket;
import java.net.URL;
import java.net.URLConnection;
import java.net.URLEncoder;
import java.nio.charset.Charset;
import java.util.HashMap;
import java.util.Map;
import java.util.Map.Entry;
import java.util.Set;
import java.util.Vector;

/**
 * @author Wiker Yong Email:[email protected]
 * @date 2013-11-8   7:22:43
 * @version 1.0-SNAPSHOT
 */
public class HttpUtils {

    private String defaultContentEncoding;

    public HttpUtils() {
        this.defaultContentEncoding = Charset.defaultCharset().name();
    }

    /**
     *   GET  
     * 
     * @param urlString  URL  
     * @return     
     * @throws IOException
     */
    public HttpRespons sendGet(String urlString) throws IOException {
        return this.send(urlString, "GET", null, null);
    }

    /**
     *   GET  
     * 
     * @param urlString  URL  
     * @param params     
     * @return     
     * @throws IOException
     */
    public HttpRespons sendGet(String urlString, Map params) throws IOException {
        return this.send(urlString, "GET", params, null);
    }

    /**
     *   GET  
     * 
     * @param urlString URL  
     * @param params     
     * @param propertys     
     * @return     
     * @throws IOException
     */
    public HttpRespons sendGet(String urlString, Map params, Map propertys)
            throws IOException {
        return this.send(urlString, "GET", params, propertys);
    }

    /**
     *   POST  
     * 
     * @param urlString URL  
     * @return     
     * @throws IOException
     */
    public HttpRespons sendPost(String urlString) throws IOException {
        return this.send(urlString, "POST", null, null);
    }

    /**
     *   POST  
     * 
     * @param urlString URL  
     * @param params     
     * @return     
     * @throws IOException
     */
    public HttpRespons sendPost(String urlString, Map params) throws IOException {
        return this.send(urlString, "POST", params, null);
    }

    /**
     *   POST  
     * 
     * @param urlString URL  
     * @param params     
     * @param propertys     
     * @return     
     * @throws IOException
     */
    public HttpRespons sendPost(String urlString, Map params, Map propertys)
            throws IOException {
        return this.send(urlString, "POST", params, propertys);
    }

    /**
     *   HTTP  
     * 
     * @param urlString   
     * @param method  get/post
     * @param parameters               
     * @param propertys                 
     * @return     
     * @throws IOException
     */
    private HttpRespons send(String urlString, String method, Map parameters,
            Map propertys) throws IOException {
        HttpURLConnection urlConnection = null;

        if (method.equalsIgnoreCase("GET") && parameters != null) {
            StringBuffer param = new StringBuffer();
            int i = 0;
            for (String key : parameters.keySet()) {
                if (i == 0)
                    param.append("?");
                else
                    param.append("&");
                param.append(key).append("=").append(parameters.get(key));
                i++;
            }
            urlString += param;
        }

        URL url = new URL(urlString);
        urlConnection = (HttpURLConnection) url.openConnection();
        urlConnection.setRequestMethod(method);
        urlConnection.setDoOutput(true);
        urlConnection.setDoInput(true);
        urlConnection.setUseCaches(false);

        if (propertys != null)
            for (String key : propertys.keySet()) {
                urlConnection.addRequestProperty(key, propertys.get(key));
            }

        if (method.equalsIgnoreCase("POST") && parameters != null) {
            StringBuffer param = new StringBuffer();
            for (String key : parameters.keySet()) {
                param.append("&");
                param.append(key).append("=").append(parameters.get(key));
            }
            urlConnection.getOutputStream().write(param.toString().getBytes());
            urlConnection.getOutputStream().flush();
            urlConnection.getOutputStream().close();
        }
        return this.makeContent(urlString, urlConnection);
    }

    /**
     *       
     * 
     * @param urlConnection
     * @return     
     * @throws IOException
     */
    private HttpRespons makeContent(String urlString, HttpURLConnection urlConnection) throws IOException {
        HttpRespons httpResponser = new HttpRespons();
        try {
            InputStream in = urlConnection.getInputStream();
            BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(in));
            httpResponser.contentCollection = new Vector();
            StringBuffer temp = new StringBuffer();
            String line = bufferedReader.readLine();
            while (line != null) {
                httpResponser.contentCollection.add(line);
                temp.append(line).append("\r
"); line = bufferedReader.readLine(); } bufferedReader.close(); String ecod = urlConnection.getContentEncoding(); if (ecod == null) ecod = this.defaultContentEncoding; httpResponser.urlString = urlString; httpResponser.defaultPort = urlConnection.getURL().getDefaultPort(); httpResponser.file = urlConnection.getURL().getFile(); httpResponser.host = urlConnection.getURL().getHost(); httpResponser.path = urlConnection.getURL().getPath(); httpResponser.port = urlConnection.getURL().getPort(); httpResponser.protocol = urlConnection.getURL().getProtocol(); httpResponser.query = urlConnection.getURL().getQuery(); httpResponser.ref = urlConnection.getURL().getRef(); httpResponser.userInfo = urlConnection.getURL().getUserInfo(); httpResponser.content = new String(temp.toString().getBytes(), ecod); httpResponser.contentEncoding = ecod; httpResponser.code = urlConnection.getResponseCode(); httpResponser.message = urlConnection.getResponseMessage(); httpResponser.contentType = urlConnection.getContentType(); httpResponser.method = urlConnection.getRequestMethod(); httpResponser.connectTimeout = urlConnection.getConnectTimeout(); httpResponser.readTimeout = urlConnection.getReadTimeout(); return httpResponser; } catch (IOException e) { throw e; } finally { if (urlConnection != null) urlConnection.disconnect(); } } /** * */ public String getDefaultContentEncoding() { return this.defaultContentEncoding; } /** * GET * @param url * @param params * @param headers * @return * @throws Exception */ public static URLConnection sendGetRequest(String url, Map params, Map headers) throws Exception { StringBuilder buf = new StringBuilder(url); Set> entrys = null; // GET , URL if (params != null && !params.isEmpty()) { buf.append("?"); entrys = params.entrySet(); for (Map.Entry entry : entrys) { buf.append(entry.getKey()).append("=") .append(URLEncoder.encode(entry.getValue(), "UTF-8")) .append("&"); } buf.deleteCharAt(buf.length() - 1); } URL url1 = new URL(buf.toString()); HttpURLConnection conn = (HttpURLConnection) url1.openConnection(); conn.setRequestMethod("GET"); // if (headers != null && !headers.isEmpty()) { entrys = headers.entrySet(); for (Map.Entry entry : entrys) { conn.setRequestProperty(entry.getKey(), entry.getValue()); } } conn.getResponseCode(); return conn; } /** * POST * @param url * @param params * @param headers * @return * @throws Exception */ public static URLConnection sendPostRequest(String url, Map params, Map headers) throws Exception { StringBuilder buf = new StringBuilder(); Set> entrys = null; // , HTTP , name=aaa&age=10 if (params != null && !params.isEmpty()) { entrys = params.entrySet(); for (Map.Entry entry : entrys) { buf.append(entry.getKey()).append("=") .append(URLEncoder.encode(entry.getValue(), "UTF-8")) .append("&"); } buf.deleteCharAt(buf.length() - 1); } URL url1 = new URL(url); HttpURLConnection conn = (HttpURLConnection) url1.openConnection(); conn.setRequestMethod("POST"); conn.setDoOutput(true); OutputStream out = conn.getOutputStream(); out.write(buf.toString().getBytes("UTF-8")); if (headers != null && !headers.isEmpty()) { entrys = headers.entrySet(); for (Map.Entry entry : entrys) { conn.setRequestProperty(entry.getKey(), entry.getValue()); } } conn.getResponseCode(); // return conn; } /** * HTTP , : *
* @param path ( : localhost 127.0.0.1 , , http://www.itcast.cn http://192.168.1.10:8080 ) * @param params key ,value * @param file */ public static boolean uploadFiles(String path, Map params, FormFile[] files) throws Exception{ final String BOUNDARY = "---------------------------7da2137580612"; // final String endline = "--" + BOUNDARY + "--\r
";// int fileDataLength = 0; if(files!=null&&files.length!=0){ for(FormFile uploadFile : files){// StringBuilder fileExplain = new StringBuilder(); fileExplain.append("--"); fileExplain.append(BOUNDARY); fileExplain.append("\r
"); fileExplain.append("Content-Disposition: form-data;name=\""+ uploadFile.getParameterName()+"\";filename=\""+ uploadFile.getFilname() + "\"\r
"); fileExplain.append("Content-Type: "+ uploadFile.getContentType()+"\r
\r
"); fileExplain.append("\r
"); fileDataLength += fileExplain.length(); if(uploadFile.getInStream()!=null){ fileDataLength += uploadFile.getFile().length(); }else{ fileDataLength += uploadFile.getData().length; } } } StringBuilder textEntity = new StringBuilder(); if(params!=null&&!params.isEmpty()){ for (Map.Entry entry : params.entrySet()) {// textEntity.append("--"); textEntity.append(BOUNDARY); textEntity.append("\r
"); textEntity.append("Content-Disposition: form-data; name=\""+ entry.getKey() + "\"\r
\r
"); textEntity.append(entry.getValue()); textEntity.append("\r
"); } } // int dataLength = textEntity.toString().getBytes().length + fileDataLength + endline.getBytes().length; URL url = new URL(path); int port = url.getPort()==-1 ? 80 : url.getPort(); Socket socket = new Socket(InetAddress.getByName(url.getHost()), port); OutputStream outStream = socket.getOutputStream(); // HTTP String requestmethod = "POST "+ url.getPath()+" HTTP/1.1\r
"; outStream.write(requestmethod.getBytes()); String accept = "Accept: image/gif, image/jpeg, image/pjpeg, image/pjpeg, application/x-shockwave-flash, application/xaml+xml, application/vnd.ms-xpsdocument, application/x-ms-xbap, application/x-ms-application, application/vnd.ms-excel, application/vnd.ms-powerpoint, application/msword, */*\r
"; outStream.write(accept.getBytes()); String language = "Accept-Language: zh-CN\r
"; outStream.write(language.getBytes()); String contenttype = "Content-Type: multipart/form-data; boundary="+ BOUNDARY+ "\r
"; outStream.write(contenttype.getBytes()); String contentlength = "Content-Length: "+ dataLength + "\r
"; outStream.write(contentlength.getBytes()); String alive = "Connection: Keep-Alive\r
"; outStream.write(alive.getBytes()); String host = "Host: "+ url.getHost() +":"+ port +"\r
"; outStream.write(host.getBytes()); // HTTP HTTP outStream.write("\r
".getBytes()); // outStream.write(textEntity.toString().getBytes()); // if(files!=null&&files.length!=0){ for(FormFile uploadFile : files){ StringBuilder fileEntity = new StringBuilder(); fileEntity.append("--"); fileEntity.append(BOUNDARY); fileEntity.append("\r
"); fileEntity.append("Content-Disposition: form-data;name=\""+ uploadFile.getParameterName()+"\";filename=\""+ uploadFile.getFilname() + "\"\r
"); fileEntity.append("Content-Type: "+ uploadFile.getContentType()+"\r
\r
"); outStream.write(fileEntity.toString().getBytes()); if(uploadFile.getInStream()!=null){ byte[] buffer = new byte[1024]; int len = 0; while((len = uploadFile.getInStream().read(buffer, 0, 1024))!=-1){ outStream.write(buffer, 0, len); } uploadFile.getInStream().close(); }else{ outStream.write(uploadFile.getData(), 0, uploadFile.getData().length); } outStream.write("\r
".getBytes()); } } // , outStream.write(endline.getBytes()); BufferedReader reader = new BufferedReader(new InputStreamReader(socket.getInputStream())); if(reader.readLine().indexOf("200")==-1){// web , 200, 200, return false; } outStream.flush(); outStream.close(); reader.close(); socket.close(); return true; } /** * * @param path ( : localhost 127.0.0.1 , , http://www.itcast.cn http://192.168.1.10:8080 ) * @param params key ,value * @param file */ public static boolean uploadFile(String path, Map params, FormFile file) throws Exception{ return uploadFiles(path, params, new FormFile[]{file}); } /** * * @param inStream * @return * @throws Exception */ public static byte[] read2Byte(InputStream inStream)throws Exception{ ByteArrayOutputStream outSteam = new ByteArrayOutputStream(); byte[] buffer = new byte[1024]; int len = 0; while( (len = inStream.read(buffer)) !=-1 ){ outSteam.write(buffer, 0, len); } outSteam.close(); inStream.close(); return outSteam.toByteArray(); } /** * * @param inStream * @return * @throws Exception */ public static String read2String(InputStream inStream)throws Exception{ ByteArrayOutputStream outSteam = new ByteArrayOutputStream(); byte[] buffer = new byte[1024]; int len = 0; while( (len = inStream.read(buffer)) !=-1 ){ outSteam.write(buffer, 0, len); } outSteam.close(); inStream.close(); return new String(outSteam.toByteArray(),"UTF-8"); } /** * xml * @param path * @param xml xml * @param encoding * @return * @throws Exception */ public static byte[] postXml(String path, String xml, String encoding) throws Exception{ byte[] data = xml.getBytes(encoding); URL url = new URL(path); HttpURLConnection conn = (HttpURLConnection)url.openConnection(); conn.setRequestMethod("POST"); conn.setDoOutput(true); conn.setRequestProperty("Content-Type", "text/xml; charset="+ encoding); conn.setRequestProperty("Content-Length", String.valueOf(data.length)); conn.setConnectTimeout(5 * 1000); OutputStream outStream = conn.getOutputStream(); outStream.write(data); outStream.flush(); outStream.close(); if(conn.getResponseCode()==200){ return read2Byte(conn.getInputStream()); } return null; } // public static void main(String args[]) throws Exception { Map params = new HashMap(); params.put("name", "xiazdong"); params.put("age", "10"); HttpURLConnection conn = (HttpURLConnection) sendGetRequest( "http://192.168.0.103:8080/Server/PrintServlet", params, null); int code = conn.getResponseCode(); InputStream in = conn.getInputStream(); byte[]data = read2Byte(in); } /** * */ public void setDefaultContentEncoding(String defaultContentEncoding) { this.defaultContentEncoding = defaultContentEncoding; } }

参照するファイルFormFile.javaは次のとおりです.
package com.wiker;

import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.InputStream;

/**
 *     
 */
public class FormFile {
    /*         */
    private byte[] data;
    private InputStream inStream;
    private File file;
    /*      */
    private String filname;
    /*       */
    private String parameterName;
    /*      */
    private String contentType = "application/octet-stream";
    
    /**
     *           
     * @param filname
     * @param data
     * @param parameterName
     * @param contentType
     */
    public FormFile(String filname, byte[] data, String parameterName, String contentType) {
        this.data = data;
        this.filname = filname;
        this.parameterName = parameterName;
        if(contentType!=null) this.contentType = contentType;
    }
    /**
     *           
     * @param filname
     * @param file
     * @param parameterName
     * @param contentType
     */
    public FormFile(String filname, File file, String parameterName, String contentType) {
        this.filname = filname;
        this.parameterName = parameterName;
        this.file = file;
        try {
            this.inStream = new FileInputStream(file);
        } catch (FileNotFoundException e) {
            e.printStackTrace();
        }
        if(contentType!=null) this.contentType = contentType;
    }
    
    public File getFile() {
        return file;
    }

    public InputStream getInStream() {
        return inStream;
    }

    public byte[] getData() {
        return data;
    }

    public String getFilname() {
        return filname;
    }

    public void setFilname(String filname) {
        this.filname = filname;
    }

    public String getParameterName() {
        return parameterName;
    }

    public void setParameterName(String parameterName) {
        this.parameterName = parameterName;
    }

    public String getContentType() {
        return contentType;
    }

    public void setContentType(String contentType) {
        this.contentType = contentType;
    }
    
}