OKHTTP3 异步写法

1、MainActivity.java

package com.test.androidclient;

import android.Manifest;
import android.content.pm.PackageManager;
import android.os.Build;
import android.os.Bundle;
import android.support.annotation.NonNull;
import android.support.v4.app.ActivityCompat;
import android.support.v4.content.ContextCompat;
import android.support.v7.app.AppCompatActivity;
import android.view.View;
import android.widget.Button;
import android.widget.TextView;

import com.google.gson.Gson;
import com.test.androidclient.model.Student;
import com.test.androidclient.util.NetTool;

import java.util.HashMap;
import java.util.Map;

public class MainActivity extends AppCompatActivity {

    private String URL= "http://192.168.13.26:8088";
    private TextView tvData = null;
    private Button btnTxt = null;
    private Button btnGet = null;

    public NetTool nt;

    private Button btnUploadFile = null;
    private Button btnReadTxtFile = null;
    private Button btnDownloadFile = null;
    private static final int FILE_SELECT_CODE = 0;
    String filepath = "";
    String filename = "";
    String retStr = "";
    final int REQUEST_WRITE=1;//申请权限的请求码

    //需要将下面的IP改为服务器端IP
    private String txtUrl = URL + "/AppServer/SynTxtDataServlet.json";
    private String url = URL + "/AppServer/SynDataServlet.json";
    private String uploadUrl = URL + "/AppServer/UploadFileServlet.json";
    private String fileUrl = URL + "/download/2.jpg";

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);

        tvData = (TextView) findViewById(R.id.tvData);
        btnTxt = (Button) findViewById(R.id.btnTxt);
        btnGet = (Button) findViewById(R.id.btnGet);

        btnUploadFile = (Button) findViewById(R.id.btnUploadFile);
        btnDownloadFile = (Button) findViewById(R.id.btnDownloadFile);

        btnTxt.setOnClickListener(btnListener);
        btnGet.setOnClickListener(btnListener);

        btnUploadFile.setOnClickListener(btnListener);
        btnDownloadFile.setOnClickListener(btnListener);
        nt = new NetTool(this);

        /*try {
            run("http://192.168.1.3:8080/user/Test.json");
        } catch (IOException e) {
            e.printStackTrace();
        }*/


    }





    View.OnClickListener btnListener = new View.OnClickListener() {


        @Override
        public void onClick(View v) {
            switch (v.getId()) {
                case R.id.btnTxt:
                    Student student = new Student();

                    student.setLoginname("likun");
                    student.setPassword("123456");
                    student.setEmail("[e-mail]");
                    student.setMobile("13911111111");
                    student.setUsername("李坤");
                    student.setClasses("五期信息技术提高班");
                    Gson gson = new Gson();
                    String jsonTxt = gson.toJson(student);

                    try {
                        nt.sendTxt(txtUrl, jsonTxt,"UTF-8");
                    } catch (Exception e2) {
                        e2.printStackTrace();
                    }
                    break;
                case R.id.btnGet:
                    Map<String, String> map = new HashMap<String, String>();
                    map.put("name", "李坤");
                    map.put("age", "26");
                    map.put("classes", "五期信息技术提高班");
                    try {
                        retStr = NetTool.sendGetRequest(url, map, "utf-8");
                    } catch (Exception e) {
                        e.printStackTrace();
                    }
                    break;

                case R.id.btnUploadFile:
                    // 需要在sdcard中放一张image.jsp的图片,本例才能正确运行
                    try {
                        if (Build.VERSION.SDK_INT >= 23)
                        {
                            if(ContextCompat.checkSelfPermission(MainActivity.this, Manifest.permission.WRITE_EXTERNAL_STORAGE)!=PackageManager.PERMISSION_GRANTED)
                            {
                                ActivityCompat.requestPermissions(MainActivity.this,new String[]{Manifest.permission.WRITE_EXTERNAL_STORAGE},REQUEST_WRITE);

                            }else {
                                retStr = NetTool.sendFile(uploadUrl, "/sdcard/Pictures/1.jpg",
                                        "1.jpg");
                            }
                        }
                        else
                        {
                            retStr = NetTool.sendFile(uploadUrl, "/sdcard/Pictures/1.jpg",
                                    "1.jpg");
                        }


                    } catch (Exception e) {
                        e.printStackTrace();
                    }
                    break;

                case R.id.btnDownloadFile:

                    if (Build.VERSION.SDK_INT >= 23)
                    {
                        if(ContextCompat.checkSelfPermission(MainActivity.this, Manifest.permission.WRITE_EXTERNAL_STORAGE)!=PackageManager.PERMISSION_GRANTED)
                        {
                            ActivityCompat.requestPermissions(MainActivity.this,new String[]{Manifest.permission.WRITE_EXTERNAL_STORAGE},REQUEST_WRITE);

                        }else {
                            try {
                                NetTool.downloadFile(fileUrl, "/sdcard/Pictures/", "newfile.jpg");
                            } catch (Exception e) {
                                e.printStackTrace();
                            }
                        }
                    }
                    else
                    {
                        try {
                            NetTool.downloadFile(fileUrl, "/sdcard/Pictures/", "newfile.jpg");
                        } catch (Exception e) {
                            e.printStackTrace();
                        }
                    }


                    break;
                default:
                    break;
            }
            tvData.setText(retStr);
        }
    };

    @Override
    public void onRequestPermissionsResult(int requestCode, @NonNull String[] permissions, @NonNull int[] grantResults) {
        super.onRequestPermissionsResult(requestCode, permissions, grantResults);
        if(requestCode==REQUEST_WRITE&&grantResults[0]== PackageManager.PERMISSION_GRANTED){
            try {
                retStr = NetTool.sendFile(uploadUrl, "/sdcard/Pictures/1.jpg",
                        "1.jpg");
            } catch (Exception e) {
                e.printStackTrace();
            }
        }

    }
}

　　

2、NetTool

package com.test.androidclient.util;

import android.os.Environment;
import android.os.Looper;
import android.util.Log;
import android.widget.Toast;

import com.test.androidclient.MainActivity;

import java.io.BufferedReader;
import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.HttpURLConnection;
import java.net.URL;
import java.net.URLEncoder;
import java.util.Map;
import java.util.concurrent.TimeUnit;

import okhttp3.Call;
import okhttp3.Callback;
import okhttp3.MediaType;
import okhttp3.MultipartBody;
import okhttp3.OkHttpClient;
import okhttp3.Request;
import okhttp3.RequestBody;
import okhttp3.Response;

import static android.content.ContentValues.TAG;

/**
 * NetTool:封装一个类搞定90%安卓客户端与服务器端交互
 *
 *
 */
public  class NetTool {
    private static final int TIMEOUT = 10000;// 10秒
    private static OkHttpClient client = null;
    public static final MediaType FORM_CONTENT_TYPE
            = MediaType.parse("application/json; charset=utf-8");
    public static final MediaType MEDIA_OBJECT_STREAM
            = MediaType.parse("application/octet-stream");

    public MainActivity aActivity = null;
    public NetTool(MainActivity mainActivity) {
        aActivity = mainActivity;
    }


    /**
     * 传送文本,例如Json
     */
    public  void sendTxt(String urlPath, String txt, String encoding)
            throws Exception {
        RequestBody body = RequestBody.create(FORM_CONTENT_TYPE, txt);
        client = new OkHttpClient();
        Request request = new Request.Builder()
                .url(urlPath)
                .post(body)
                .build();
        Call call = client.newCall(request);
        call.enqueue(new Callback() {
            // 2
            @Override
            public void onFailure(Call call, IOException e) {
                //Toast.makeText(MainActivity.this, e.getMessage(), Toast.LENGTH_SHORT).show();

                if (Looper.getMainLooper().getThread() == Thread.currentThread()) {
                    Log.d("eee", "Main Thread");

                } else {
                    Log.d("eee", "Not Main Thread11111");
                }
            }

            @Override
            public void onResponse(Call call, final Response response) throws IOException {
                // 3
                if (Looper.getMainLooper().getThread() == Thread.currentThread()) {
                    Log.d("eee", "Main Thread");
                    System.out.println(response.body().string()+"=================================");
                } else {
                    System.out.println(response.body().string()+"=================================222222");
                    Log.d("eee", "Not Main Thread22222");

                }

                aActivity.runOnUiThread(new Runnable() {
                    @Override
                    public void run() {
                        Log.d(TAG, "code: ");
                        Toast.makeText(aActivity, String.valueOf(response.code()), Toast.LENGTH_SHORT).show();
                    }
                });
            }
        });

    }


    /**
     * 上传文件
     */
    public static String sendFile(String urlPath, String filePath,
                                  String newName) throws Exception {
        client = new OkHttpClient();
        //创建File
        File file = new File(filePath);
        //创建RequestBody
        RequestBody body = RequestBody.create(MEDIA_OBJECT_STREAM, file);
        RequestBody requestBody = new MultipartBody.Builder().addFormDataPart("filename", file.getName(), body).build();

        //创建Request
        final Request request = new Request.Builder().url(urlPath).post(requestBody).build();
        final Call call = client.newBuilder().writeTimeout(50, TimeUnit.SECONDS).build().newCall(request);
        call.enqueue(new Callback() {
            @Override
            public void onFailure(Call call, IOException e) {
                Log.e(TAG, e.toString());
            }

            @Override
            public void onResponse(Call call, Response response) throws IOException {
                if (response.isSuccessful()) {
                    String string = response.body().string();
                    Log.e(TAG, "response ----->" + string);
                } else {
                }
            }
        });
        return null;
    }

    /**
     * 通过get方式提交参数给服务器
     */
    public static String sendGetRequest(String actionUrl,
                                        Map<String, String> paramsMap, String encoding) throws Exception {

        try {
        StringBuilder tempParams = new StringBuilder();
        int pos = 0;
        for (String key : paramsMap.keySet()) {
            if (pos > 0) {
                tempParams.append("&");
            }
            tempParams.append(String.format("%s=%s", key, URLEncoder.encode(paramsMap.get(key), "utf-8")));
            pos++;
        }
        String params = tempParams.toString();
        RequestBody body = RequestBody.create(FORM_CONTENT_TYPE, params);
        String requestUrl = String.format("%s?%s",actionUrl,tempParams.toString());
        client = new OkHttpClient();
        Request request = new Request.Builder()
                .url(requestUrl)

                .build();


        Call call = client.newCall(request);
        call.enqueue(new Callback() {
            @Override
            public void onFailure(Call call, IOException e) {
                Log.e(TAG, e.toString());
            }

            @Override
            public void onResponse(Call call, Response response) throws IOException {
                if (response.isSuccessful()) {
                    String string = response.body().string();
                    Log.e(TAG, "response ----->" + string);
                } else {
                }
            }
        });
        return "error";
    } catch (Exception e) {
        Log.e(TAG, e.toString());
    }
    return null;

    }

    /**
     * 通过Post方式提交参数给服务器,也可以用来传送json
     */
    public static String sendPostRequest(String urlPath,
                                         Map<String, String> params, String encoding) throws Exception {
        StringBuilder sb = new StringBuilder();
        // 如果参数不为空
        if (params != null && !params.isEmpty()) {
            for (Map.Entry<String, String> entry : params.entrySet()) {
                // Post方式提交参数的话，不能省略内容类型与长度
                sb.append(entry.getKey()).append('=').append(
                        URLEncoder.encode(entry.getValue(), encoding)).append(
                        '&');
            }
            sb.deleteCharAt(sb.length() - 1);
        }
        // 得到实体的二进制数据
        byte[] entitydata = sb.toString().getBytes();
        URL url = new URL(urlPath);
        HttpURLConnection conn = (HttpURLConnection) url.openConnection();
        conn.setRequestMethod("POST");
        conn.setConnectTimeout(TIMEOUT);
        // 如果通过post提交数据，必须设置允许对外输出数据
        conn.setDoOutput(true);
        // 这里只设置内容类型与内容长度的头字段
        conn.setRequestProperty("Content-Type",
                "application/x-www-form-urlencoded");
        // conn.setRequestProperty("Content-Type", "text/xml");
        conn.setRequestProperty("Charset", encoding);
        conn.setRequestProperty("Content-Length", String
                .valueOf(entitydata.length));
        OutputStream outStream = conn.getOutputStream();
        // 把实体数据写入是输出流
        outStream.write(entitydata);
        // 内存中的数据刷入
        outStream.flush();
        outStream.close();
        // 如果请求响应码是200，则表示成功
        if (conn.getResponseCode() == 200) {
            // 获得服务器响应的数据
            BufferedReader in = new BufferedReader(new InputStreamReader(conn
                    .getInputStream(), encoding));
            // 数据
            String retData = null;
            String responseData = "";
            while ((retData = in.readLine()) != null) {
                responseData += retData;
            }
            in.close();
            return responseData;
        }
        return "sendText error!";
    }





    /**
     * 该函数返回整形 -1：代表下载文件出错 0：代表下载文件成功 1：代表文件已经存在
     */
    public static int downloadFile(String urlStr, String path, String fileName)
            throws Exception {
        // 获取SD卡的目录
        File sdCardDir = Environment.getExternalStorageDirectory();



        final File targetFile = new File(sdCardDir.getCanonicalPath() + "/Pictures/" + fileName);
        client = new OkHttpClient();


        final Request request = new Request.Builder().url(urlStr).build();
        final Call call = client.newCall(request);
        call.enqueue(new Callback() {
            @Override
            public void onFailure(Call call, IOException e) {
                Log.e(TAG, e.toString());
            }

            @Override
            public void onResponse(Call call, Response response) throws IOException {
                InputStream is = null;
                byte[] buf = new byte[2048];
                int len = 0;
                FileOutputStream fos = null;
                try {
                    long total = response.body().contentLength();
                    Log.e(TAG, "total------>" + total);
                    long current = 0;
                    is = response.body().byteStream();
                    fos = new FileOutputStream(targetFile);
                    while ((len = is.read(buf)) != -1) {
                        current += len;
                        fos.write(buf, 0, len);
                        Log.e(TAG, "current------>" + current);
                    }
                    fos.flush();
                } catch (IOException e) {
                    Log.e(TAG, e.toString());
                } finally {
                    try {
                        if (is != null) {
                            is.close();
                        }
                        if (fos != null) {
                            fos.close();
                        }
                    } catch (IOException e) {
                        Log.e(TAG, e.toString());
                    }
                }
            }
        });
        return 0;
    }


}