java操作new HttpPost(URL)和 new URL(shixun_ip) 获取流

内容摘要
HttpClient：private static HttpClient httpClient;
static {
if (httpClient == null) {
HttpParams params = new BasicHttpParams();
// 设置一些基本参数
Ht
文章正文

HttpClient：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
private static HttpClient httpClient;
    static {
        if (httpClient == null) {
            HttpParams params = new BasicHttpParams();
            // 设置一些基本参数
            HttpProtocolParams.setVersion(params, HttpVersion.HTTP_1_1);
            // 超时设置 /* 从连接池中取连接的超时时间 */
            ConnManagerParams.setTimeout(params, 1000);
            /* 连接超时 */
            HttpConnectionParams.setConnectionTimeout(params, 2000);
            /* 请求超时 */
            HttpConnectionParams.setSoTimeout(params, 4000);
            SchemeRegistry schReg = new SchemeRegistry();
            schReg.register(new Scheme("http", PlainSocketFactory
                    .getSocketFactory(), 80));
            schReg.register(new Scheme("https", SSLSocketFactory
                    .getSocketFactory(), 443));
            // 使用线程安全的连接管理来创建HttpClient
            ClientConnectionManager conMgr = new ThreadSafeClientConnManager(
                    params, schReg);
            httpClient = new DefaultHttpClient(conMgr, params);
        }
    }
@SuppressWarnings("unchecked")
    private <T> T getJsonObjectFromUrl(String urlStr,
            List<NameValuePair> params, Class<T> className) throws Exception{
        T object = null;
  
        InputStream in = null;
        try {
            HttpPost httpPost = new HttpPost(urlStr);
  
            if (params != null) {
                //              List<NameValuePair> nvps = new ArrayList<NameValuePair>();
                //              for (Entry<String, String> entry : params.entrySet()) {
                //                  nvps.add(new BasicNameValuePair(entry.getKey(), entry
                //                          .getValue()));
                //              }
                httpPost.setEntity(new UrlEncodedFormEntity(params, HTTP.UTF_8));
            }
            HttpResponse response = httpClient.execute(httpPost);
            HttpEntity entity = response.getEntity();
  
            if(entity!=null){
                in= entity.getContent(); //之前没使用这个造成了大量异常抛出
            }
  
            /*String s = EntityUtils.toString(in, "UTF-8");
            if (entity != null) {
                EntityUtils.consume(entity);
            }*/
  
            String s = inputStream2String(in,"UTF-8");
            JsonResult jsonResult = (JsonResult)JSONObject.parseObject(s, JsonResult.class);
            if(jsonResult.getCode() == 200){
                Object obj = jsonResult.getData();
  
                if(obj != null){
                    if(className.isInstance(obj)){
                        object = (T)(obj);
                    }
                    else if(obj instanceof JSONObject){
                        object= JSONObject.parseObject(obj.toString(), className);
                    }                  
                }
            }else{
                throw new Exception(jsonResult.getMsg());
            }
  
            if(in!=null){
                in.close();
            }
  
        } catch (Exception e) {
            throw e;
        }
  
        return object;
    }

new URL()：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
try{
                     
<span style="white-space:pre">                    </span>//省略
                    URL shixun = new URL(url);
                    InputStream in = shixun.openStream();
  
                     
                    long end = System.currentTimeMillis(); 
                    if((end-start)<=5000){  //5s内不响应就跳过
                         
                        String ret = cn.com.jsoft.jframe.utils.StringUtils.toString(in, "utf-8");
                        JSONObject obj = JSONObject.fromObject(ret);
                        if(obj!=null&&obj.getJSONObject("info")!=null&&obj.containsKey("info")==true){
                            JSONObject info = obj.getJSONObject("info");
                            JSONArray data = info.getJSONArray("data");
                            if(data!=null&&data.size()>0){
                                for(int i=0;i<data.size();i++){
                                    JSONObject entry = data.getJSONObject(i);
                                     
                                }
                            }
                        }
                        in.close();
                    }
  
                }catch (Exception e) {
                    e.printStackTrace();
                }

java将InputStream转为String

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
public static String inputStream2String(InputStream is, String charset) {
        ByteArrayOutputStream baos = null;
  
        try {
            baos = new ByteArrayOutputStream();
            int i = -1;
            while ((i = is.read()) != -1) {
                baos.write(i);
            }
            return baos.toString(charset);
        } catch (IOException e) {
            e.printStackTrace();
            logger.error("FileWRUtil.inputStream2String(InputStream is, String charset) occur error:"
                    + e.getMessage());
        } finally {
            if (null != baos) {
                try {
                    baos.close();
                } catch (IOException e) {
                    e.printStackTrace();
                    logger.error("FileWRUtil.inputStream2String(InputStream is, String charset) occur error:"
                            + e.getMessage());
                }
                baos = null;
            }
        }
  
        return null;
    }
代码注释
[!--zhushi--]
上一篇10个Java异常的关键知识点下一篇android和java的区别是什么

作者：喵哥笔记

IDC笔记

学的不仅是技术，更是梦想！