Android 使用 OkHttp 访问流式接口并监听数据示例

以下是一个使用 OkHttp 访问流式接口并监听接口数据的示例代码：

OkHttpClient client = new OkHttpClient();

Request request = new Request.Builder()
        .url('http://example.com/stream')
        .build();

client.newCall(request).enqueue(new Callback() {
    @Override
    public void onFailure(Call call, IOException e) {
        e.printStackTrace();
    }

    @Override
    public void onResponse(Call call, Response response) throws IOException {
        if (!response.isSuccessful()) {
            throw new IOException('Unexpected code ' + response);
        }

        // 获取响应体输入流
        InputStream inputStream = response.body().byteStream();

        // 读取响应体数据
        BufferedReader reader = new BufferedReader(new InputStreamReader(inputStream));
        String line;
        while ((line = reader.readLine()) != null) {
            // 处理每一行数据
            System.out.println(line);
        }

        // 关闭输入流
        inputStream.close();
    }
});

在这个示例中，我们使用 OkHttp 创建一个 GET 请求，并将其发送到流式接口 URL。然后，我们在回调函数中处理响应。当响应成功时，我们获取响应体输入流并读取响应体数据。每次读取到一行数据时，我们可以将其传递给处理函数以进行处理。最后，我们关闭输入流以释放资源。