使用 OkHttp 时是否可以限制带宽?
Is it possible to throttle bandwidth when using OkHttp?
在使用OkHttp 时是否可以限制带宽? (可能使用网络拦截器)。
您可以通过两种方式使其发挥作用:
- 手动发送请求和读取流,并在读取时节流。
- 添加拦截器。
使用OkHttp最好的方法是拦截器。还有几个简单的步骤:
- 继承Interceptor接口。
- 继承ResponseBodyclass.
- 在自定义 ResponceBody 中
override fun source(): BufferedSource
需要 return BandwidthSource 的缓冲区。
带宽源示例:
class BandwidthSource(
source: Source,
private val bandwidthLimit: Int
) : ForwardingSource(source) {
private var time = getSeconds()
override fun read(sink: Buffer, byteCount: Long): Long {
val read = super.read(sink, byteCount)
throttle(read)
return read
}
private fun throttle(byteCount: Long) {
val bitsCount = byteCount * BITS_IN_BYTE
val currentTime = getSeconds()
val timeDiff = currentTime - time
if (timeDiff == 0L) {
return
}
val kbps = bitsCount / timeDiff
if (kbps > bandwidthLimit) {
val times = (kbps / bandwidthLimit)
if (times > 0) {
runBlocking { delay(TimeUnit.SECONDS.toMillis(times)) }
}
}
time = currentTime
}
private fun getSeconds(): Long {
return TimeUnit.MILLISECONDS.toSeconds(System.currentTimeMillis())
}
}
在使用OkHttp 时是否可以限制带宽? (可能使用网络拦截器)。
您可以通过两种方式使其发挥作用:
- 手动发送请求和读取流,并在读取时节流。
- 添加拦截器。
使用OkHttp最好的方法是拦截器。还有几个简单的步骤:
- 继承Interceptor接口。
- 继承ResponseBodyclass.
- 在自定义 ResponceBody 中
override fun source(): BufferedSource
需要 return BandwidthSource 的缓冲区。
带宽源示例:
class BandwidthSource(
source: Source,
private val bandwidthLimit: Int
) : ForwardingSource(source) {
private var time = getSeconds()
override fun read(sink: Buffer, byteCount: Long): Long {
val read = super.read(sink, byteCount)
throttle(read)
return read
}
private fun throttle(byteCount: Long) {
val bitsCount = byteCount * BITS_IN_BYTE
val currentTime = getSeconds()
val timeDiff = currentTime - time
if (timeDiff == 0L) {
return
}
val kbps = bitsCount / timeDiff
if (kbps > bandwidthLimit) {
val times = (kbps / bandwidthLimit)
if (times > 0) {
runBlocking { delay(TimeUnit.SECONDS.toMillis(times)) }
}
}
time = currentTime
}
private fun getSeconds(): Long {
return TimeUnit.MILLISECONDS.toSeconds(System.currentTimeMillis())
}
}