快速开始

#include "librtc.h"
#include <stdio.h>
#include <string.h>
#include <unistd.h>

// 连接状态回调：0=连接中 1=已连接 2=已断开 3=重连中
static void on_connection_state(void* ctx, int state) {
    const char* names[] = {"connecting", "connected", "disconnected", "reconnecting"};
    printf("[conn] %s\n", names[state]);
}

// 用户事件回调：0=加入 1=离开
static void on_user_event(void* ctx, const char* uid, int event_type) {
    printf("[user] %s %s\n", uid, event_type == 0 ? "join" : "leave");
}

// 轨道数据回调：所有已订阅轨道的编码数据都从这里出来
// 注意：data 指针只在回调期间有效，需要留存必须立刻拷贝
static void on_track_sample(void* ctx,
                            rtc_user_info_t* user, rtc_track_info_t* track,
                            uint8_t* data, int len,
                            int64_t timestamp, int64_t duration) {
    char filename[256];
    const char* ext = (track->kind == 0) ? "opus" : "h264";  // 0=音频 1=视频
    snprintf(filename, sizeof(filename), "%s_%s.%s", user->uid, track->track_id, ext);

    FILE* fp = fopen(filename, "ab");
    if (fp) {
        fwrite(data, 1, len, fp);
        fclose(fp);
    }
}

int main(int argc, char** argv) {
    const char* token = argv[1];

    // 1. 创建实例
    void* rtc = rtc_create();

    // 2. 设置回调（必须在加入频道前设置，否则会漏掉早期事件）
    rtc_set_connection_callback(rtc, on_connection_state, NULL);
    rtc_set_user_event_callback(rtc, on_user_event, NULL);
    rtc_set_track_sample_callback(rtc, on_track_sample, NULL);

    // 3. 开启自动订阅：新用户发布的音视频轨道会被自动订上，无需手动 subscribe
    rtc_set_auto_subscribe(rtc, 1, 1);

    // 4. 同步加入频道，10 秒超时
    int ret = rtc_join_channel_sync(rtc, token, 10000);
    if (ret != RTC_OK) {
        printf("join failed: %d\n", ret);
        rtc_destroy(rtc);
        return 1;
    }
    printf("joined\n");

    // 5. 保持运行，媒体数据持续从 on_track_sample 回调进来
    sleep(30);

    // 6. 清理
    rtc_leave_channel(rtc);
    rtc_destroy(rtc);
    return 0;
}

gcc -Wall -I/path/to/sdk -o subscriber main.c -L/path/to/sdk -lrtc -lpthread -lm
LD_LIBRARY_PATH=/path/to/sdk ./subscriber "your_token_here"

#include "librtc.h"
#include <stdio.h>
#include <string.h>

int main(int argc, char** argv) {
    const char* token = argv[1];

    void* rtc = rtc_create();
    if (rtc_join_channel_sync(rtc, token, 10000) != RTC_OK) {
        rtc_destroy(rtc);
        return 1;
    }

    // 1. 创建本地轨道（按编码格式创建）
    void* video = rtc_create_local_track(RTC_CODEC_H264);
    void* audio = rtc_create_local_track(RTC_CODEC_OPUS);

    // 2. 配置发布选项：视频必填 desc/width/height/fps，音频必填 desc/sample_rate/channel_count
    rtc_publish_options_t vopts = {0};
    strcpy(vopts.desc, "camera");
    vopts.width   = 1280;
    vopts.height  = 720;
    vopts.fps     = 30;
    vopts.bitrate = 2000000;   // 2 Mbps，可选

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

    // 3. 发布
    if (rtc_publish_local_track(rtc, video, &vopts) != RTC_OK) { /* 处理失败 */ }
    if (rtc_publish_local_track(rtc, audio, &aopts) != RTC_OK) { /* 处理失败 */ }

    // 4. 循环推数据。第 4 个参数是 RTP 时间戳增量：
    //    H264/H265 时钟 90000，30fps 每帧 3000；OPUS 时钟 48000，20ms 每帧 960
    while (running) {
        rtc_write_sample(video, h264_frame, h264_len, 3000);
        rtc_write_sample(audio, opus_frame, opus_len, 960);
    }

    // 5. 清理：先取消发布，再销毁轨道，最后销毁实例
    rtc_unpublish_local_track(rtc, video);
    rtc_unpublish_local_track(rtc, audio);
    rtc_destroy_local_track(video);
    rtc_destroy_local_track(audio);
    rtc_leave_channel(rtc);
    rtc_destroy(rtc);
    return 0;
}

rtc_set_log_level(RTC_LOG_DEBUG);   // 0=DEBUG 1=INFO 2=WARN 3=ERROR