Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.

Periksa kodenya

Di bagian ini, Anda memeriksa pustaka Java dan kode pengujian, dan mempelajari cara menggunakan alat dari perpustakaan dalam kode Anda sendiri.

Pustaka parser aliran video Kinesis berisi alat-alat berikut:

StreamingMkvReader

Kelas ini membaca MKV elemen tertentu dari aliran dengan cara non-pemblokiran.

Contoh kode berikut (fromFragmentMetadataVisitorTest) menunjukkan cara membuat dan menggunakan a Streaming MkvReader untuk mengambil MkvElement objek dari aliran masukan yang disebutinputStream:

StreamingMkvReader mkvStreamReader =
                StreamingMkvReader.createDefault(new InputStreamParserByteSource(inputStream));
        while (mkvStreamReader.mightHaveNext()) {
            Optional<MkvElement> mkvElement = mkvStreamReader.nextIfAvailable();
            if (mkvElement.isPresent()) {
                mkvElement.get().accept(fragmentVisitor);
                ...
                }
            }
        }

FragmentMetadataVisitor

Kelas ini mengambil metadata untuk fragmen (elemen media) dan melacak aliran data individual yang berisi informasi media, seperti data pribadi codec, lebar piksel, atau tinggi piksel.

Contoh kode berikut (dari FragmentMetadataVisitorTest file) menunjukkan cara menggunakan FragmentMetadataVisitor untuk mengambil data dari MkvElement objek:

FragmentMetadataVisitor fragmentVisitor = FragmentMetadataVisitor.create();
        StreamingMkvReader mkvStreamReader =
                StreamingMkvReader.createDefault(new InputStreamParserByteSource(in));
        int segmentCount = 0;
        while(mkvStreamReader.mightHaveNext()) {
            Optional<MkvElement> mkvElement = mkvStreamReader.nextIfAvailable();
            if (mkvElement.isPresent()) {
                mkvElement.get().accept(fragmentVisitor);
                if (MkvTypeInfos.SIMPLEBLOCK.equals(mkvElement.get().getElementMetaData().getTypeInfo())) {
                    MkvDataElement dataElement = (MkvDataElement) mkvElement.get();
                    Frame frame = ((MkvValue<Frame>)dataElement.getValueCopy()).getVal();
                    MkvTrackMetadata trackMetadata = fragmentVisitor.getMkvTrackMetadata(frame.getTrackNumber());
                    assertTrackAndFragmentInfo(fragmentVisitor, frame, trackMetadata);
                }
                if (MkvTypeInfos.SEGMENT.equals(mkvElement.get().getElementMetaData().getTypeInfo())) {
                    if (mkvElement.get() instanceof MkvEndMasterElement) {
                        if (segmentCount < continuationTokens.size()) {
                            Optional<String> continuationToken = fragmentVisitor.getContinuationToken();
                            Assert.assertTrue(continuationToken.isPresent());
                            Assert.assertEquals(continuationTokens.get(segmentCount), continuationToken.get());
                        }
                        segmentCount++;
                    }
                }
            }

        }

Contoh sebelumnya menunjukkan pola pengkodean berikut:

Untuk digunakan FragmentMetadataVisitor dalam proyek Anda, berikan MkvElement objek ke pengunjung menggunakan accept metode mereka:

mkvElement.get().accept(fragmentVisitor);

OutputSegmentMerger

Kelas ini menggabungkan metadata dari trek yang berbeda dalam aliran menjadi aliran dengan segmen tunggal.

Contoh kode berikut (dari FragmentMetadataVisitorTest file) menunjukkan cara menggunakan OutputSegmentMerger untuk menggabungkan metadata track dari array byte yang disebut: inputBytes

FragmentMetadataVisitor fragmentVisitor = FragmentMetadataVisitor.create();

ByteArrayOutputStream outputStream = new ByteArrayOutputStream();

OutputSegmentMerger outputSegmentMerger =
    OutputSegmentMerger.createDefault(outputStream);

CompositeMkvElementVisitor compositeVisitor =
    new TestCompositeVisitor(fragmentVisitor, outputSegmentMerger);

final InputStream in = TestResourceUtil.getTestInputStream("output_get_media.mkv");

StreamingMkvReader mkvStreamReader =
    StreamingMkvReader.createDefault(new InputStreamParserByteSource(in));
    
while (mkvStreamReader.mightHaveNext()) {
    Optional<MkvElement> mkvElement = mkvStreamReader.nextIfAvailable();
    if (mkvElement.isPresent()) {
        mkvElement.get().accept(compositeVisitor);
    if (MkvTypeInfos.SIMPLEBLOCK.equals(mkvElement.get().getElementMetaData().getTypeInfo())) {
        MkvDataElement dataElement = (MkvDataElement) mkvElement.get();
        Frame frame = ((MkvValue<Frame>) dataElement.getValueCopy()).getVal();
        Assert.assertTrue(frame.getFrameData().limit() > 0);
        MkvTrackMetadata trackMetadata = fragmentVisitor.getMkvTrackMetadata(frame.getTrackNumber());
        assertTrackAndFragmentInfo(fragmentVisitor, frame, trackMetadata);
    }
}

Contoh sebelumnya menunjukkan pola pengkodean berikut:

KinesisVideoExample

Ini adalah contoh aplikasi yang menunjukkan cara menggunakan pustaka parser aliran video Kinesis.

Kelas ini melakukan operasi berikut:

Hapus dan buat ulang aliran

Contoh kode berikut (dari StreamOps.java file) menghapus aliran video Kinesis yang diberikan:

//Delete the stream
amazonKinesisVideo.deleteStream(new DeleteStreamRequest().withStreamARN(streamInfo.get().getStreamARN()));
            

Contoh kode berikut (dari StreamOps.java file) membuat aliran video Kinesis dengan nama yang ditentukan:

amazonKinesisVideo.createStream(new CreateStreamRequest().withStreamName(streamName)
.withDataRetentionInHours(DATA_RETENTION_IN_HOURS)
.withMediaType("video/h264"));

Panggilan PutMedia

Contoh kode berikut (dari PutMediaWorker.java file) memanggil PutMediaaliran:

 putMedia.putMedia(new PutMediaRequest().withStreamName(streamName)
.withFragmentTimecodeType(FragmentTimecodeType.RELATIVE)
.withProducerStartTimestamp(new Date())
.withPayload(inputStream), new PutMediaAckResponseHandler() {
...
});

Panggilan GetMedia

Contoh kode berikut (dari GetMediaWorker.java file) memanggil GetMediaaliran:

GetMediaResult result = videoMedia.getMedia(new GetMediaRequest().withStreamName(streamName).withStartSelector(startSelector));

Parse hasilnya GetMedia

Bagian ini menjelaskan cara menggunakanStreamingMkvReader, FragmentMetadataVisitor dan CompositeMkvElementVisitor mengurai, menyimpan ke file, dan mencatat data yang dikembalikan. GetMedia

Baca output GetMedia dengan StreamingMkvReader

Contoh kode berikut (dari GetMediaWorker.java file) membuat StreamingMkvReader dan menggunakannya untuk mengurai hasil dari GetMediaoperasi:

StreamingMkvReader mkvStreamReader = StreamingMkvReader.createDefault(new InputStreamParserByteSource(result.getPayload()));
log.info("StreamingMkvReader created for stream {} ", streamName);
try {
    mkvStreamReader.apply(this.elementVisitor);
} catch (MkvElementVisitException e) {
    log.error("Exception while accepting visitor {}", e);
}

Dalam contoh kode sebelumnya, StreamingMkvReader mengambil MKVElement objek dari muatan hasil. GetMedia Pada bagian selanjutnya, elemen diteruskan ke aFragmentMetadataVisitor.

Ambil fragmen dengan FragmentMetadataVisitor

Contoh kode berikut (dari KinesisVideoExample.java dan StreamingMkvReader.java file) membuat fileFragmentMetadataVisitor. MkvElementObjek yang diulang oleh kemudian StreamingMkvReader diteruskan ke pengunjung menggunakan accept metode ini.

dariKinesisVideoExample.java:

FragmentMetadataVisitor fragmentMetadataVisitor = FragmentMetadataVisitor.create();
                        

dariStreamingMkvReader.java:

if (mkvElementOptional.isPresent()) {
    //Apply the MkvElement to the visitor
    mkvElementOptional.get().accept(elementVisitor);
        }

Log elemen dan tulis ke file

Contoh kode berikut (dari KinesisVideoExample.java file) membuat objek berikut dan mengembalikannya sebagai bagian dari nilai kembali GetMediaProcessingArguments fungsi:

//A visitor used to log as the GetMedia stream is processed.
    LogVisitor logVisitor = new LogVisitor(fragmentMetadataVisitor);

    //An OutputSegmentMerger to combine multiple segments that share track and ebml metadata into one
    //mkv segment.
    OutputStream fileOutputStream = Files.newOutputStream(Paths.get("kinesis_video_example_merged_output2.mkv"),
            StandardOpenOption.WRITE, StandardOpenOption.CREATE);
    BufferedOutputStream outputStream = new BufferedOutputStream(fileOutputStream);
    OutputSegmentMerger outputSegmentMerger = OutputSegmentMerger.createDefault(outputStream);

    //A composite visitor to encapsulate the three visitors.
    CompositeMkvElementVisitor mkvElementVisitor =
            new CompositeMkvElementVisitor(fragmentMetadataVisitor, outputSegmentMerger, logVisitor);

    return new GetMediaProcessingArguments(outputStream, logVisitor, mkvElementVisitor);

Argumen pemrosesan media kemudian diteruskan keGetMediaWorker, yang pada gilirannya diteruskan keExecutorService, yang membawa pekerja pada utas terpisah:

GetMediaWorker getMediaWorker = GetMediaWorker.create(getRegion(),
        getCredentialsProvider(),
        getStreamName(),
        new StartSelector().withStartSelectorType(StartSelectorType.EARLIEST),
        amazonKinesisVideo,
        getMediaProcessingArgumentsLocal.getMkvElementVisitor());
executorService.submit(getMediaWorker);