java 用户登录token

package com.cuiyongzhi.wechat.util;

import java.io.BufferedInputStream;

import java.io.BufferedReader;

import java.io.IOException;

import java.io.InputStream;

import java.io.InputStreamReader;

import java.io.OutputStreamWriter;

import java.net.MalformedURLException;

import java.net.URI;

import java.net.URL;

import java.net.URLConnection;

import java.util.ArrayList;

import java.util.List;

import java.util.Map;

import java.util.Set;

import java.util.zip.GZIPInputStream;

import org.apache.http.HttpResponse;

import org.apache.http.NameValuePair;

import org.apache.http.client.ClientProtocolException;

import org.apache.http.client.HttpClient;

import org.apache.http.client.entity.UrlEncodedFormEntity;

import org.apache.http.client.methods.HttpGet;

import org.apache.http.client.methods.HttpPost;

import org.apache.http.entity.StringEntity;

import org.apache.http.impl.client.DefaultHttpClient;

import org.apache.http.message.BasicNameValuePair;

import org.apache.http.protocol.HTTP;

import org.apache.http.util.EntityUtils;

@SuppressWarnings("deprecation")

public class HttpUtils {

@SuppressWarnings("resource")

public static String sendGet(String reqUrl, Map params)

throws Exception {

InputStream inputStream = null;

HttpGet request = new HttpGet();

try {

String url = buildUrl(reqUrl, params);

HttpClient client = new DefaultHttpClient();

request.setHeader("Accept-Encoding", "gzip");

request.setURI(new URI(url));

HttpResponse response = client.execute(request);

inputStream = response.getEntity().getContent();

String result = getJsonStringFromGZIP(inputStream);

return result;

} finally {

if (inputStream != null) {

inputStream.close();

}

request.releaseConnection();

}

}

@SuppressWarnings("resource")

public static String sendPost(String reqUrl, Map params)

throws Exception {

try {

Set set = params.keySet();

List list = new ArrayList();

for (String key : set) {

list.add(new BasicNameValuePair(key, params.get(key)));

}

if (list.size() > 0) {

try {

HttpClient client = new DefaultHttpClient();

HttpPost request = new HttpPost(reqUrl);

request.setHeader("Accept-Encoding", "gzip");

request.setEntity(new UrlEncodedFormEntity(list, HTTP.UTF_8));

HttpResponse response = client.execute(request);

InputStream inputStream = response.getEntity().getContent();

try {

String result = getJsonStringFromGZIP(inputStream);

return result;

} finally {

inputStream.close();

}

} catch (Exception ex) {

ex.printStackTrace();

throw new Exception("网络连接失败,请连接网络后再试");

}

} else {

throw new Exception("参数不全，请稍后重试");

}

} catch (Exception ex) {

ex.printStackTrace();

throw new Exception("发送未知异常");

}

}

public static String sendPostBuffer(String urls, String params)

throws ClientProtocolException, IOException {

HttpPost request = new HttpPost(urls);

StringEntity se = new StringEntity(params, HTTP.UTF_8);

request.setEntity(se);

// 发送请求

@SuppressWarnings("resource")

HttpResponse httpResponse = new DefaultHttpClient().execute(request);

// 得到应答的字符串，这也是一个 JSON 格式保存的数据

String retSrc = EntityUtils.toString(httpResponse.getEntity());

request.releaseConnection();

return retSrc;

}

public static String sendXmlPost(String urlStr, String xmlInfo) {

// xmlInfo xml具体字符串

try {

URL url = new URL(urlStr);

URLConnection con = url.openConnection();

con.setDoOutput(true);

con.setRequestProperty("Pragma:", "no-cache");

con.setRequestProperty("Cache-Control", "no-cache");

con.setRequestProperty("Content-Type", "text/xml");

OutputStreamWriter out = new OutputStreamWriter(

con.getOutputStream());

out.write(new String(xmlInfo.getBytes("utf-8")));

out.flush();

out.close();

BufferedReader br = new BufferedReader(new InputStreamReader(

con.getInputStream()));

String lines = "";

for (String line = br.readLine(); line != null; line = br

.readLine()) {

lines = lines + line;

}

return lines; // 返回请求结果

} catch (MalformedURLException e) {

e.printStackTrace();

} catch (IOException e) {

e.printStackTrace();

}

return "fail";

}

private static String getJsonStringFromGZIP(InputStream is) {

String jsonString = null;

try {

BufferedInputStream bis = new BufferedInputStream(is);

bis.mark(2);

// 取前两个字节

byte[] header = new byte[2];

int result = bis.read(header);

// reset输入流到开始位置

bis.reset();

// 判断是否是GZIP格式

int headerData = getShort(header);

// Gzip 流 的前两个字节是 0x1f8b

if (result != -1 && headerData == 0x1f8b) {

// LogUtil.i("HttpTask", " use GZIPInputStream  ");

is = new GZIPInputStream(bis);

} else {

// LogUtil.d("HttpTask", " not use GZIPInputStream");

is = bis;

}

InputStreamReader reader = new InputStreamReader(is, "utf-8");

char[] data = new char[100];

int readSize;

StringBuffer sb = new StringBuffer();

while ((readSize = reader.read(data)) > 0) {

sb.append(data, 0, readSize);

}

jsonString = sb.toString();

bis.close();

reader.close();

} catch (Exception e) {

e.printStackTrace();

}

return jsonString;

}

private static int getShort(byte[] data) {

return (data[0] <

}

public static String buildUrl(String reqUrl, Map params) {

StringBuilder query = new StringBuilder();

Set set = params.keySet();

for (String key : set) {

query.append(String.format("%s=%s&", key, params.get(key)));

}

return reqUrl + "?" + query.toString();

}

}