Android 网络操作(上传下载等)
package com.maidong.utils; import java.io.BufferedReader; import java.io.DataOutputStream; import java.io.File; import java.io.FileInputStream; import java.io.IOException; import java.io.InputStream; import java.io.InputStreamReader; import java.io.UnsupportedEncodingException; import java.net.HttpURLConnection; import java.net.URL; import java.net.URLConnection; import java.net.URLDecoder; import java.net.URLEncoder; import java.util.ArrayList; import java.util.List; import java.util.Map; import org.apache.http.HttpEntity; 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.HttpPost; import org.apache.http.impl.client.DefaultHttpClient; import org.apache.http.protocol.HTTP; import android.app.Activity; import android.content.Context; import android.net.ConnectivityManager; import android.net.NetworkInfo; public class InternetUtils { private static final String USER_AGENT = "User-Agent"; public static String httpPost(String url, List<NameValuePair> nameValuePairs) throws ClientProtocolException, IOException { HttpClient httpclient = new DefaultHttpClient(); HttpPost httpPost = new HttpPost(url); // List<NameValuePair> nameValuePairs = new ArrayList<NameValuePair>(2); // Your DATA // nameValuePairs.add(new BasicNameValuePair("id", "12345")); // nameValuePairs.add(new BasicNameValuePair("stringdata", // "eoeAndroid.com is Cool!")); httpPost.setHeader(USER_AGENT, "Mozilla/4.5"); HttpEntity httpEntity = null; try { httpPost.setEntity(new UrlEncodedFormEntity(nameValuePairs, HTTP.UTF_8)); httpEntity = httpclient.execute(httpPost).getEntity(); } finally { //httpPost.abort(); } return retrieveHttpEntity(httpEntity); } public static InputStream download(URL url) throws IOException { URLConnection conn = url.openConnection(); InputStream is = conn.getInputStream(); return is; } public static byte[] downloadFileData(String surl) throws IOException { URL url = new URL(surl); URLConnection conn = url.openConnection(); // 获取长度 int length = (int) conn.getContentLength(); InputStream is = conn.getInputStream(); byte[] imgData = null; if (length != -1) { imgData = new byte[length]; byte[] temp = new byte[512]; int readLen = 0; int destPos = 0; while ((readLen = is.read(temp)) > 0) { System.arraycopy(temp, 0, imgData, destPos, readLen); destPos += readLen; } } return imgData; } public static InputStream download(String url) throws IOException { return download(new URL(url)); } public static String httpPost(String url) throws ClientProtocolException, IOException { return httpPost(url, new ArrayList<NameValuePair>()); } private static String retrieveHttpEntity(HttpEntity httpEntity) throws UnsupportedEncodingException, IllegalStateException, IOException { StringBuffer stringBuffer = new StringBuffer(); InputStreamReader is = new InputStreamReader(httpEntity.getContent(), HTTP.UTF_8); BufferedReader bufferedReader = new BufferedReader(is); String line; while ((line = bufferedReader.readLine()) != null) { stringBuffer.append(line); } return stringBuffer.toString(); } public static String uploadFile(String actionUrl, String newName, InputStream fStream) { String end = "\r\n"; String twoHyphens = "--"; String boundary = java.util.UUID.randomUUID().toString(); DataOutputStream ds = null; try { URL url = new URL(actionUrl); HttpURLConnection con = (HttpURLConnection) url.openConnection(); /* 允许Input、Output,不使用Cache */ con.setDoInput(true); con.setDoOutput(true); con.setUseCaches(false); /* 设定传送的method=POST */ con.setRequestMethod("POST"); /* setRequestProperty */ con.setRequestProperty("Connection", "Keep-Alive"); con.setRequestProperty("Charset", "UTF-8"); con.setRequestProperty("Content-Type", "multipart/form-data;boundary=" + boundary); /* 设定DataOutputStream */ ds = new DataOutputStream(con.getOutputStream()); ds.writeBytes(twoHyphens + boundary + end); ds.writeBytes("Content-Disposition: form-data; " + "name=\"Filedata\";filename=\"" + newName + "\"" + end); ds.writeBytes(end); /* 取得文件的FileInputStream */ // FileInputStream fStream = new FileInputStream(uploadFile); /* 设定每次写入1024bytes */ int bufferSize = 1024; byte[] buffer = new byte[bufferSize]; int length = -1; /* 从文件读取数据到缓冲区 */ while ((length = fStream.read(buffer)) != -1) { /* 将数据写入DataOutputStream中 */ ds.write(buffer, 0, length); } ds.writeBytes(end); ds.writeBytes(twoHyphens + boundary + twoHyphens + end); ds.flush(); /* 取得Response内容 */ InputStream is = con.getInputStream(); int ch; StringBuffer b = new StringBuffer(); while ((ch = is.read()) != -1) { b.append((char) ch); } /* 将Response显示于Dialog */ // showDialog(b.toString().trim()); return b.toString().trim(); /* 关闭DataOutputStream */ } catch (Exception e) { // showDialog("" + e); } finally { AppUtils.close(ds); AppUtils.close(fStream); } return null; } /** * * @param s * @return null if the given string is null. * @throws UnsupportedEncodingException */ public static String decode(String s, String enc) throws UnsupportedEncodingException { return s == null ? null : URLDecoder.decode(s, enc); } public static String encode(String s, String enc) throws UnsupportedEncodingException { return URLEncoder.encode((s == null ? "" : s), enc); } /** * * 判断网络状态是否可用 * * @return true: 网络可用 ; false: 网络不可用 */ public static boolean isNetworkConnected(Activity activity) { ConnectivityManager conManager = (ConnectivityManager) activity.getSystemService(Context.CONNECTIVITY_SERVICE); NetworkInfo networkInfo = conManager.getActiveNetworkInfo(); if (networkInfo != null) { // 这个判断一定要,要不然会出错 return networkInfo.isAvailable(); } return false; } }
相关推荐
Kafka 2020-09-18
Wepe0 2020-10-30
杜倩 2020-10-29
windle 2020-10-29
minerd 2020-10-28
mengzuchao 2020-10-22
Junzizhiai 2020-10-10
bxqybxqy 2020-09-30
风之沙城 2020-09-24
kingszelda 2020-09-22
大唐帝国前营 2020-08-18
yixu0 2020-08-17
TangCuYu 2020-08-15
xiaoboliu00 2020-08-15
songshijiazuaa 2020-08-15
xclxcl 2020-08-03
zmzmmf 2020-08-03
newfarhui 2020-08-03
likesyour 2020-08-01