ffmpeg 中read_packet怎么正确使用fifo读数据 给个示例

在 FFmpeg 中，可以使用 AVFifoBuffer 结构体实现 FIFO 缓冲区的功能，然后使用 av_read_frame 函数读取数据包，并将数据包写入 FIFO 缓冲区中。下面是一个示例代码：

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <libavcodec/avcodec.h>
#include <libavformat/avformat.h>
#include <libavutil/avutil.h>

#define MAX_AUDIO_FRAME_SIZE 192000

int main(int argc, char *argv[]) {
    AVFormatContext *pFormatCtx = NULL;
    int audioStream = -1;
    AVCodecContext *pCodecCtx = NULL;
    AVCodec *pCodec = NULL;
    AVPacket packet;
    AVFrame *pFrame = NULL;
    uint8_t *out_buffer = NULL;
    AVFifoBuffer *fifo_buffer = NULL;
    int out_buffer_size;
    int frame_count = 0;

    if (argc < 2) {
        printf("Usage: %s <input file>\n", argv[0]);
        return -1;
    }

    av_register_all();
    avformat_network_init();

    // 打开输入文件并读取文件头
    if (avformat_open_input(&pFormatCtx, argv[1], NULL, NULL) != 0) {
        printf("Error: could not open input file.\n");
        return -1;
    }

    // 获取流信息
    if (avformat_find_stream_info(pFormatCtx, NULL) < 0) {
        printf("Error: could not find stream information.\n");
        return -1;
    }

    // 查找音频流
    for (int i = 0; i < pFormatCtx->nb_streams; i++) {
        if (pFormatCtx->streams[i]->codecpar->codec_type == AVMEDIA_TYPE_AUDIO) {
            audioStream = i;
            break;
        }
    }

    if (audioStream == -1) {
        printf("Error: could not find audio stream.\n");
        return -1;
    }

    // 获取音频解码器
    pCodec = avcodec_find_decoder(pFormatCtx->streams[audioStream]->codecpar->codec_id);
    if (pCodec == NULL) {
        printf("Error: could not find audio decoder.\n");
        return -1;
    }

    // 打开音频解码器
    pCodecCtx = avcodec_alloc_context3(pCodec);
    if (avcodec_parameters_to_context(pCodecCtx, pFormatCtx->streams[audioStream]->codecpar) < 0) {
        printf("Error: could not copy codec parameters to decoder context.\n");
        return -1;
    }
    if (avcodec_open2(pCodecCtx, pCodec, NULL) < 0) {
        printf("Error: could not open audio decoder.\n");
        return -1;
    }

    // 初始化 FIFO 缓冲区
    fifo_buffer = av_fifo_alloc(MAX_AUDIO_FRAME_SIZE * 10);
    if (fifo_buffer == NULL) {
        printf("Error: could not allocate FIFO buffer.\n");
        return -1;
    }

    // 初始化音频帧
    pFrame = av_frame_alloc();
    if (pFrame == NULL) {
        printf("Error: could not allocate audio frame.\n");
        return -1;
    }

    // 计算音频数据的输出缓冲区大小
    out_buffer_size = av_samples_get_buffer_size(NULL, pCodecCtx->channels, MAX_AUDIO_FRAME_SIZE, pCodecCtx->sample_fmt, 0);
    out_buffer = (uint8_t *)av_malloc(out_buffer_size);
    if (out_buffer == NULL) {
        printf("Error: could not allocate output buffer.\n");
        return -1;
    }

    // 读取音频数据并写入 FIFO 缓冲区
    while (av_read_frame(pFormatCtx, &packet) >= 0) {
        if (packet.stream_index == audioStream) {
            // 解码音频数据
            int ret = avcodec_send_packet(pCodecCtx, &packet);
            while (ret >= 0) {
                ret = avcodec_receive_frame(pCodecCtx, pFrame);
                if (ret == AVERROR(EAGAIN) || ret == AVERROR_EOF) {
                    break;
                } else if (ret < 0) {
                    printf("Error: could not decode audio frame.\n");
                    return -1;
                }
                // 将解码后的音频数据写入 FIFO 缓冲区
                av_fifo_generic_write(fifo_buffer, pFrame->data[0], pFrame->linesize[0], NULL);
            }
        }
        av_packet_unref(&packet);
    }

    // 从 FIFO 缓冲区中读取数据
    while (av_fifo_size(fifo_buffer) >= out_buffer_size) {
        av_fifo_generic_read(fifo_buffer, out_buffer, out_buffer_size, NULL);
        // 处理读取到的音频数据
        frame_count++;
    }

    // 释放资源
    av_fifo_free(fifo_buffer);
    av_free(out_buffer);
    av_frame_free(&pFrame);
    avcodec_free_context(&pCodecCtx);
    avformat_close_input(&pFormatCtx);

    printf("Processed %d audio frames.\n", frame_count);
    return 0;
}

上述代码中，首先使用 av_read_frame 函数读取音频数据，并通过 av_fifo_generic_write 函数将解码后的音频数据写入 FIFO 缓冲区中。然后使用 av_fifo_generic_read 函数从 FIFO 缓冲区中读取数据，并进行后续处理。

需要注意的是，FIFO 缓冲区的大小应该足够大，以免因 FIFO 缓冲区空间不足而导致数据丢失。另外，FIFO 缓冲区的读写操作应该在不同的线程中进行，否则可能会导致死锁或竞争条件。