我无法得到任何为我工作的答案。问题是在图像上传之前进度将运行到 100%，这暗示在通过网络发送数据之前，一些缓冲区已被填满。经过一番研究，我发现确实是这样，那个缓冲区就是 Socket 发送缓冲区。为 OkHttpClient 提供一个 SocketFactory 终于奏效了。我的 Kotlin 代码如下...
首先，和其他人一样，我有一个用于包装 MultipartBody 的 CountingRequestBody。
class CountingRequestBody(var delegate: RequestBody, private var listener: (max: Long, value: Long) -> Unit): RequestBody() {
override fun contentType(): MediaType? {
return delegate.contentType()
}
override fun contentLength(): Long {
try {
return delegate.contentLength()
} catch (e: IOException) {
e.printStackTrace()
}
return -1
}
override fun writeTo(sink: BufferedSink) {
val countingSink = CountingSink(sink)
val bufferedSink = Okio.buffer(countingSink)
delegate.writeTo(bufferedSink)
bufferedSink.flush()
}
inner class CountingSink(delegate: Sink): ForwardingSink(delegate) {
private var bytesWritten: Long = 0
override fun write(source: Buffer, byteCount: Long) {
super.write(source, byteCount)
bytesWritten += byteCount
listener(contentLength(), bytesWritten)
}
}
}
我在 Retrofit2 中使用它。一般用法是这样的：
val builder = MultipartBody.Builder()
// Add stuff to the MultipartBody via the Builder
val body = CountingRequestBody(builder.build()) { max, value ->
// Progress your progress, or send it somewhere else.
}
在这一点上，我正在取得进展，但我会看到 100%，然后在数据上传时等待很长时间。关键是套接字在我的设置中默认配置为缓冲 3145728 字节的发送数据。好吧，我的图像就在它下面，进度显示填充该套接字发送缓冲区的进度。为了缓解这种情况，请为 OkHttpClient 创建一个 SocketFactory。
class ProgressFriendlySocketFactory(private val sendBufferSize: Int = DEFAULT_BUFFER_SIZE) : SocketFactory() {
override fun createSocket(): Socket {
return setSendBufferSize(Socket())
}
override fun createSocket(host: String, port: Int): Socket {
return setSendBufferSize(Socket(host, port))
}
override fun createSocket(host: String, port: Int, localHost: InetAddress, localPort: Int): Socket {
return setSendBufferSize(Socket(host, port, localHost, localPort))
}
override fun createSocket(host: InetAddress, port: Int): Socket {
return setSendBufferSize(Socket(host, port))
}
override fun createSocket(address: InetAddress, port: Int, localAddress: InetAddress, localPort: Int): Socket {
return setSendBufferSize(Socket(address, port, localAddress, localPort))
}
private fun setSendBufferSize(socket: Socket): Socket {
socket.sendBufferSize = sendBufferSize
return socket
}
companion object {
const val DEFAULT_BUFFER_SIZE = 2048
}
}
在配置期间，设置它。
val clientBuilder = OkHttpClient.Builder()
.socketFactory(ProgressFriendlySocketFactory())
正如其他人所提到的，记录请求正文可能会影响这一点并导致数据被多次读取。要么不记录正文，要么我所做的就是为 CountingRequestBody 关闭它。为此，我编写了自己的 HttpLoggingInterceptor，它解决了这个问题和其他问题（比如记录 MultipartBody）。但这超出了这个问题的范围。
if(requestBody is CountingRequestBody) {
// don't log the body in production
}
另一个问题是 MockWebServer。我有一种使用 MockWebServer 和 json 文件的风格，因此我的应用程序可以在没有网络的情况下运行，因此我可以在没有这种负担的情况下进行测试。要使此代码正常工作，Dispatcher 需要读取正文数据。我创建了这个 Dispatcher 就是为了做到这一点。然后它将调度转发给另一个 Dispatcher，例如默认的 QueueDispatcher。
class BodyReadingDispatcher(val child: Dispatcher): Dispatcher() {
override fun dispatch(request: RecordedRequest?): MockResponse {
val body = request?.body
if(body != null) {
val sink = ByteArray(1024)
while(body.read(sink) >= 0) {
Thread.sleep(50) // change this time to work for you
}
}
val response = child.dispatch(request)
return response
}
}
您可以在 MockWebServer 中将其用作：
var server = MockWebServer()
server.setDispatcher(BodyReadingDispatcher(QueueDispatcher()))
这是我项目中的所有工作代码。我确实出于说明目的而将其拉出。如果开箱即用对您不起作用，我深表歉意。