Newer
Older
sink / src / main / java / org / flume / alarm / restful / HttpClientUtils.java
zhout on 2 Mar 2022 4 KB first commit
package org.flume.alarm.restful;


import org.apache.commons.httpclient.HttpClient;
import org.apache.commons.httpclient.HttpStatus;
import org.apache.commons.httpclient.methods.GetMethod;
import org.apache.commons.httpclient.methods.PostMethod;
import org.flume.alarm.util.Configure;

import javax.xml.bind.annotation.XmlType;
import java.io.IOException;

public class HttpClientUtils {

    /**
     * ���� post������ʱ���Ӧ�ò����ݴ��ݲ�����ͬ���ز�ͬ���<br />
     */
    public static String post(String uri, String body) {
        HttpClient client = new HttpClient();
        client.setTimeout(30000);
        PostMethod method = new PostMethod(uri);
        // for (Map.Entry<String, String> entry : headers.entrySet()) {
        method.addRequestHeader("Content-type",
                "application/json; charset=utf-8");
        method.addRequestHeader("Accept", "application/json");
        method.addRequestHeader("X-APP-KEY", Configure.getProperty("X-APP-KEY"));
        // method.setEntity(new StringEntity(jsonParam.toString(),
        // Charset.forName("UTF-8")));

        // method.setRequestHeader(entry.getKey(), entry.getValue());
        // method.setRequestHeader("Accept-Charset", "UTF-8");

        // }
        method.setRequestBody(body);
        try {
            int statusCode = client.executeMethod(method);
            if (statusCode == HttpStatus.SC_OK) {
                return new String(method.getResponseBody(), "UTF-8");
                // return method.getResponseBodyAsString();
            }

        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (Exception e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        return null;
    }



    public static String postCase(String uri, String body) {
        HttpClient client = new HttpClient();
        client.setTimeout(6000);
        PostMethod method = new PostMethod(uri);
        method.addRequestHeader("Content-type",
                "application/json; charset=utf-8");
        method.addRequestHeader("Accept", "application/json");
        method.addRequestHeader("X-Timestamp", "1555578802");
        method.addRequestHeader("X-Nonce", "1555578802");
        method.addRequestHeader("X-Signature", "cdfda5b3d6418aeff617d85334dc206cb08a97f4");
        method.addRequestHeader("X-Token", Configure.getProperty("caseToken"));
        method.setRequestBody(body);
        try {
            int statusCode = client.executeMethod(method);
            if (statusCode == HttpStatus.SC_OK) {
                return new String(method.getResponseBody(), "UTF-8");
                // return method.getResponseBodyAsString();
            }
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (Exception e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        return null;
    }


    /**
     * post�ύ��
     */
    public static String postForm(String uri, String body) {
        HttpClient client = new HttpClient();
        client.setTimeout(6000);
        PostMethod method = new PostMethod(uri);
        method.addRequestHeader("Content-Type", "application/x-www-form-urlencoded;charset=utf-8");//
        method.addRequestHeader("Accept", "application/json");
        method.setRequestBody(body);
        try {
            int statusCode = client.executeMethod(method);
            if (statusCode == HttpStatus.SC_OK) {
                return new String(method.getResponseBody(), "UTF-8");
//	    return method.getResponseBodyAsString();
                // return method.getResponseBodyAsString();
            }

        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
            return e.getMessage();
        } catch (Exception e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
            return e.getMessage();
        }
        return null;
    }

    /**
     * ���� get����
     */
    @SuppressWarnings("deprecation")
    public static String get(String uri) {
        HttpClient client = new HttpClient();
        client.setTimeout(6000);
        GetMethod method = new GetMethod(uri);
        try {
            int statusCode = client.executeMethod(method);
            if (statusCode == HttpStatus.SC_OK) {
                return method.getResponseBodyAsString();
            }

        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (Exception e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        return null;
    }


}