OkHttp封装

1
/**
2
 * Okhttp封装
3
 */
4
public class OkhttpNet {
5
    private static OkHttpClient client = null;
6

7
    private OkhttpNet() {
8
    }
9

10
    public static OkHttpClient getInstance() {
11
        if (client == null) {
12
            synchronized (OkhttpNet.class) {
13
                if (client == null)
14
                    client = new OkHttpClient();
15
            }
16
        }
17
        return client;
18
    }
19

20
    /**
21
     * Get请求
22
     *
23
     * @param url
24
     * @param callback
25
     */
26
    public static void doGet(String url, Callback callback) {
27
        Request request = new Request.Builder()
28
                .url(url)
29
                .build();
30
        Call call = getInstance().newCall(request);
31
        call.enqueue(callback);
32
    }
33

34
    /**
35
     * Post请求发送键值对数据
36
     *
37
     * @param url
38
     * @param mapParams
39
     * @param callback
40
     */
41
    public static void doPost(String url, Map mapParams, Callback callback) {
42
        FormBody.Builder builder = new FormBody.Builder();
43
        for (String key : mapParams.keySet()) {
44
            builder.add(key, mapParams.get(key));
45
        }
46
        Request request = new Request.Builder()
47
                .url(url)
48
                .post(builder.build())
49
                .build();
50
        Call call = getInstance().newCall(request);
51
        call.enqueue(callback);
52
    }
53

54

55
    /**
56
     * Post请求发送JSON数据
57
     *
58
     * @param url
59
     * @param jsonParams
60
     * @param callback
61
     */
62
    public static void doPost(String url, String jsonParams, Callback callback) {
63
        RequestBody body = RequestBody.create(MediaType.parse("application/json; charset=utf-8")
64
                , jsonParams);
65
        Request request = new Request.Builder()
66
                .url(url)
67
                .post(body)
68
                .build();
69
        Call call = getInstance().newCall(request);
70
        call.enqueue(callback);
71
    }
72

73

74
    /**
75
     * 上传文件
76
     *
77
     * @param url
78
     * @param callback
79
     * @param map           上传文件，map值：file///文件路径
80
     */
81
    public static void doFile(String url, Map map, Callback callback) {
82

83
        //创建文件参数
84
        MultipartBody.Builder builder = new MultipartBody.Builder()
85
                .setType(MultipartBody.FORM);
86
        if (map != null) {
87
            for (String key : map.keySet()) {
88

89
                Pattern pattern = Pattern.compile("^file///");
90
                    Matcher matcher = pattern.matcher(map.get(key));
91
                    //判断是否是要上传文件
92
                    if (matcher.find()) {
93
                        String[] path = map.get(key).split("file///");
94
                        String filePath = path[1];
95
                        String[] fileName = filePath.split("/");
96
                        //判断文件类型
97
                        MediaType MEDIA_TYPE = MediaType.parse(judgeType(filePath));
98
                        builder.addFormDataPart(key, fileName[fileName.length - 1],
99
                                RequestBody.create(MEDIA_TYPE, new File(filePath)));
100
                } else {
101
                    builder.addFormDataPart(key, map.get(key));
102
                }
103
            }
104
        }
105

106
        //发出请求参数
107
        Request request = new Request.Builder()
108
//                .header("Authorization", "Client-ID " + "9199fdef135c122")
109
                .url(url)
110
                .post(builder.build())
111
                .build();
112
        Call call = getInstance().newCall(request);
113
        call.enqueue(callback);
114
    }
115

116
    /**
117
     * 根据文件路径判断MediaType
118
     *
119
     * @param path
120
     * @return
121
     */
122
    private static String judgeType(String path) {
123
        FileNameMap fileNameMap = URLConnection.getFileNameMap();
124
        String contentTypeFor = fileNameMap.getContentTypeFor(path);
125
        if (contentTypeFor == null) {
126
            contentTypeFor = "application/octet-stream";
127
        }
128
        return contentTypeFor;
129
    }
130

131

132
    /**
133
     * 下载文件
134
     *
135
     * @param url
136
     * @param fileDir
137
     * @param fileName
138
     */
139
    public static void downFile(String url, final String fileDir, final String fileName) {
140
        Request request = new Request.Builder()
141
                .url(url)
142
                .build();
143
        Call call = getInstance().newCall(request);
144
        call.enqueue(new Callback() {
145
            @Override
146
            public void onFailure(Call call, IOException e) {
147

148
            }
149

150
            @Override
151
            public void onResponse(Call call, Response response) throws IOException {
152
                InputStream is = null;
153
                byte[] buf = new byte[2048];
154
                int len = 0;
155
                FileOutputStream fos = null;
156
                try {
157
                    is = response.body().byteStream();
158
                    File file = new File(fileDir, fileName);
159
                    fos = new FileOutputStream(file);
160
                    while ((len = is.read(buf)) != -1) {
161
                        fos.write(buf, 0, len);
162
                    }
163
                    fos.flush();
164
                } catch (IOException e) {
165
                    e.printStackTrace();
166
                } finally {
167
                    if (is != null) is.close();
168
                    if (fos != null) fos.close();
169
                }
170
            }
171
            //获取进度条
172
//            @Override
173
//            public void onResponse(Call call, Response response) throws IOException {
174
//                InputStream is = null;
175
//                byte[] buf = new byte[2048];
176
//                int len = 0;
177
//                FileOutputStream fos = null;
178
//                try {
179
//                    is = response.body().byteStream();
180
//                    File file = new File(fileDir, fileName);
181
//                    fos = new FileOutputStream(file);
182
//                    //---增加的代码---
183
//                    //计算进度
184
//                    long totalSize = response.body().contentLength();
185
//                    long sum = 0;
186
//                    while ((len = is.read(buf)) != -1) {
187
//                        sum += len;
188
//                        //progress就是进度值
189
//                        int progress = (int) (sum * 1.0f/totalSize * 100);
190
//                        //---增加的代码---
191
//                        fos.write(buf, 0, len);
192
//                    }
193
//                    fos.flush();
194
//                } catch (IOException e) {
195
//                    e.printStackTrace();
196
//                } finally {
197
//                    if (is != null) is.close();
198
//                    if (fos != null) fos.close();
199
//                }
200
//            }
201
        });
202
    }
203
}