ffmpeg RTP拉取PCM音频流C代码

可以使用FFmpeg的C API来实现RTP拉取PCM音频流的功能。以下是一个简单的示例代码：

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <stdint.h>
#include <unistd.h>
#include <pthread.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <libavutil/avutil.h>
#include <libavformat/avformat.h>
#include <libavcodec/avcodec.h>

#define RTP_HEADER_SIZE 12

typedef struct {
    AVFormatContext *fmt_ctx;
    AVCodecContext *codec_ctx;
    AVPacket *pkt;
    int audio_stream_index;
    int sockfd;
    struct sockaddr_in addr;
} RTPContext;

static void *recv_rtp_packets(void *arg)
{
    RTPContext *ctx = (RTPContext *)arg;
    uint8_t buffer[4096];
    int n;

    while (1) {
        n = recvfrom(ctx->sockfd, buffer, sizeof(buffer), 0, NULL, NULL);
        if (n <= 0) {
            break;
        }
        av_packet_from_data(ctx->pkt, buffer + RTP_HEADER_SIZE, n - RTP_HEADER_SIZE);
        avcodec_send_packet(ctx->codec_ctx, ctx->pkt);
        while (avcodec_receive_frame(ctx->codec_ctx, ctx->fmt_ctx->streams[ctx->audio_stream_index]->codecpar) == 0) {
            // 处理音频帧
        }
    }

    return NULL;
}

int main(int argc, char *argv[])
{
    if (argc < 3) {
        fprintf(stderr, "Usage: %s <ip_address> <port>\n", argv[0]);
        exit(1);
    }

    av_register_all();
    avformat_network_init();

    RTPContext ctx = {0};
    int ret;

    // 打开RTP流
    avformat_open_input(&ctx.fmt_ctx, "rtp://", NULL, NULL);
    av_dict_set(&ctx.fmt_ctx->metadata, "rtpflags", "listen", 0);
    av_dict_set(&ctx.fmt_ctx->metadata, "protocol_whitelist", "udp,rtp", 0);
    av_dict_set(&ctx.fmt_ctx->metadata, "listen_timeout", "0", 0);

    // 添加音频流
    AVStream *audio_stream = avformat_new_stream(ctx.fmt_ctx, NULL);
    audio_stream->codecpar->codec_type = AVMEDIA_TYPE_AUDIO;
    audio_stream->codecpar->codec_id = AV_CODEC_ID_PCM_S16LE;
    audio_stream->codecpar->channels = 1;
    audio_stream->codecpar->sample_rate = 8000;
    avformat_write_header(ctx.fmt_ctx, NULL);

    // 打开解码器
    ctx.codec_ctx = avcodec_alloc_context3(NULL);
    avcodec_parameters_to_context(ctx.codec_ctx, audio_stream->codecpar);
    avcodec_open2(ctx.codec_ctx, avcodec_find_decoder(AV_CODEC_ID_PCM_S16LE), NULL);

    // 创建RTP套接字
    ctx.sockfd = socket(AF_INET, SOCK_DGRAM, 0);
    ctx.addr.sin_family = AF_INET;
    ctx.addr.sin_addr.s_addr = inet_addr(argv[1]);
    ctx.addr.sin_port = htons(atoi(argv[2]));
    bind(ctx.sockfd, (struct sockaddr *)&ctx.addr, sizeof(ctx.addr));

    // 创建AVPacket
    ctx.pkt = av_packet_alloc();

    // 启动接收线程
    pthread_t recv_thread;
    pthread_create(&recv_thread, NULL, recv_rtp_packets, &ctx);

    // 等待接收线程结束
    pthread_join(recv_thread, NULL);

    // 清理资源
    av_packet_free(&ctx.pkt);
    avcodec_free_context(&ctx.codec_ctx);
    avformat_close_input(&ctx.fmt_ctx);
    avformat_network_deinit();

    return 0;
}

代码中使用了FFmpeg的C API来实现RTP流的接收和音频解码，需要注意的是，音频帧的处理需要在解码器解码后进行。在代码中使用了一个线程来接收RTP数据包，当收到数据包后，将其存入一个AVPacket中，然后送给解码器进行解码。解码器每次解码出一帧音频数据后，将其存储在AVCodecParameters结构体中，可以通过该结构体的成员变量获取音频数据的信息。可以根据需要修改音频流的参数和输出方式。