使用 OkHttp 消费音频流答案

【问题标题】：Consuming the audio stream with OkHttp使用 OkHttp 消费音频流
【发布时间】：2021-06-14 04:15:12
【问题描述】：

我想使用 Java 使用以下音频流 - https://playoutonestreaming.com/proxy/bylr?mp=/stream。

主要目标非常简单 - 我想创建一个服务，这将允许我目前拥有 300-400 个活动连接（例如活动侦听器）。当我尝试与 OkHttp 建立连接时出现问题。

这是我的代码：

消费流的任务

@Slf4j
@RequiredArgsConstructor
class ListenStream implements Runnable {
    private static final String STREAM_URL = "https://playoutonestreaming.com/proxy/bylr?mp=/stream";
    private final OkHttpClient client;
    private final int id;

    @Override
    public void run() {
        Clip clip;
        try {
            log.info("[TASK-{}] - Connecting to the stream...", id);
            Request request = new Request.Builder()
                    .url(STREAM_URL)
                    .get()
                    .build();
            Response response = client.newCall(request).execute();
            assert response.body() != null;
            InputStream is = new ByteArrayInputStream(response.body().bytes());
            AudioInputStream audioInputStream = AudioSystem.getAudioInputStream(is);
            clip = AudioSystem.getClip();
            clip.open(audioInputStream);
            clip.loop(Clip.LOOP_CONTINUOUSLY);
        } catch (IOException e) {
            log.info("Finished listening to the stream");
        } catch (LineUnavailableException | UnsupportedAudioFileException e) {
            log.error("Failed to process audio stream");
            e.printStackTrace();
        }
    }
}

执行者

public class RadioMain {

    public static void main(String[] args) throws InterruptedException {
        OkHttpClient client = new OkHttpClient.Builder()
                .callTimeout(120, TimeUnit.SECONDS)
                .connectTimeout(120, TimeUnit.SECONDS)
                .readTimeout(120, TimeUnit.SECONDS)
                .writeTimeout(120, TimeUnit.SECONDS)
                .followRedirects(true)
                .followSslRedirects(true)
                .build();

        ExecutorService service = Executors.newFixedThreadPool(300);
        List<Runnable> tasks = IntStream.range(1, 301)
                .mapToObj(number -> new ListenStream(client, number))
                .collect(Collectors.toList());
        tasks.forEach(service::submit);
        service.awaitTermination(120, TimeUnit.SECONDS);
        service.shutdown();
    }
}

通过以下方法，我必须为 OkHttpClient 设置超时，然后使用它发出请求。但是，一旦出现超时，我就会收到InterruptedIOException: socket closed，我需要创建一个新任务。有没有使用 OkHttp 消费音频流的正确方法？

【问题讨论】：

标签： java http okhttp audio-streaming

【解决方案1】：

在该时间长度之后调用超时将使请求失败，因此请删除该设置或将其定义为 0。

https://square.github.io/okhttp/4.x/okhttp/okhttp3/-ok-http-client/-builder/call-timeout/

设置完整调用的默认超时。值为 0 表示否超时，否则值必须介于 1 和 Integer.MAX_VALUE 之间时转换为毫秒。

呼叫超时跨越整个呼叫：解析 DNS、连接、编写请求正文、服务器处理和读取响应身体。如果调用需要重定向或重试，所有都必须完成在一个超时期限内。

默认值为 0，表示没有超时。

【讨论】：