发布与推流

rtc_create_local_track  →  rtc_set_keyframe_request_callback  →  rtc_publish_local_track
        →  循环 rtc_write_sample  →  rtc_unpublish_local_track  →  rtc_destroy_local_track

void* rtc_create_local_track(int codec);

void rtc_destroy_local_track(void* track_handle);

int rtc_publish_local_track(void* handle, void* track_handle, rtc_publish_options_t* options);

int rtc_unpublish_local_track(void* handle, void* track_handle);

int rtc_write_sample(void* track_handle, uint8_t* data, int length, uint32_t samples);

typedef void (*rtc_keyframe_request_callback)(void* context, const char* track_id);
void rtc_set_keyframe_request_callback(void* track_handle,
                                       rtc_keyframe_request_callback callback,
                                       void* context);

static void on_keyframe_request(void* ctx, const char* track_id) {
    // 不要在这里做重活，置个标志让编码线程下一帧编 IDR
    encoder_request_idr(track_id);
}

void* video = rtc_create_local_track(RTC_CODEC_H264);
rtc_set_keyframe_request_callback(video, on_keyframe_request, NULL);
rtc_publish_local_track(rtc, video, &vopts);   // 设置完回调再发布

// 1. 创建轨道
void* video = rtc_create_local_track(RTC_CODEC_H264);
void* audio = rtc_create_local_track(RTC_CODEC_OPUS);

// 2. 视频轨道注册关键帧请求回调（发布前）
rtc_set_keyframe_request_callback(video, on_keyframe_request, NULL);

// 3. 配置发布选项
rtc_publish_options_t vopts = {0};
strcpy(vopts.desc, "camera");
vopts.width = 1280; vopts.height = 720; vopts.fps = 30;

rtc_publish_options_t aopts = {0};
strcpy(aopts.desc, "microphone");
aopts.sample_rate = 48000; aopts.channel_count = 2;

// 4. 发布
rtc_publish_local_track(rtc, video, &vopts);
rtc_publish_local_track(rtc, audio, &aopts);

// 5. 推数据
rtc_write_sample(video, h264_frame, h264_len, 3000);  // 30fps
rtc_write_sample(audio, opus_frame, opus_len, 960);   // 20ms

// 6. 收尾
rtc_unpublish_local_track(rtc, video);
rtc_unpublish_local_track(rtc, audio);
rtc_destroy_local_track(video);
rtc_destroy_local_track(audio);