Windows SDK

extern "C" liteav::ITXRealtimeASR* TXRealtimeASRCreate();
extern "C" void TXRealtimeASRDestroy(liteav::ITXRealtimeASR* instance);

#include "tx_realtime_asr.h"
#include <atomic>
#include <string>

using namespace liteav;

// 1. 实现监听器
class MyASRListener : public TXRealtimeASRListener {
 public:
  // 绑定当前会话实例。该示例一次仅支持一个转录会话。
  bool bindASR(ITXRealtimeASR* asr) {
    ITXRealtimeASR* expected = nullptr;
    return asr_.compare_exchange_strong(expected, asr);
  }

  // 由业务侧在用户结束录音/转录时调用。
  void stop() {
    ITXRealtimeASR* asr = asr_.load();
    if (asr != nullptr) {
      // 异步停止。资源会在停止或错误回调中释放。
      asr->stopRealtimeASR();
    }
  }

  void onRealtimeASRStarted(const char* voiceId) override {
    // 转录会话已开启，voiceId 为识别会话 ID
  }

  void onReceiveRealtimeASRMessage(
      const TXRealtimeASRMessage& message) override {
    if (message.isCompleted) {
      // 稳态结果：某句话已说完，sourceText 为最终识别文本
    } else {
      // 中间结果：正在识别中，sourceText 为实时暂存文本
    }

    // 可获取该消息在音频流中的时间区间（毫秒），-1 表示未知
    int start = message.startTime;
    int end = message.endTime;
  }

  void onRealtimeASRStopped() override {
    // 转录已正常停止，此时再释放资源。
    releaseASR();
  }

  void onRealtimeASRError(
      int errorCode, const char* errorMsg) override {
    // 转录出错，errorCode 非 0 表示异常。
    // 可在此记录 errorCode 与 errorMsg。
    releaseASR();
  }

  void onRealtimeASRVolume(int volume) override {
    // 实时音量，volume 取值 [0, 100]
  }

 private:
  void releaseASR() {
    // 防止错误回调与停止回调先后触发时重复销毁。
    ITXRealtimeASR* asr = asr_.exchange(nullptr);
    if (asr == nullptr) {
      return;
    }

    asr->removeListener(this);
    TXRealtimeASRDestroy(asr);
  }

 private:
  std::atomic<ITXRealtimeASR*> asr_{nullptr};
};

static MyASRListener g_listener;

void RunASR() {
  // 2. 创建实例
  ITXRealtimeASR* asr = TXRealtimeASRCreate();
  if (asr == nullptr) {
    return;
  }

  // 3. 设置监听器。监听器对象需在整个会话期间保持有效。
  if (!g_listener.bindASR(asr)) {
    // 已有未结束的会话，不允许重复创建。
    TXRealtimeASRDestroy(asr);
    return;
  }
  asr->addListener(&g_listener);

  // 4. 配置参数并启动
  TXRealtimeASRParams params;
  params.sdkAppId = "1400000000";         // TRTC 应用 ID
  params.userSig = "your_user_sig";       // 服务端下发的用户签名
  params.voiceId = "uuid-xxxx-xxxx-xxxx"; // 每次调用建议重新生成 UUID
  params.sourceLanguage = "zh";           // "zh" / "en"，留空为自动识别
  params.enableCustomCapture = false;     // 是否启用自定义音频采集
  asr->startRealtimeASR(params);

  // 5. 可选：自定义采集模式。
  // const int16_t pcm[160]; // 16k、单声道、16bit 采样
  // asr->feedPcmData(pcm, 160, 16000, 1);

  // 不要在此处立即停止或销毁实例。
}

// 6. 例如用户点击“停止转录”时调用。
void StopASR() {
  g_listener.stop();

{ "api": "<接口名>", "params": { ... } }

const char* json =
    R"({"api":"setExtraParams","params":{"extraRequestParams":"engine_model_type=bigmodel","clientDenoiseStrategy":1}})";
asr->callExperimentalAPI(json);