import com.squareup.okhttp.*;
import okio.Buffer;
import okio.BufferedSink;
import okio.Okio;
import okio.Source;import java.io.File;
import java.io.IOException;public class ProgressUploadFile {private static final OkHttpClient okHttpClient = new OkHttpClient();private void run() {MultipartBuilder builder = new MultipartBuilder().type(MultipartBuilder.FORM);File file = new File("D:\\file.jpg");builder.addFormDataPart("file", file.getName(), createCustomRequestBody(MultipartBuilder.FORM, file, new ProgressListener() {@Override public void onProgress(long totalBytes, long remainingBytes, boolean done) {System.out.print((totalBytes - remainingBytes) * 100 / totalBytes + "%");}}));RequestBody requestBody = builder.build();Request request = new Request.Builder().url("http://localhost:8080/upload") //地址
                .post(requestBody).build();okHttpClient.newCall(request).enqueue(new Callback() {@Override public void onFailure(Request request, IOException e) {}@Override public void onResponse(Response response) throws IOException {System.out.println("response.body().string() = " + response.body().string());}});}public static RequestBody createCustomRequestBody(final MediaType contentType, final File file, final ProgressListener listener) {return new RequestBody() {@Override public MediaType contentType() {return contentType;}@Override public long contentLength() {return file.length();}@Override public void writeTo(BufferedSink sink) throws IOException {Source source;try {source = Okio.source(file);//sink.writeAll(source);Buffer buf = new Buffer();Long remaining = contentLength();for (long readCount; (readCount = source.read(buf, 2048)) != -1; ) {sink.write(buf, readCount);listener.onProgress(contentLength(), remaining -= readCount, remaining == 0);}} catch (Exception e) {e.printStackTrace();}}};}interface ProgressListener {void onProgress(long totalBytes, long remainingBytes, boolean done);}public static void main(String[] args) {new ProgressUploadFile().run();}}