时间戳

首页 > 解决方案 > 使用 Retrofit 或 OkHttp 的 Twitter API v2 流式传输

twitter - 使用 Retrofit 或 OkHttp 的 Twitter API v2 流式传输

问题描述

我正在尝试集成新的 Twitter API，特别是我的 android 应用程序中的流式推文部分，我正在使用 Retrofit 进行我的 http 调用。

当我尝试拨打电话以获取流式推文时，它只是挂起并且不返回任何内容。

这是我的改装电话

@Streaming
@GET("tweets/search/stream")
suspend fun getFilteredStream(@Header("Authorization") token:String)

然后，我尝试仅使用 OkHttp 进行调用，如文档中所示，我得到了成功的响应，但我不知道如何流式传输数据。

我可以通过 curl 调用成功拨打电话，并且查看数据没有问题。

如何通过改造或 OkHttp 流式传输数据

更新：

使用 OkHttp，我可以通过这样做来获取数据

val client: OkHttpClient = OkHttpClient().newBuilder()
            .build()
        val request: Request = Request.Builder()
            .url("https://api.twitter.com/2/tweets/search/stream")
            .method("GET", null)
            .build()
        val response: Response = client.newCall(request).execute()
        val source = response.body?.source()
        val buffer = Buffer()
        while(!source!!.exhausted()){
            response.body?.source()?.read(buffer, 8192)
            val data = buffer.readString(Charset.defaultCharset())
        }

data保存多个推文对象的字符串数据表示，但是我如何一次读取一条推文，或者像这样解析响应？

标签： twitterretrofit2okhttptwitter-streaming-api

解决方案

从文档中，我认为您需要结合您拥有的两个示例。

https://github.com/square/retrofit/blob/108fe23964b986107aed352ba467cd2007d15208/retrofit/src/main/java/retrofit2/http/Streaming.java

按原样处理返回 {@link ResponseBody ResponseBody} 的方法的响应主体，即不将主体转换为 {@code byte[]}。

以及示例调用代码

https://github.com/square/retrofit/blob/108fe23964b986107aed352ba467cd2007d15208/retrofit/src/test/java/retrofit2/CallTest.java#L599

我怀疑，取决于您使用的 JSON API，您可能能够使用响应正文中的 Streaming API。但如果不是，您可以只在换行符或换行符上拆分，然后在下一行 { 并单独解析。对不起，我在这里帮不上忙。

见https://en.wikipedia.org/wiki/JSON_streaming#Concatenated_JSON

推荐阅读