C++ SDK

#include <string.h>
#include <unistd.h>
#include <pthread.h>
#include <stdlib.h>
#include <ctime>
#include <string>
#include <iostream>
#include <vector>
#include <fstream>
#include <sys/time.h>
#include <errno.h>
#include "nlsClient.h"
#include "nlsEvent.h"
#include "nlsToken.h"
#include "speechTranscriberRequest.h"

#define FRAME_SIZE 3200
#define SAMPLE_RATE 16000

using namespace AlibabaNlsCommon; 
using AlibabaNls::NlsClient; 
using AlibabaNls::NlsEvent; 
using AlibabaNls::LogDebug; 
using AlibabaNls::LogInfo; 
using AlibabaNls::LogError;
using AlibabaNls::SpeechTranscriberRequest;

//自訂線程參數。
struct ParamStruct {
  std::string fileName;
  std::string appkey; 
  std::string token; 
};
//自訂事件回調參數。
struct ParamCallBack {
 public:
  ParamCallBack() {
    pthread_mutex_init(&mtxWord, NULL);
    pthread_cond_init(&cvWord, NULL);
  };
  ~ParamCallBack() {
    pthread_mutex_destroy(&mtxWord);
    pthread_cond_destroy(&cvWord);
  };

  int userId;
  char userInfo[8];
  pthread_mutex_t mtxWord;
  pthread_cond_t cvWord;
};

/**
 * 全域維護一個服務鑒權token和其對應的有效期間時間戳記，
 * 每次調用服務之前，首先判斷token是否已經到期，
 * 如果已經到期，則根據AccessKey ID和AccessKey Secret重建一個token，
 * 並更新這個全域的token和其有效期間時間戳記。
 *
 * 擷取Token具體操作，請參見：https://help.aliyun.com/document_detail/450514.html
 *
 * 注意：不要每次調用服務之前都重建新token，
 * 只需在token即將到期時重建即可。所有的服務並發可共用一個token。
 * Intelligent Speech Interaction的AccessKey ID、AccessKey Secret和AppKey的環境變數名：NLS_AK_ENV、NLS_SK_ENV、NLS_APPKEY_ENV
 */
std::string g_akId = "";
std::string g_akSecret = "";
std::string g_token = "";
long g_expireTime = -1;
int g_sync_timeout = 0;
struct timeval tv;
struct timeval tv1;

/**
 * 根據AccessKey ID和AccessKey Secret重建一個token，
 * 並擷取其有效期間時間戳記
 */
int generateToken(std::string akId, std::string akSecret,
                  std::string* token, long* expireTime) {
  NlsToken nlsTokenRequest;
  nlsTokenRequest.setAccessKeyId(akId); 
  nlsTokenRequest.setKeySecret(akSecret); 

  int ret = nlsTokenRequest.applyNlsToken();
  if (ret < 0) {
    // 擷取失敗原因。
    printf("generateToken Failed, error code:%d msg:%s\n",
        ret, nlsTokenRequest.getErrorMsg());
    return ret;
  }
  *token = nlsTokenRequest.getToken();
  *expireTime = nlsTokenRequest.getExpireTime();
  return 0;
}

/**
 * @brief 擷取sendAudio發送延時時間
 * @param dataSize 待發送資料大小
 * @param sampleRate 採樣率 16k/8K
 * @param compressRate 資料壓縮率，例如壓縮比為10:1的16k opus編碼，此時為10；
 *                     非壓縮資料則為1
 * @return 返回sendAudio之後需要sleep的時間
 * @note 對於8k pcm 編碼資料, 16位採樣，建議每發送1600位元組 sleep 100 ms.
         對於16k pcm 編碼資料, 16位採樣，建議每發送3200位元組 sleep 100 ms.
         對於其它編碼格式(OPUS)的資料, 由於傳遞給SDK的仍然是PCM編碼資料,
         按照SDK OPUS/OPU 資料長度限制, 需要每次發送640位元組 sleep 20ms.
 */
unsigned int getSendAudioSleepTime(int dataSize,
                                   int sampleRate,
                                   int compressRate) { 
  // 僅支援16位採樣
  const int sampleBytes = 16;     // 僅支援單通道
  const int soundChannel = 1;     // 當前採樣率，採樣位元下每秒採樣資料的大小。
  int bytes = (sampleRate * sampleBytes * soundChannel) / 8;     // 當前採樣率，採樣位元下每毫秒採樣資料的大小。
  int bytesMs = bytes / 1000;     // 待發送資料大小除以每毫秒採樣資料大小，以擷取sleep時間。
  int sleepMs = (dataSize * compressRate) / bytesMs;
  return sleepMs; 
}

/**
 * @brief 調用start(), 成功與雲端建立串連, sdk內部線程上報started事件
 * @param cbEvent 回調事件結構, 詳見nlsEvent.h
 * @param cbParam 回調自訂參數，預設為NULL, 可以根據需求自訂參數
 * @return
 */
void onTranscriptionStarted(NlsEvent* cbEvent, void* cbParam) {
  ParamCallBack* tmpParam = (ParamCallBack*)cbParam;
  // 示範如何列印/使用使用者自訂參數樣本。
  printf("onTranscriptionStarted: %d\n", tmpParam->userId);
  // 當前任務的task id，方便定位問題。
  printf("onTranscriptionStarted: status code=%d, task id=%s\n",
      cbEvent->getStatusCode(), cbEvent->getTaskId());

  // 擷取服務端返回的全部資訊
  //printf("onTranscriptionStarted: all response=%s\n", cbEvent->getAllResponse());

  // 通知發送線程start()成功, 可以繼續發送資料
  pthread_mutex_lock(&(tmpParam->mtxWord));
  pthread_cond_signal(&(tmpParam->cvWord));
  pthread_mutex_unlock(&(tmpParam->mtxWord));
} 

/**
 * @brief 服務端檢測到了一句話的開始, sdk內部線程上報SentenceBegin事件
 * @param cbEvent 回調事件結構, 詳見nlsEvent.h
 * @param cbParam 回調自訂參數，預設為NULL, 可以根據需求自訂參數
 * @return
*/
void onSentenceBegin(NlsEvent* cbEvent, void* cbParam) {
  ParamCallBack* tmpParam = (ParamCallBack*)cbParam;
  // 示範如何列印/使用使用者自訂參數樣本。
  printf("onSentenceBegin: %d\n", tmpParam->userId);
  printf("onSentenceBegin: status code=%d, task id=%s, index=%d, time=%d\n",
      cbEvent->getStatusCode(), cbEvent->getTaskId(),
      cbEvent->getSentenceIndex(), //句子編號，從1開始遞增。
      cbEvent->getSentenceTime() //當前已處理的音頻時間長度，單位：毫秒。
  );

  // 擷取服務端返回的全部資訊
  //printf("onTranscriptionStarted: all response=%s\n", cbEvent->getAllResponse());
}

/**
 * @brief 服務端檢測到了一句話結束, sdk內部線程上報SentenceEnd事件
 * @param cbEvent 回調事件結構, 詳見nlsEvent.h
 * @param cbParam 回調自訂參數，預設為NULL, 可以根據需求自訂參數
 * @return
*/
void onSentenceEnd(NlsEvent* cbEvent, void* cbParam) {
  ParamCallBack* tmpParam = (ParamCallBack*)cbParam;
  // 示範如何列印
  //使用使用者自訂參數樣本。
  printf("onSentenceEnd: %d\n", tmpParam->userId);
  printf("onSentenceEnd: status code=%d, task id=%s, index=%d, time=%d, begin_time=%d, result=%s\n",
      cbEvent->getStatusCode(),
      cbEvent->getTaskId(),
      cbEvent->getSentenceIndex(), //句子編號，從1開始遞增。
      cbEvent->getSentenceTime(), //當前已處理的音頻時間長度，單位：毫秒。
      cbEvent->getSentenceBeginTime(), // 對應的SentenceBegin事件的時間。
      cbEvent->getResult()    // 當前句子的完整識別結果。
  );
  // 擷取服務端返回的全部資訊
  //printf("onTranscriptionStarted: all response=%s\n", cbEvent->getAllResponse());
}

/**
 * @brief 識別結果發生了變化, sdk在接收到雲端返回到最新結果時,
 *        sdk內部線程上報ResultChanged事件
 * @param cbEvent 回調事件結構, 詳見nlsEvent.h
 * @param cbParam 回調自訂參數，預設為NULL, 可以根據需求自訂參數
 * @return
*/
void onTranscriptionResultChanged(NlsEvent* cbEvent, void* cbParam) {
  ParamCallBack* tmpParam = (ParamCallBack*)cbParam;
  // 示範如何列印/使用使用者自訂參數樣本。
  printf("onTranscriptionResultChanged: %d\n", tmpParam->userId);
  printf("onTranscriptionResultChanged: status code=%d, task id=%s, index=%d, time=%d, result=%s\n",
      cbEvent->getStatusCode(),
      cbEvent->getTaskId(),
      cbEvent->getSentenceIndex(), //句子編號，從1開始遞增。
      cbEvent->getSentenceTime(), //當前已處理的音頻時間長度，單位：毫秒。
      cbEvent->getResult()    // 當前句子的完整識別結果
  );
  // 擷取服務端返回的全部資訊
  //printf("onTranscriptionStarted: all response=%s\n", cbEvent->getAllResponse());
}

/**
 * @brief 服務端停止即時音頻流識別時, sdk內部線程上報Completed事件
 * @note 上報Completed事件之後，SDK內部會關閉識別串連通道. 
         此時調用sendAudio會返回負值, 請停止發送.
 * @param cbEvent 回調事件結構, 詳見nlsEvent.h
 * @param cbParam 回調自訂參數，預設為NULL, 可以根據需求自訂參數
 * @return
*/
void onTranscriptionCompleted(NlsEvent* cbEvent, void* cbParam) {
  ParamCallBack* tmpParam = (ParamCallBack*)cbParam;
  // 示範如何列印/使用使用者自訂參數樣本。
  printf("onTranscriptionCompleted: %d\n", tmpParam->userId);
  printf("onTranscriptionCompleted: status code=%d, task id=%s\n",
      cbEvent->getStatusCode(),
      cbEvent->getTaskId());
}

/**
 * @brief 識別過程(包含start(), sendAudio(), stop())發生異常時, sdk內部線程上報TaskFailed事件
 * @note 上報TaskFailed事件之後, SDK內部會關閉識別串連通道. 此時調用sendAudio會返回負值, 請停止發送
 * @param cbEvent 回調事件結構, 詳見nlsEvent.h
 * @param cbParam 回調自訂參數，預設為NULL, 可以根據需求自訂參數
 * @return
 */
void onTaskFailed(NlsEvent* cbEvent, void* cbParam) { 
  ParamCallBack* tmpParam = (ParamCallBack*)cbParam; 
  // 示範如何列印/使用使用者自訂參數樣本。
  printf("onTaskFailed: %d\n", tmpParam->userId); 
  printf("onTaskFailed: status code=%d, task id=%s, error message=%s\n", 
      cbEvent->getStatusCode(), 
      cbEvent->getTaskId(), 
      cbEvent->getErrorMessage()
  );     
  // 擷取服務端返回的全部資訊
  //printf("onTaskFailed: all response=%s\n", cbEvent->getAllResponse()); 
}

/**
 * @brief 識別結束或發生異常時，會關閉串連通道, sdk內部線程上報ChannelCloseed事件
 * @param cbEvent 回調事件結構, 詳見nlsEvent.h
 * @param cbParam 回調自訂參數，預設為NULL, 可以根據需求自訂參數
 * @return
 */
void onChannelClosed(NlsEvent* cbEvent, void* cbParam) {     
  ParamCallBack* tmpParam = (ParamCallBack*)cbParam;     
  // 示範如何列印/使用使用者自訂參數。
  printf("onChannelClosed: %d, %s\n", tmpParam->userId, tmpParam->userInfo); // 擷取服務端返回的全部資訊。
  printf("onChannelClosed: response=%s\n", cbEvent->getAllResponse());

  //通知發送線程, 最終識別結果已經返回, 可以調用stop()
  pthread_mutex_lock(&(tmpParam->mtxWord));
  pthread_cond_signal(&(tmpParam->cvWord));
  pthread_mutex_unlock(&(tmpParam->mtxWord));
}

/**
 * @brief 短連結模式下背景工作執行緒
 *        以 createTranscriberRequest           <----|
 *                   |                               |
 *           request->start()                        |
 *                   |                               |
 *           request->sendAudio()                    |
 *                   |                               |
 *           request->stop()                         |
 *                   |                               |
 *           收到onChannelClosed回調                 |
 *                   |                               |
 *           releaseTranscriberRequest(request)  ----|
 *        進行迴圈。
 */
void* pthreadFunction(void* arg) {
  int sleepMs = 0;
  int ret = 0;
  ParamCallBack *cbParam = NULL;

  //初始化自訂回調參數，以下兩變數僅作為樣本表示參數傳遞，在樣本中不起任何作用。
  //回調參數在堆中分配之後，請在退出線程前釋放。
  cbParam = new ParamCallBack();
  cbParam->userId = rand() % 100;
  strcpy(cbParam->userInfo, "User.");
  // 0：從自訂線程參數中擷取token，設定檔等參數。
  ParamStruct *tst = (ParamStruct *) arg; 
  if (tst == NULL) {
    printf("arg is not valid\n"); 
    delete cbParam;
    return NULL;
  } 
  // 開啟音頻檔案，擷取資料。
  std::ifstream fs;
  fs.open(tst->fileName.c_str(), std::ios::binary | std::ios::in);
  if (!fs) {
    printf("%s isn't exist..\n", tst->fileName.c_str());
    return NULL;
  }
  /*
   * 1. 建立即時音頻流識別SpeechTranscriberRequest對象
   */
  SpeechTranscriberRequest* request =
      NlsClient::getInstance()->createTranscriberRequest();
  if (request == NULL) {
    printf("createTranscriberRequest failed\n");
    delete cbParam;
    return NULL;
  }

  // 設定識別啟動回呼函數
  request->setOnTranscriptionStarted(onTranscriptionStarted, cbParam);
  // 設定識別結果變化回呼函數
  request->setOnTranscriptionResultChanged(onTranscriptionResultChanged, cbParam);
  // 設定語音轉寫結束回呼函數
  request->setOnTranscriptionCompleted(onTranscriptionCompleted, cbParam);
  // 設定一句話開始回呼函數
  request->setOnSentenceBegin(onSentenceBegin, cbParam);
  // 設定一句話結束回呼函數
  request->setOnSentenceEnd(onSentenceEnd, cbParam);
  // 設定異常識別回呼函數
  request->setOnTaskFailed(onTaskFailed, cbParam);
  // 設定識別通道關閉回呼函數
  request->setOnChannelClosed(onChannelClosed, cbParam);

  // 設定appKey。必填參數。
  request->setAppKey(tst->appkey.c_str());
  // 設定帳號校正token, 必填參數
  request->setToken(tst->token.c_str());

  // 設定音頻資料編碼格式。選擇性參數，目前支援PCM/OPUS，預設為PCM。
  request->setFormat("opus");
  // 設定音頻資料採樣率。選擇性參數，目前支援16000/8000。預設為16000。
  request->setSampleRate(SAMPLE_RATE);
  // 設定是否返回中間識別結果。選擇性參數，預設false。
  request->setIntermediateResult(true);
  // 設定是否在後處理中添加標點。選擇性參數，預設false。
  request->setPunctuationPrediction(true);
  // 設定是否在後處理中執行ITN。選擇性參數，預設false。
  request->setInverseTextNormalization(true);

  // 語音斷句檢測閾值，一句話之後靜音長度超過該值，即本句結束，合法參數範圍200ms～2000ms，預設值800ms。
  //request->setMaxSentenceSilence(800);
  // 語義斷句，啟動此功能語音斷句檢測功能不會生效。此功能必須開啟中間識別結果。
  //request->setSemanticSentenceDetection(true);
  // 定製語言模型id，可選。
  //request->setCustomizationId("TestId_123");
  // 定製泛熱詞id，可選。
  //request->setVocabularyId("TestId_456");
  // 用於傳遞某些定製化、進階參數設定，參數格式為JSON格式：{"key": "value"}。
  //request->setPayloadParam("{\"vad_model\": \"farfield\"}");

  struct timespec outtime;
  struct timeval now;
  /*
   * 2. start()為同步/非同步兩種操作，預設非同步。由於非同步模式通過回調判斷request是否成功運行有修改門檻，且部分舊版本為同步介面。
   *    為了能較為平滑的更新升級SDK，提供了同步/非同步兩種調用方式。
   *    非同步情況：預設未調用setSyncCallTimeout()的時候，start()調用立即返回，
   *            且傳回值並不代表request成功開始工作，需要等待返回started事件表示成功啟動，或返回TaskFailed事件表示失敗。
   *    同步情況：調用setSyncCallTimeout()設定同步介面的逾時時間，並啟動同步模式。start()調用後不會立即返回，
   *            直到內部得到成功(同時也會觸發started事件回調)或失敗(同時也會觸發TaskFailed事件回調)後返回。
   *            此方法方便舊版本SDK
   */
  ret = request->start();
  if (ret < 0) {
    printf("start() failed. may be can not connect server. please check network or firewalld\n");
    NlsClient::getInstance()->releaseTranscriberRequest(request); // start()失敗，釋放request對象。
    delete cbParam;
    return NULL;
  } else {
    if (g_sync_timeout == 0) {
      /*
       * 2.1. g_sync_timeout等於0，即預設未調用setSyncCallTimeout()，非同步方式調用start()
       *      需要等待返回started事件表示成功啟動，或返回TaskFailed事件表示失敗。
       * 
       * 等待started事件返回表示start()成功, 然後再發送音頻資料。
       * Voice Messaging Service器存在來不及處理當前請求的情況, 10s內不返回任何回調的問題,
       * 然後在10s後返回一個TaskFailed回調, 所以需要設定一個逾時機制。
       */
      // 等待started事件返回, 再發送
      printf("wait started callback.\n");
    
      // Voice Messaging Service器存在來不及處理當前請求, 10s內不返回任何回調的問題,
      // 然後在10s後返回一個TaskFailed回調, 所以需要設定一個逾時機制.
      gettimeofday(&now, NULL);
      outtime.tv_sec = now.tv_sec + 5;
      outtime.tv_nsec = now.tv_usec * 1000;
      pthread_mutex_lock(&(cbParam->mtxWord));
      if (ETIMEDOUT == pthread_cond_timedwait(&(cbParam->cvWord), &(cbParam->mtxWord), &outtime)) {
        printf("start timeout.\n");
        pthread_mutex_unlock(&(cbParam->mtxWord));
        request->cancel();
        NlsClient::getInstance()->releaseTranscriberRequest(request);
        delete cbParam;
        return NULL;
      }
      pthread_mutex_unlock(&(cbParam->mtxWord));
    } else {
      /*
       * 2.2. g_sync_timeout大於0，即調用了setSyncCallTimeout()，同步方式調用start()
       *      傳回值0即表示啟動成功。
       */
    }
  }

  while (!fs.eof()) {
    uint8_t data[FRAME_SIZE] = {0};
    fs.read((char *) data, sizeof(uint8_t) * FRAME_SIZE); 
    size_t nlen = fs.gcount();
    if (nlen <= 0) {
      continue;
    }

    /*
     * 3. 發送音頻資料: sendAudio為非同步作業, 返回負值表示發送失敗, 需要停止發送;
     *      返回大於0 為成功. 
     *      若希望用省流量的opus格式上傳音頻資料, 則第三參數傳入ENCODER_OPU/ENCODER_OPUS
     *
     * ENCODER_OPU/ENCODER_OPUS模式時, 會佔用一定的CPU進行音頻壓縮
     */
    ret = request->sendAudio(data, nlen, ENCODER_OPUS); 
    if (ret < 0) {
      // 發送失敗，退出迴圈資料發送。
      printf("send data fail.\n"); 
      break;
    } 

    /*
     * 實際使用中, 語音資料是即時的, 不用sleep控制速率, 直接發送即可.
     * 此處是用語音資料來自檔案的方式進行類比, 故發送時需要控制速率來類比真實錄音情境.
     */
    sleepMs = getSendAudioSleepTime(nlen, SAMPLE_RATE, 1); // 根據發送資料大小、採樣率、資料壓縮比來擷取sleep時間。
    /*
     * 語音資料發送延時控制, 實際使用中無需sleep.
     */
    usleep(sleepMs * 1000);
  } // while

  printf("sendAudio done.\n");
  //5: 關閉音頻檔案
  fs.close();
  
  /*
   * 4. 通知雲端資料發送結束.
   *    stop()為同步/非同步兩種操作，預設非同步。由於非同步模式通過回調判斷request是否成功運行有修改門檻，且部分舊版本為同步介面。
   *    為了能較為平滑的更新升級SDK，提供了同步/非同步兩種調用方式。
   *    非同步情況：預設未調用setSyncCallTimeout()的時候，stop()調用立即返回，
   *            且傳回值並不代表request成功結束，需要等待返回closed事件表示結束。
   *    同步情況：調用setSyncCallTimeout()設定同步介面的逾時時間，並啟動同步模式。stop()調用後不會立即返回，
   *            直到內部完成工作，並觸發closed事件回調後返回。
   *            此方法方便舊版本SDK。
   */
  ret = request->stop();
  if (ret == 0) {
      if (g_sync_timeout == 0) {
        /*
         * 4.1. g_sync_timeout等於0，即預設未調用setSyncCallTimeout()，非同步方式調用stop()
         *      需要等待返回closed事件表示成功停止，或返回TaskFailed事件表示失敗。
         * 
         * 等待closed事件返回表示stop()成功, 然後才可釋放。
         * Voice Messaging Service器存在來不及處理當前請求的情況, 10s內不返回任何回調的問題,
         * 然後在10s後返回一個TaskFailed回調, 所以需要設定一個逾時機制。
         */
        // 等待closed事件後再進行釋放, 否則會出現崩潰
        // 若調用了setSyncCallTimeout()啟動了同步調用模式, 則可以不等待closed事件。
        printf("wait closed callback.\n");
        
        // Voice Messaging Service器存在來不及處理當前請求, 10s內不返回任何回調的問題,
        // 然後在10s後返回一個TaskFailed回調, 錯誤資訊為:
        // "Gateway:IDLE_TIMEOUT:Websocket session is idle for too long time, the last directive is 'StopRecognition'!"
        // 所以需要設定一個逾時機制.
        gettimeofday(&now, NULL);
        outtime.tv_sec = now.tv_sec + 5;
        outtime.tv_nsec = now.tv_usec * 1000;
        // 等待closed事件後再進行釋放
        pthread_mutex_lock(&(cbParam->mtxWord));
        if (ETIMEDOUT == pthread_cond_timedwait(&(cbParam->cvWord), &(cbParam->mtxWord), &outtime)) {
          printf("stop timeout\n");
          pthread_mutex_unlock(&(cbParam->mtxWord));
          NlsClient::getInstance()->releaseTranscriberRequest(request);
          delete cbParam;
          return NULL;
        }
        pthread_mutex_unlock(&(cbParam->mtxWord));
      } else {
        /*
         * 4.2. g_sync_timeout大於0，即調用了setSyncCallTimeout()，同步方式調用stop()
         *      傳回值0即表示啟動成功。
         */
      }
  } else {
    printf("stop ret is %d\n", ret);
  }

  /*
   * 5. 完成所有工作後釋放當前請求。
   *    請在closed事件(確定完成所有工作)後再釋放, 否則容易破壞內部狀態機器, 會強制卸載正在啟動並執行請求。
   */
  NlsClient::getInstance()->releaseTranscriberRequest(request);
  delete cbParam;
  return NULL;
}

// 識別單個音頻資料
int speechTranscriberFile(const char* appkey) {
  //擷取當前系統時間戳，判斷token是否到期。
  std::time_t curTime = std::time(0);
  if (g_expireTime - curTime < 10) {
    printf("the token will be expired, please generate new token by AccessKey-ID and AccessKey-Secret.\n");
    if (generateToken(g_akId, g_akSecret, &g_token, &g_expireTime) < 0) {
      return -1;
    } 
  }

  ParamStruct pa;
  pa.token = g_token;
  pa.appkey = appkey;
  pa.fileName = "test0.wav";

  // 啟動一個背景工作執行緒，用於單次識別。
  pthread_t pthreadId;
  pthread_create(&pthreadId, NULL, &pthreadFunction, (void *)&pa);
  pthread_join(pthreadId, NULL);
  return 0;
}

//識別多個音頻資料
//SDK多線程指一個音頻資料來源對應一個線程，非一個音頻資料對應多個線程。
//範例程式碼為同時開啟2個線程識別2個檔案。
//免費使用者並發串連不能超過2個。
#define AUDIO_FILE_NUMS 2
#define AUDIO_FILE_NAME_LENGTH 32
int speechTranscriberMultFile(const char* appkey) {
  //擷取當前系統時間戳判斷token是否到期。
  std::time_t curTime = std::time(0);
  if (g_expireTime - curTime < 10) {
    printf("the token will be expired, please generate new token by AccessKey-ID and AccessKey-Secret.\n");
    if (generateToken(g_akId, g_akSecret, &g_token, &g_expireTime) < 0) {
      return -1;
    }
  }

  char audioFileNames[AUDIO_FILE_NUMS][AUDIO_FILE_NAME_LENGTH] = {
      "test0.wav", 
      "test1.wav"
  };
  ParamStruct pa[AUDIO_FILE_NUMS];
  for (int i = 0; i < AUDIO_FILE_NUMS; i ++) {
    pa[i].token = g_token; 
    pa[i].appkey = appkey;
    pa[i].fileName = audioFileNames[i]; 
  } 

  // 啟動2個背景工作執行緒，同時識別2個音頻檔案。
  std::vector<pthread_t> pthreadId(AUDIO_FILE_NUMS);
  for (int j = 0; j < AUDIO_FILE_NUMS; j++) {
    pthread_create(&pthreadId[j], NULL, &pthreadFunction, (void *)&(pa[j]));
  }
  for (int j = 0; j < AUDIO_FILE_NUMS; j++) {
    pthread_join(pthreadId[j], NULL);
  }
  return 0;
}

int main(int argc, char* argv[]) {
  printf("Usage: ./demo <your appkey> <your AccessKey ID> <your AccessKey Secret>\n");

  std::string appkey = getenv("NLS_APPKEY_ENV");
  g_akId = getenv("NLS_AK_ENV");
  g_akSecret = getenv("NLS_SK_ENV");

  // 根據需要設定SDK輸出日誌。可選。
  // 此處表示SDK日誌輸出至log-transcriber.txt。
  // LogDebug表示輸出所有層級日誌，支援LogDebug、LogInfo、LogWarning、LogError。
  // 400表示單個檔案400MB。50表示50個記錄檔迴圈記錄。
  int ret = NlsClient::getInstance()->setLogConfig(
      "log-transcriber", LogDebug, 400, 50);
  if (ret < 0) {
    printf("set log failed.\n");
    return -1;
  }

  // 設定運行環境需要的套介面地址類型, 預設為AF_INET
  // 必須在startWorkThread()前調用
  //NlsClient::getInstance()->setAddrInFamily("AF_INET");
    
  // 私人雲端部署的情況下可進行直連IP的設定
  // 必須在startWorkThread()前調用
  //NlsClient::getInstance()->setDirectHost("106.15.83.44");

  // 存在部分裝置在設定了dns後仍然無法通過SDK的dns擷取可用的IP,
  // 可調用此介面主動啟用系統的getaddrinfo來解決這個問題.
  //NlsClient::getInstance()->setUseSysGetAddrInfo(true);

  // g_sync_timeout等於0，即預設未調用setSyncCallTimeout()
  // 非同步方式調用
  //   start(): 需要等待返回started事件表示成功啟動，或返回TaskFailed事件表示失敗。
  //   stop(): 需要等待返回closed事件則表示完成此次互動。
  // 同步方式調用
  //   start()/stop() 調用返回即表示互動啟動/結束。
  if (g_sync_timeout > 0) {
    NlsClient::getInstance()->setSyncCallTimeout(g_sync_timeout);
  }

  // 啟動背景工作執行緒, 在建立請求和啟動前必須調用此函數, 可理解為對NlsClient的初始化
  // 入參為負時, 啟動當前系統中可用的核心數。
  // 200並發以下推薦入參為1, 更高並發入參推薦可看readme。
  NlsClient::getInstance()->startWorkThread(1);

  // 識別單個音頻資料
  speechTranscriberFile(appkey.c_str());
  // 並發識別多個音頻資料
  //speechTranscriberMultFile(appkey.c_str());

  // 所有工作完成，進程退出前，釋放nlsClient。
  // 請注意releaseInstance()非安全執行緒, 需要確認所有請求都停止工作才可釋放。
  NlsClient::releaseInstance();

  return 0;
}