httpclient

package com.fx.util;

import java.util.Vector;

public class HttpResponser {

	String urlString;// URL地址串

	int defaultPort;

	String file;

	String host;

	String path;

	int port;

	String protocol;

	String query;

	String ref;

	String userInfo;

	String contentEncoding;

	String contentString;// 以字符串形式保存 内容

	String contentType;

	int code;

	String message;

	String method;// 方法

	int connectTimeout;

	int readTimeout;

	Vector<String> contentCollection;// 以集合形式保存内容，集合中保存行

	public String getContentString() {
		return contentString;
	}

	public String getContentType() {
		return contentType;
	}

	public int getCode() {
		return code;
	}

	public String getMessage() {
		return message;
	}

	public Vector<String> getContentCollection() {
		return contentCollection;
	}

	public String getContentEncoding() {
		return contentEncoding;
	}

	public String getMethod() {
		return method;
	}

	public int getConnectTimeout() {
		return connectTimeout;
	}

	public int getReadTimeout() {
		return readTimeout;
	}

	public String getUrlString() {
		return urlString;
	}

	public int getDefaultPort() {
		return defaultPort;
	}

	public String getFile() {
		return file;
	}

	public String getHost() {
		return host;
	}

	public String getPath() {
		return path;
	}

	public int getPort() {
		return port;
	}

	public String getProtocol() {
		return protocol;
	}

	public String getQuery() {
		return query;
	}

	public String getRef() {
		return ref;
	}

	public String getUserInfo() {
		return userInfo;
	}

}

package com.fx.util;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.net.HttpURLConnection;
import java.net.URL;
import java.nio.charset.Charset;
import java.util.Map;
import java.util.Vector;

/**
 * HTTP请求对象
 * 
 * @author YaoMing
 */
public class HttpRequester {

	private String defaultContentEncoding;

	public HttpRequester() {
		// 得到系统默认的字符编码
		this.defaultContentEncoding = Charset.defaultCharset().name();
	}

	public HttpResponser sendGet(String urlString) throws IOException {
		return this.send(urlString, "GET", null, null);
	}

	public HttpResponser sendGet(String urlString, Map<String, String> params)
			throws IOException {
		return this.send(urlString, "GET", params, null);
	}

	public HttpResponser sendGet(String urlString, Map<String, String> params,
			Map<String, String> propertys) throws IOException {
		return this.send(urlString, "GET", params, propertys);
	}

	public HttpResponser sendPost(String urlString) throws IOException {
		return this.send(urlString, "POST", null, null);
	}

	public HttpResponser sendPost(String urlString, Map<String, String> params)
			throws IOException {
		return this.send(urlString, "POST", params, null);
	}

	public HttpResponser sendPost(String urlString, Map<String, String> params,
			Map<String, String> propertys) throws IOException {
		return this.send(urlString, "POST", params, propertys);
	}

	/**
	 * 
	 * @param urlString
	 *            地址 应该包含?
	 * @param method
	 *            提交方式
	 * @param parameters
	 *            参数 传入的参数应该是一个已经通过URL编码以后的参数
	 * @param propertys
	 *            请求属性 键值对 例如 key=sun.net.client.defaultConnectTimeout
	 *            value=5000 key=sun.net.client.defaultReadTimeout value=5000
	 * @return
	 * @throws IOException
	 */
	private HttpResponser send(String urlString, String method,
			Map<String, String> parameters, Map<String, String> propertys)
			throws IOException {
		HttpURLConnection urlConnection = null;
		URL url = null;
		StringBuffer param = new StringBuffer();
		if (parameters != null) {
			for (String key : parameters.keySet()) {
				param.append(key).append("=").append(parameters.get(key));
				param.append("&");
			}
			if (param.length() > 0) {
				param = param.deleteCharAt(param.length() - 1);
			}
		}
		url = new URL(urlString + (method.equalsIgnoreCase("GET") ? param : ""));
		urlConnection = (HttpURLConnection) url.openConnection();
		urlConnection.setRequestMethod(method);
		urlConnection.setConnectTimeout(5000);
		urlConnection.setReadTimeout(5000);
		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")) {
			// 要注意：一旦使用了urlConnection.getOutputStream().write()方法，
			// urlConnection.setRequestMethod("GET");将失效，其请求方法会自动转为POST
			urlConnection.getOutputStream().write(
					param.toString().getBytes("UTF-8"));
			urlConnection.getOutputStream().flush();
			urlConnection.getOutputStream().close();
		}
		return this.makeContent(urlString, urlConnection);
	}

	private HttpResponser makeContent(String urlString,
			HttpURLConnection urlConnection) throws IOException {
		HttpResponser httpResponserText = new HttpResponser();
		try {
			InputStream in = urlConnection.getInputStream();
			BufferedReader bufferedReader = new BufferedReader(
					new InputStreamReader(in));

			httpResponserText.contentCollection = new Vector<String>();
			StringBuffer contentString = new StringBuffer();

			String crlf = System.getProperty("line.separator");
			String line = bufferedReader.readLine();
			while (line != null) {
				httpResponserText.contentCollection.add(line);
				contentString.append(line).append(crlf);
				line = bufferedReader.readLine();
			}
			bufferedReader.close();
			in.close();

			// 获得返回值的字符集
			String ecod = urlConnection.getContentEncoding();
			if (ecod == null)
				ecod = this.defaultContentEncoding;

			httpResponserText.urlString = urlString;
			httpResponserText.defaultPort = urlConnection.getURL()
					.getDefaultPort();
			httpResponserText.file = urlConnection.getURL().getFile();
			httpResponserText.host = urlConnection.getURL().getHost();
			httpResponserText.path = urlConnection.getURL().getPath();
			httpResponserText.port = urlConnection.getURL().getPort();
			httpResponserText.protocol = urlConnection.getURL().getProtocol();
			httpResponserText.query = urlConnection.getURL().getQuery();
			httpResponserText.ref = urlConnection.getURL().getRef();
			httpResponserText.userInfo = urlConnection.getURL().getUserInfo();
			httpResponserText.contentString = new String(contentString
					.toString().getBytes(), ecod);
			httpResponserText.contentEncoding = ecod;
			httpResponserText.code = urlConnection.getResponseCode();
			httpResponserText.message = urlConnection.getResponseMessage();
			httpResponserText.contentType = urlConnection.getContentType();
			httpResponserText.method = urlConnection.getRequestMethod();
			httpResponserText.connectTimeout = urlConnection
					.getConnectTimeout();
			httpResponserText.readTimeout = urlConnection.getReadTimeout();

			return httpResponserText;
		} catch (IOException e) {
			throw e;
		} finally {
			// 最终关闭流
			if (urlConnection != null)
				urlConnection.disconnect();
		}
	}
/**
 * 
 * @param urlPath eg:http://www.viralpatel.net/blogs/
 * @return
 */
	public String getResponseString(String urlPath) {
		try {
			URL url = new URL(urlPath);
			BufferedReader br = new BufferedReader(new InputStreamReader(url
					.openStream()));
			StringBuffer sb = new StringBuffer();
			String tp=br.readLine();
			while (tp!= null) {
				sb.append(tp);
				tp=br.readLine();
			}
			return sb.toString();
		} catch (Exception ex) {
			ex.printStackTrace();
		}
		return null;
	}

	public String getDefaultContentEncoding() {
		return this.defaultContentEncoding;
	}

	public void setDefaultContentEncoding(String contentEncoding) {
		this.defaultContentEncoding = contentEncoding;
	}
}

package com.fx.util;

import java.io.IOException;
import java.io.UnsupportedEncodingException;
import java.net.HttpURLConnection;
import java.net.URL;
import java.net.URLDecoder;
import java.net.URLEncoder;

import sun.misc.BASE64Decoder;
import sun.misc.BASE64Encoder;

public class HttpCheck {
	/**
	 * 将参数先进行base64编码 在进行URL编码
	 * @param httpUrlstr
	 * @param param
	 * @return
	 */
	public static String check(String httpUrlstr, String param){
		HttpRequester request = new HttpRequester();
		HttpResponser hr = null;
		BASE64Decoder bd = new BASE64Decoder();
		BASE64Encoder be= new BASE64Encoder();
		String req="";
		try {
			req = URLEncoder.encode(be.encode((param).getBytes("utf-8")),"utf-8");
		} catch (UnsupportedEncodingException e1) {
			e1.printStackTrace();
			return null;
		}
		try {
			hr = request.sendGet(httpUrlstr+req);
			String resposne=new String(bd.decodeBuffer(URLDecoder.decode(hr.getContentString(), "utf-8")),"utf-8");
			return resposne;
		} catch (Exception e) {
			String e_str = "Send get to " + httpUrlstr + " error : " + e.toString();
			System.err.println(e_str);
			return null;
		}
	}

	public static boolean exits(String http) {
		HttpURLConnection connection = null;
		try {
			connection = (HttpURLConnection) new URL(http).openConnection();
			connection.setConnectTimeout(1000);
			return connection.getResponseCode() == HttpURLConnection.HTTP_OK;
		} catch (IOException e) {
			return false;
		} finally {
			if (connection != null) {
				connection.disconnect();
			}
		}
	}
}