1

我正在使用 AWS Kinesis Video Stream 服务来获取我的视频记录。因此，由于 Kinesis Video Stream 片段限制，事实证明我一次请求最多只能检索约 30 分钟的视频。我打算检索一个 2 小时的视频。

所以我循环请求并将所有 4 个响应放入 List 中InputStream，然后我将它们变成SequenceInputStream，因为我试图将它们全部链接在一起。

但是，当我成功将它们上传到 S3 存储桶并尝试从那里下载时。它显示我文件已损坏。我研究过，SequenceInputStream但似乎我的设计还可以。

此外，如果我延长我的视频长度，假设我有 24 InputStream，并且我将它们全部链接到一个SequenceInputStream，它将SSL Socket Exception: Connection Reset在我readAllBytes对序列输入流运行操作时遇到 。

有什么方法可以实现我想要的或我的代码中的错误导致这种情况？

这是我的源代码：

private String downloadMedia(Request request, JSONObject response, JSONObject metaData, Date startDate, Date endDate) throws Exception {
        long duration  = endDate.getTime() - startDate.getTime();
        long durationInMinutes = TimeUnit.MILLISECONDS.toMinutes(duration);
        long intervalsCount = durationInMinutes / 30;

        ArrayList<GetClipResult> getClipResults = new ArrayList<>();

        for (int i = 0; i < intervalsCount; i++){
            Media currentMedia = constructMediaAfterIntervalsBreakdown(metaData, request, startDate, endDate);

            String deviceName = metaData.getString("name") + "_" + request.getId();
            Stream stream = getStreamByName(name, request.getId());

            String endPoint = getDataEndpoint(stream.getStreamName());
            GetClipResult clipResult = downloadMedia(currentMediaDto, endPoint, stream.getStreamName());
            if(clipResult != null){
                getClipResults.add(clipResult);
            }

            startDate = currentMediaDto.getEndTime();
        }

        //Get presigned URL from S3 service response
        String url = response.getJSONArray("data").getJSONObject(0).getJSONArray("parts").getJSONObject(0).getString("url");

        if (getClipResults.size() > 0) {
            Vector<InputStream> inputStreams = new Vector<>();
            for (GetClipResult clipResult : getClipResults){
                InputStream videoStream = clipResult.getPayload();
                inputStreams.add(videoStream);
            }
            Enumeration<InputStream> inputStreamEnumeration = inputStreams.elements();;
            SequenceInputStream sequenceInputStream = new SequenceInputStream(inputStreamEnumeration);
            if (sequenceInputStream.available() > 0){
                sequenceInputStream.readAllBytes();
                byte[] bytes = sequenceInputStream.readAllBytes();
                String message = uploadFileUsingSecureUrl(url, bytes, metaData);
                return message;
            }
        }
        return "failed";
    }

编辑：我遇到了几个名为Xugglerand的包FFMPEG，但是他们中的大多数都是从磁盘（有路径）获取视频文件，但就我而言，没有任何视频文件，因为我没有将它们下载到本地，他们仅存在于运行时，将在连接后稍后上传到 S3。

感谢任何帮助！谢谢！

4

1 回答 1

0

所以最后我只是下载了剪辑，在运行时将其保存到磁盘，使用合并它们mp4parser并上传到 S3。之后我只是删除了我磁盘上的那些。

如果有人对代码感到好奇，它来自https://github.com/sannies/mp4parser/blob/master/examples/src/main/java/com/googlecode/mp4parser/AppendExample.java

谢谢你。

于 2021-12-28T12:05:34.237 回答