用封裝好的okHttp3上傳圖片到介面
阿新 • • 發佈：2019-01-02
首先 ok的兩個依賴:
//okhttp compile 'com.squareup.okhttp3:okhttp:3.6.0' compile 'com.squareup.okio:okio:1.11.0'
//載入圖片 compile 'com.github.bumptech.glide:glide:3.6.1'
//工具類
package com.example.administrator.a1511a_myjd.view.util; import android.app.Activity; import android.content.Intent; importandroid.net.Uri; import android.os.Environment; import android.util.Log; import android.widget.Toast; import java.io.File; import java.io.FileOutputStream; import java.io.IOException; import java.io.InputStream; import java.util.Map; import java.util.concurrent.TimeUnit; import okhttp3.Cache; importokhttp3.Call; import okhttp3.Callback; import okhttp3.FormBody; import okhttp3.MediaType; import okhttp3.MultipartBody; import okhttp3.OkHttpClient; import okhttp3.Request; import okhttp3.RequestBody; import okhttp3.Response; /** * Created by Dash on 2017/12/8. */ public class OkHttp3Util { /** * 懶漢 安全 加同步* 1.私有的靜態成員變數 只宣告不建立 * 2.私有的構造方法 * 3.提供返回例項的靜態方法 */ private static OkHttpClient okHttpClient = null; private OkHttp3Util() { } public static OkHttpClient getInstance() { if (okHttpClient == null) { //加同步安全 synchronized (OkHttp3Util.class) { if (okHttpClient == null) { //okhttp可以快取資料....指定快取路徑 File sdcache = new File(Environment.getExternalStorageDirectory(),
"cache"); //指定快取大小 int cacheSize = 10 * 1024 * 1024; okHttpClient = new OkHttpClient.Builder()//構建器 .connectTimeout(15, TimeUnit.SECONDS)//連線超時 .writeTimeout(20, TimeUnit.SECONDS)//寫入超時 .readTimeout(20, TimeUnit.SECONDS)//讀取超時 .cache(new Cache(sdcache.getAbsoluteFile(), cacheSize))
//設定快取 .build(); } } } return okHttpClient; } /** * get請求 * 引數1 url * 引數2 回撥Callback */ public static void doGet(String oldUrl, Callback callback) { //建立OkHttpClient請求物件 OkHttpClient okHttpClient = getInstance(); //建立Request Request request = new Request.Builder().url(oldUrl).build(); //得到Call物件 Call call = okHttpClient.newCall(request); //執行非同步請求 call.enqueue(callback); } /** * post請求 * 引數1 url * 引數2 Map<String, String> params post請求的時候給伺服器傳的資料 * add..("","") * add() */ public static void doPost(String url, Map<String, String> params, Callback callback) { //建立OkHttpClient請求物件 OkHttpClient okHttpClient = getInstance(); //3.x版本post請求換成FormBody 封裝鍵值對引數 FormBody.Builder builder = new FormBody.Builder(); //遍歷集合,,,map集合遍歷方式 for (String key : params.keySet()) { builder.add(key, params.get(key)); } //建立Request....formBody...new formBody.Builder()...add()....build() Request request = new Request.Builder().url(url).post(builder.build()).build(); Call call = okHttpClient.newCall(request); call.enqueue(callback); } /** * post請求上傳檔案....包括圖片....流的形式傳任意檔案... * 引數1 url * file表示上傳的檔案 * fileName....檔案的名字,,例如aaa.jpg * params ....傳遞除了file檔案 其他的引數放到map集合 * */ public static void uploadFile(String url, File file, String fileName,Map<String,String>
params,Callback callback) {
//建立OkHttpClient請求物件
OkHttpClient okHttpClient = getInstance(); //MultipartBody多功能的請求實體物件,,,formBody只能傳表單形式的資料 MultipartBody.Builder builder = new MultipartBody.Builder(); builder.setType(MultipartBody.FORM); //引數 if (params != null){ for (String key : params.keySet()){ builder.addFormDataPart(key,params.get(key)); } } //檔案...引數name指的是請求路徑中所接受的引數...如果路徑接收引數鍵值是fileeeee,
//此處應該改變 builder.addFormDataPart("file",fileName,RequestBody.create
(MediaType.parse("application/octet-stream"),file)); //構建 MultipartBody multipartBody = builder.build(); //建立Request Request request = new Request.Builder().url(url).post(multipartBody).build(); //得到Call Call call = okHttpClient.newCall(request); //執行請求 call.enqueue(callback); } /** * Post請求傳送JSON資料....{"name":"zhangsan","pwd":"123456"} * 引數一：請求Url * 引數二：請求的JSON * 引數三：請求回撥 */ public static void doPostJson(String url, String jsonParams, Callback callback) { RequestBody requestBody = RequestBody.create(MediaType.parse
("application/json; charset=utf-8"), jsonParams); Request request = new Request.Builder().url(url).post(requestBody).build(); Call call = getInstance().newCall(request); call.enqueue(callback); } /** * 下載檔案 以流的形式把apk寫入的指定檔案 得到file後進行安裝 * 引數er：請求Url * 引數san：儲存檔案的資料夾....download */ public static void download(final Activity context, final String url,
final String saveDir) { Request request = new Request.Builder().url(url).build(); Call call = getInstance().newCall(request); call.enqueue(new Callback() { @Override public void onFailure(Call call, IOException e) { //com.orhanobut.logger.Logger.e(e.getLocalizedMessage()); } @Override public void onResponse(Call call, final Response response)
throws IOException { InputStream is = null; byte[] buf = new byte[2048]; int len = 0; FileOutputStream fos = null; try { is = response.body().byteStream();//以位元組流的形式拿回響應實體內容 //apk儲存路徑 final String fileDir = isExistDir(saveDir); //檔案 File file = new File(fileDir, getNameFromUrl(url)); fos = new FileOutputStream(file); while ((len = is.read(buf)) != -1) { fos.write(buf, 0, len); } fos.flush(); context.runOnUiThread(new Runnable() { @Override public void run() { Toast.makeText(context, "下載成功:" + fileDir + ",
" + getNameFromUrl(url), Toast.LENGTH_SHORT).show(); } }); //apk下載完成後 呼叫系統的安裝方法 Intent intent = new Intent(Intent.ACTION_VIEW); intent.setDataAndType(Uri.fromFile(file),
"application/vnd.android.package-archive"); context.startActivity(intent); } catch (IOException e) { e.printStackTrace(); } finally { if (is != null) is.close(); if (fos != null) fos.close(); } } }); } /** * 判斷下載目錄是否存在......並返回絕對路徑 * * @param saveDir * @return * @throws IOException */ public static String isExistDir(String saveDir) throws IOException { // 下載位置 if (Environment.getExternalStorageState().equals(Environment.MEDIA_MOUNTED)) { File downloadFile = new File(Environment.getExternalStorageDirectory(), saveDir); if (!downloadFile.mkdirs()) { downloadFile.createNewFile(); } String savePath = downloadFile.getAbsolutePath(); Log.e("savePath", savePath); return savePath; } return null; } /** * @param url * @return 從下載連線中解析出檔名 */ private static String getNameFromUrl(String url) { return url.substring(url.lastIndexOf("/") + 1); } }////////////////////////////////////////////////////////////////////////////////////////////////////////工具類結束
//舉例用法
上傳成功後,再獲取下來賦值到控制元件
//把頭像存到介面 每次介面獲取賦值 找到根目錄下的yixilong.jpg檔案圖片,dash.jpg是自己隨意寫的
名字,在介面中顯示的名字 File file = new File(Environment.getExternalStorageDirectory(), "yixilong.jpg");
Toast.makeText(getActivity(), file + "", Toast.LENGTH_SHORT).show(); HashMap<String, String> map = new HashMap<>(); map.put("uid", "4123");
OkHttp3Util.uploadFile(API_util.touxiang_api, file, "dash.jpg", map, new Callback() { @Override public void onFailure(Call call, IOException e) { Log.e("+++", "onFailure: " + e.getMessage()); e.printStackTrace(); } @Override public void onResponse(Call call, final Response response) throws IOException { Log.e("---", "onResponse: " + response.body().string()); if (response.isSuccessful()) { getActivity().runOnUiThread(new Runnable() { @Override public void run() { Toast.makeText(getActivity(), "此時上傳成功!!", Toast.LENGTH_SHORT).
show();
}
});
//此時上傳成功 獲取使用者資訊
OkHttp3Util.doGet("https://www.zhaoapi.cn/user/getUserInfo?uid=4123",
new Callback() { @Override
public void onFailure(Call call, IOException e) { } @Override public void onResponse(Call call, Response response) throws IOException { String string = response.body().string(); final UserBean userBean = new Gson().fromJson(string, UserBean.class); getActivity().runOnUiThread(new Runnable() { @Override public void run() { Glide.with(getActivity()).load(userBean.getData().getIcon()).into(touxiang); Toast.makeText(getActivity(), "上傳並且獲取成功", Toast.LENGTH_SHORT).show(); } }); } }); } } });