- android - 多次调用 OnPrimaryClipChangedListener
- android - 无法更新 RecyclerView 中的 TextView 字段
- android.database.CursorIndexOutOfBoundsException : Index 0 requested, 光标大小为 0
- android - 使用 AppCompat 时,我们是否需要明确指定其 UI 组件(Spinner、EditText)颜色
使用 OkHttp Websocket 时 listener使用 ByteString 向应用程序提供二进制有效负载。我想将这些字节输入到一些需要 okio.Source (在本例中为 GzipSource)的代码中,但我找不到任何有效的方法来做到这一点。
我当前的解决方案如下所示:
@Override
public void onMessage(WebSocket webSocket, ByteString bytes) {
Buffer gzipBuffer = new Buffer();
gzipBuffer.write(bytes);
GzipSource gzipSource = new GzipSource(gzipBuffer);
....
}
这个 Buffer.write 的缺点是它会产生额外的字节副本(在 Buffer 的情况下,会产生分段副本,即使合并起来也会产生额外的开销)。在这个 Websocket 示例中,只是为 ByteString 本身分配了一个字节数组(当从 WebSocketReader
impl 移交时)。
我的问题是:是否有其他首选方式通过 Source
读取 ByteString
?由于 ByteString
应该是不可变的,而 Source
仅保存一些读取位置信息,我认为它应该是完全可行的(但不是来自外部代码,因为我无法访问 byte[]
)。所以感觉我在这里缺少一个明显的解决方案..:)
感谢您的任何提示或指示!
最佳答案
您编写的方式几乎是最佳的。
Okio 针对在转换层之间移动数据进行了优化:压缩、成帧、线程等。虽然在层之间移动数据的速度非常快(无副本),但最初将数据导入系统会产生前期成本。这通常是您需要执行的 I/O:加载文件或发送数据包。但在这种情况下,您必须复制才能将字节放入第一个缓冲区。这感觉效率低下,但好处是您的下一次 Source.read() 调用将会很快,因此整体效果仍然很好。
关于java - 由已分配的 ByteString 支持的高效 okio 源?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/54532432/
我有一个运行良好的应用程序,但有时当我向我的程序添加一些类和代码时,我的应用程序崩溃了。在我的 logcat 错误是这样的: 8871-8929/com.example.first E/Androi
在使用 Android Studio 运行我的代码时,它会生成此错误: Warning: Conflict with dependency 'com.squareup.okio: okio'. Res
我已经包含 okhttp3 并在低于 LOLLIPOP (api 21) 的安卓版本中测试了 PATCH 和 DELETE 方法。我没有包括 Okio,它运行良好。但是,在 okhttp site他们
我开始收到有关 的错误 **InvalidPackage: Package not included in Android** ../../../../../../../.gradle/caches/
我正在使用 OkHttp(首先是原始版本,然后我升级到 OkHttp3),我的应用程序的一些用户报告说,当应用程序未运行时,电池生命周期会显着下降。 我运行了一个分析器,结果是这样的: 如您所见,Ok
我的团队正受此困扰issue使用 slack 集成来上传文件,因此根据该问题中的评论,我想限制我们的 Kotlin 实现中的请求。 我正在尝试集成 Okio Throttler在 OkHttp 拦截器
i am getting this error when after integrating the OverAir sdks in Gradle and i dont know which one
大家好,我正在从 Android 设备读取原始音频,我想使用 Okio 将其写入文件中像这样: BufferedSink sink = Okio.buffer(Okio.sink(file)); 我有
我的系统需要使用 WAV 文件数组的字节创建单个 WAV 文件。目前它使用 Okio 在缓冲区上读取和写入数据,然后将数据写入最终文件。 我正在关注此文档和此堆栈溢出问题: http://tiny.s
已经在给定的解决方案下实现,但没有一个能正常工作,仍然面临下面列出的警告。 Warning: okio.DeflaterSink: can't find referenced class org.co
我正在尝试将此工作文件下载代码转换为 Reactive。但是由于我对 RxJava 知之甚少,卡住了。你能帮我把它变成 Reactive 吗? public void downloadFile(Mes
使用 OkHttp Websocket 时 listener使用 ByteString 向应用程序提供二进制有效负载。我想将这些字节输入到一些需要 okio.Source (在本例中为 GzipSou
我注意到 fabric 中有这样的异常,这种异常很少发生,但每次构建时,每周 2-3 个用户(约 500 DAU)会发生 3-5 次崩溃我没有找到有关此类崩溃的任何信息,有人知道是什么原因造成的吗?
我正在尝试使用 OkHttp 下载文件并使用 Okio 写入磁盘。我还为这个过程创建了一个 rx observable。它正在运行,但是它明显比我以前使用的(Koush 的 Ion 库)慢。 下面是我
我试图找出为什么 OkHttp 使用 Okio 而不是 BufferedInputStream 和 BufferedOutputStream 来缓冲数据。我用下面的代码来验证: private Str
我有一个应用程序可以从网络上下载内容。音乐、视频、pdf……就像一个下载管理器。 但现在每次下载内容时都会崩溃: E/LVN/advanced_memory_manager.c: ----------
在我们的应用程序中,我使用此代码下载图像文件。我需要在 UI 上显示下载进度(下载字节数百分比)。如何在此代码中获取下载进度?我搜索了解决方案,但仍然无法自行解决。 Observable downlo
我正在集成 Outlook API 并进行 HTTP 调用,我正在使用 改造版本 2.3.0 和 okHttp3 版本 3.9.1。 但是,当我进行 HTTP 调用时,例如: // Create a
问题是标题所说的。它只发生在有时和一些电话上。听说是我抓到的日志。 java.lang.IllegalStateException closed okio.RealBufferedSink.write
我遇到了依赖项问题,在某个地方我对 okio.Buffer$2 和可能对 okio.AsyncTimeout 有双重依赖(它在尝试解决问题时突然出现,但我在隔离问题时遇到了麻烦)。这是我的依赖项。 i
我是一名优秀的程序员,十分优秀!