摘要:使用UrlConnection實(shí)現(xiàn)后臺(tái)模擬http請(qǐng)求的簡(jiǎn)單實(shí)例這兩天在整理看httpclient,然后想自己用UrlConnection后臺(tái)模擬實(shí)現(xiàn)Http請(qǐng)求,于是一個(gè)簡(jiǎn)單的小例子就新鮮出爐了(支持代理哦):public class SimpleHttpTest { public static S
使用UrlConnection實(shí)現(xiàn)后臺(tái)模擬http請(qǐng)求的簡(jiǎn)單實(shí)例
這兩天在整理看httpclient,然后想自己用UrlConnection后臺(tái)模擬實(shí)現(xiàn)Http請(qǐng)求,于是一個(gè)簡(jiǎn)單的小例子就新鮮出爐了(支持代理哦):
public class SimpleHttpTest { public static String send(String urlStr, Map<String,String> map,String encoding){ String body=""; StringBuffer sbuf = new StringBuffer(); if(map!=null){ for (Entry<String,String> entry : map.entrySet()) { sbuf.append(entry.getKey()).append("=").append(entry.getValue()).append("&"); } if(sbuf.length()>0){ sbuf.DELETECharAt(sbuf.length()-1); } } // 1、重新對(duì)請(qǐng)求報(bào)文進(jìn)行 GBK 編碼 byte[] postData = null; try { postData = sbuf.toString().getBytes(encoding); } catch (UnsupportedEncodingException e) { e.printStackTrace(); } // 2、發(fā)送 HTTP(S) 請(qǐng)求 OutputStream reqStream = null; InputStream resStream = null; URLConnection request = null; try { System.out.println("交易請(qǐng)求地址:" + urlStr); System.out.println("參數(shù):" + sbuf.toString()); //A、與服務(wù)器建立 HTTP(S) 連接 URL url = null; try { Proxy proxy = new Proxy(java.net.Proxy.Type.HTTP,new InetSocketAddress("127.0.0.1", 8087)); url = new URL(urlStr); request = url.openConnection(proxy); request.setDoInput(true); request.setDoOutput(true); } catch (MalformedURLException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } //B、指定報(bào)文頭【Content-type】、【Content-length】 與 【Keep-alive】 request.setRequestProperty("Content-type", "application/x-www-form-urlencoded"); request.setRequestProperty("Content-length", String.valueOf(postData.length)); request.setRequestProperty("Keep-alive", "false"); request.setRequestProperty("User-Agent", "Mozilla/4.0 (compatible; MSIE 5.0; Windows NT; DigExt)"); //C、發(fā)送報(bào)文至服務(wù)器 reqStream = request.getOutputStream(); reqStream.write(postData); reqStream.close(); //D、接收服務(wù)器返回結(jié)果 ByteArrayOutputStream ms = null; resStream = request.getInputStream(); ms = new ByteArrayOutputStream(); byte[] buf = new byte[4096]; int count; while ((count = resStream.read(buf, 0, buf.length)) > 0) { ms.write(buf, 0, count); } resStream.close(); body = new String(ms.toByteArray(), encoding); } catch (UnknownHostException e) { System.err.println( "服務(wù)器不可達(dá)【" + e.getMessage() + "】"); } catch (IOException e) { e.printStackTrace(); } finally { try { if (reqStream != null) reqStream.close(); if (resStream != null) resStream.close(); } catch (Exception ex) { } } System.out.println("交易響應(yīng)結(jié)果:"); System.out.println(body); return body; } public static void main(String[] args) { String url="http://php.weather.sina.com.cn/iframe/index/w_cl.php"; Map<String, String> map = new HashMap<String, String>(); map.put("code", "js"); map.put("day", "0"); map.put("city", "上海"); map.put("dfc", "1"); map.put("charset", "utf-8"); send(url, map,"utf-8"); } }
結(jié)果如下:
交易請(qǐng)求地址:http://php.weather.sina.com.cn/iframe/index/w_cl.php 參數(shù):dfc=1&charset=utf-8&day=0&code=js&city=上海 交易響應(yīng)結(jié)果: (function(){var w=[];w['上海']=[{s1:'陰',s2:'陰',f1:'yin',f2:'yin',t1:'17',t2:'14',p1:'≤3',p2:'≤3', d1:'東北風(fēng)',d2:'東北風(fēng)'}];var add={now:'2015-11-11 19:04:33',time:'1447239873',UPDATE:' 北京時(shí)間11月11日17:10更新',error:'0',total:'1'};window.SWther={w:w,add:add};})();//0
代碼中的步驟寫的很明白了,如果你有心,還可以對(duì)該方法進(jìn)行各種封裝,方便使用。下篇我會(huì)分享一下httpclient是如何模擬后臺(tái)來發(fā)送http請(qǐng)求的,還有配置ssl、代理、自定義header等等,敬請(qǐng)期待吧。
更多關(guān)于使用UrlConnection實(shí)現(xiàn)后臺(tái)模擬http請(qǐng)求的簡(jiǎn)單實(shí)例請(qǐng)關(guān)注PHP中文網(wǎng)(ipnx.cn)其他文章!