Android mediaPlayer Progressive Download "Соединение сброшено по пиру" - PullRequest
Новая
       59

Android mediaPlayer Progressive Download "Соединение сброшено по пиру"

0 голосов
/ 04 марта 2020

У меня проблема с android MediaPlayer, я сначала кэшировал всю песню в память перед ее воспроизведением, затем я решил воспроизвести песню из моего API, написанного на Spark Java. Так что теперь он работает нормально, если я пытаюсь найти загруженную точку, в противном случае он просто останавливается. и производит это на сервере API: 

    org.eclipse.jetty.io.EofException
at org.eclipse.jetty.io.ChannelEndPoint.flush(ChannelEndPoint.java:286)
at org.eclipse.jetty.io.WriteFlusher.flush(WriteFlusher.java:393)
at org.eclipse.jetty.io.WriteFlusher.completeWrite(WriteFlusher.java:349)
at org.eclipse.jetty.io.ChannelEndPoint$3.run(ChannelEndPoint.java:133)
at org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.runTask(EatWhatYouKill.java:333)
at org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.doProduce(EatWhatYouKill.java:295)
at org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.tryProduce(EatWhatYouKill.java:168)
at org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.run(EatWhatYouKill.java:126)
at org.eclipse.jetty.util.thread.ReservedThreadExecutor$ReservedThread.run(ReservedThreadExecutor.java:366)
at org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:765)
at org.eclipse.jetty.util.thread.QueuedThreadPool$2.run(QueuedThreadPool.java:683)
at java.base/java.lang.Thread.run(Thread.java:830)
Caused by: java.io.IOException: Connection reset by peer
at java.base/sun.nio.ch.SocketDispatcher.write0(Native Method)
at java.base/sun.nio.ch.SocketDispatcher.write(SocketDispatcher.java:54)
at java.base/sun.nio.ch.IOUtil.writeFromNativeBuffer(IOUtil.java:113)
at java.base/sun.nio.ch.IOUtil.write(IOUtil.java:79)
at java.base/sun.nio.ch.IOUtil.write(IOUtil.java:50)
at java.base/sun.nio.ch.SocketChannelImpl.write(SocketChannelImpl.java:484)
at org.eclipse.jetty.io.ChannelEndPoint.flush(ChannelEndPoint.java:264)

Это код, используемый в части API: 

public static Object postAudioResponse(Request request, Response response) {
    try ( OutputStream os = response.raw().getOutputStream(); BufferedOutputStream bos = new BufferedOutputStream(os))
    {
        File mp3 = new File("C:\\FTPServer\\" + request.queryParams("dir"));
        String range = request.headers("Range");
        if (range == null) {
            response.status(200);
            byte[] bytes = Files.readAllBytes(java.nio.file.Paths.get("C:\\FTPServer\\" + request.queryParams("dir")));
            response.header("Content-Type", "audio/mpeg");
            response.header("Content-Length", String.valueOf(bytes.length));
            System.out.println(response.raw().toString());
            HttpServletResponse raw = response.raw();
            raw.getOutputStream().write(bytes);
            raw.getOutputStream().flush();
            raw.getOutputStream().close();
            return raw;
        }
        int[] fromTo = fromTo(mp3, range);
        int length = fromTo[1] - fromTo[0] + 1;
        response.status(206);
        response.raw().setContentType("audio/mpeg");
        response.header("Accept-Ranges", "bytes");
        response.header("Content-Range", contentRangeByteString(fromTo));
        response.header("Content-Length", String.valueOf(length));
        final RandomAccessFile raf = new RandomAccessFile(mp3, "r");
        raf.seek(fromTo[0]);
        writeAudioToOS(length, raf, bos);
        raf.close();
        bos.flush();
        bos.close();
        return response.raw();
    } catch (IOException e) {
        e.printStackTrace();
        response.header("Content-Type", "application/json");
        return gson.toJson(new StandardResponse(StatusResponse.ERROR, e.toString()));
    }
}

И это мой HTTP-ответ API (формат строки) 

HTTP/1.1 206 
Date: Wed, 04 Mar 2020 19:39:45 GMT
Content-Type: audio/mpeg
Accept-Ranges: bytes
Content-Range: bytes 4767443-4775635/8897707
Content-Length: 8193

Я пробовал несколько вещей, меняя заголовок, проверяя заголовок несколько раз, пробовал ExoPlayer, я даже проверял android исходный код для части HTTP, и он показался правильным.

Android Код: 

mediaPlayer = new MediaPlayer();
mediaPlayer.setAudioStreamType(AudioManager.STREAM_MUSIC);
mediaPlayer.setDataSource(Api.getSongSource(songName));
mediaPlayer.prepareAsync();

Примечание. Исключение происходит до того, как я отправляю новый HTTP-ответ с Контентом в заданном c диапазоне. Спасибо.

* UPD *

Я решил эту проблему в первом ответе.

1 Ответ

0 голосов
/ 05 марта 2020

Я исправил вышеуказанную ошибку, выполнив следующую команду

* на стороне клиента Вместо использования mediaPlayer в android native SDK я использовал ExoMedia (который является интерфейсом для ExoPlayer, но имеет те же функции, что и mediaPlayer)

* Сторона сервера

После использования ExoMedia я начал что-то замечать: когда я искал точку, которая еще не загружена, она воспроизводилась из этой части в течение очень небольшой доли времени, Может быть, 50 миллисекунд, поэтому я начал копаться и обнаружил следующее.

Когда сервер получает запрос с Range , сервер будет искать от, а затем отправлять ответ с данными [From, From + Chunk] .

My Chunk был равен 8192, при увеличении части чанка, я мог заметить, что песня воспроизводилась для больше . Поэтому вместо отправки [From, From + Chunk] и ожидания ExoMedia , чтобы запросить следующую часть.

Я отправил весь [From, End песни]. И это исправило мою ошибку. .

...