实时说话人分离

-keepclasseswithmembernames class * { # 保持 native 方法不被混淆
native <methods>;
}
-keep public class com.tencent.aai.*

int appid = XXX;
int projectid = 0; //此参数固定为0；
String secretId = "XXX";

final AAIClient aaiClient;
try {
       /**直接鉴权**/
       // 1、签名鉴权类，sdk中给出了一个本地的鉴权类，您也可以自行实现CredentialProvider接口，在您的服务器上实现鉴权签名
       aaiClient = new AAIClient(MainActivity.this, appid, projectId, secretId ,new LocalCredentialProvider(secretKey));
   
   /**使用临时密钥鉴权
   * * (1).通过sts 获取到临时证书 （secretId secretKey token） ,此步骤应在您的服务器端实现，见https://cloud.tencent.com/document/product/598/33416
   *   (2).通过临时密钥调用接口
   * **/
        // aaiClient = new AAIClient(MainActivity.this, appid, projectId,"临时secretId", "临时secretKey","对应的token");

    // 2、初始化语音识别请求。
    final AudioRecognizeRequest audioRecognizeRequest = builder
           //设置数据源，数据源要求实现PcmAudioDataSource接口，您可以自己实现此接口来定制您的自定义数据源，例如从第三方推流中获
           .pcmAudioDataSource(new AudioRecordDataSource(false)) // 使用SDK内置录音器作为数据源,false:不保存音频
          .setEngineModelType("16k_zh_en_speaker") // 引擎参数
          .setFilterDirty(0)  // 0 ：默认状态 不过滤脏话 1：过滤脏话
          .setFilterModal(0) // 0 ：默认状态 不过滤语气词  1：过滤部分语气词 2:严格过滤
          .setFilterPunc(0) // 0 ：默认状态 不过滤句末的句号 1：滤句末的句号
          .setConvert_num_mode(1) //1：默认状态 根据场景智能转换为阿拉伯数字；0：全部转为中文数字。
          .setNeedvad(1) //0：关闭 vad，1：默认状态 开启 vad。语音时长超过一分钟需要开启,如果对实时性要求较高,并且时间较短的输入,建议关闭
                    // .setHotWordId("")//热词 id。用于调用对应的热词表，如果在调用语音识别服务时，不进行单独的热词 id 设置，自动生效默认热词；如果进行了单独的热词 id 设置，那么将生效单独设置的热词 id。
                    //.setCustomizationId("")//自学习模型 id。如果设置了该参数，那么将生效对应的自学习模型
           .build();

    // 3、初始化语音识别结果监听器。
    final AudioRecognizeResultListener audioRecognizeResultlistener = new AudioRecognizeResultListener() {
      @Override
      public void onSuccess(AudioRecognizeRequest request, String result) {
      }

      @Override
      public void onFailure(AudioRecognizeRequest request, final ClientException clientException, final ServerException serverException, String response) {
      }

      @Override
      public void onRawResponse(AudioRecognizeRequest request, String rawResponse) {
          // 解析逻辑可参考交付Demo源码
      }
    };
    
    // 4、自定义识别配置
    final AudioRecognizeConfiguration audioRecognizeConfiguration = new AudioRecognizeConfiguration.Builder()
          //分片默认40ms，可设置40-5000,必须为20的整倍数，
          //如果不是，sdk内将自动调整为20的整倍数，例如77将被调整为60，如果您不了解此参数不建议更改
          //.sliceTime(40)
          
          // 是否使能静音检测，
          .setSilentDetectTimeOut(false)
          
          // 静音检测超时停止录音可设置>2000ms，setSilentDetectTimeOut为true有效，超过指定时间没有说话将关闭识别；需要大于等于sliceTime，实际时间为sliceTime的倍数，如果小于sliceTime，则按sliceTime的时间为准
          .audioFlowSilenceTimeOut(5000)
          
           // 音量回调时间，需要大于等于sliceTime，实际时间为sliceTime的倍数，如果小于sliceTime，则按sliceTime的时间为准
          .minVolumeCallbackTime(80)
          
           //是否压缩音频。默认压缩，压缩音频有助于优化弱网或网络不稳定时的识别速度及稳定性
           //SDK历史版本均默认压缩且未提供配置开关，如无特殊需求，建议使用默认值
          .isCompress(true)
          .build();



    // 5、启动语音识别
    new Thread(new Runnable() {
        @Override
        public void run() {
            if (aaiClient!=null) {
                aaiClient.startAudioRecognize(audioRecognizeRequest,
                                              audioRecognizeResultlistener,
                                              audioRecognizeStateListener,
                                              audioRecognizeConfiguration);
            }
        }
    }).start();

} catch (ClientException e) {
    e.printStackTrace();
}

new Thread(new Runnable() {
    @Override
    public void run() {
        if (aaiClient!=null){
                //停止语音识别，等待最终识别结果
            aaiClient.stopAudioRecognize();
        }
    }
}).start();

new Thread(new Runnable() {
    @Override
    public void run() {
        if (aaiClient!=null){
                //取消语音识别，丢弃当前任务，丢弃最终结果
            aaiClient.cancelAudioRecognize();
        }
    }
}).start();

/**
* 签名函数：将原始字符串进行加密，具体的加密算法见以下说明。
* @param source 原文字符串
* @return 加密后返回的密文
*/
String getAudioRecognizeSign(String source);

public AAIClient(Context context, int appid, int projectId, String secreteId, AbsCredentialProvider credentialProvider) throws ClientException

try {
    AAIClient aaiClient = new AAIClient(context, appid, projectId, secretId, credentialProvider);
} catch (ClientException e) {
    e.printStackTrace();
}

aaiClient.release();

ClientConfiguration.setAudioRecognizeSliceTimeout(2000)
ClientConfiguration.setAudioRecognizeConnectTimeout(2000)
ClientConfiguration.setAudioRecognizeWriteTimeout(2000)

AudioRecognizeConfiguration audioRecognizeConfiguration = new AudioRecognizeConfiguration.Builder()
    .setSilentDetectTimeOut(true)// 是否开启静音检测，开启后检测到超时不说话将触发静音超时
    .audioFlowSilenceTimeOut(5000) // 静音检测超时时间
    .setSilentDetectTimeOutAutoStop(true) //触发静音超时后是否停止识别
    .minVolumeCallbackTime(80) // 音量回调时间
    .build();

AudioRecognizeStateListener audioRecognizeStateListener = new AudioRecognizeStateListener() {
    @Override
    public void onStartRecord(AudioRecognizeRequest audioRecognizeRequest) {
            // 开始录音
    }

    @Override
    public void onStopRecord(AudioRecognizeRequest audioRecognizeRequest) {
            // 结束录音
    }

    /**
     * 该方法已废弃
     *
     * @deprecated 建议使用 {@link #onVoiceDb(float db)}.
     */
    @Override
    public void onVoiceVolume(AudioRecognizeRequest audioRecognizeRequest, int i) {
            // 音量回调
    }

    @Override
    public void onVoiceDb(float volumeDb) {
        // 分贝回调
    }

        /**
      * 返回音频流，
      * 用于返回宿主层做录音缓存业务。
      * 由于方法跑在sdk线程上，这里多用于文件操作，宿主需要新开一条线程专门用于实现业务逻辑
      * new AudioRecordDataSource(true) 有效，否则不会回调该函数
      * @param audioDatas
      */
    @Override
    public void onNextAudioData(final short[] audioDatas, final int readBufferLength){
    }
    
    /**
    * 静音检测回调
    * 当设置AudioRecognizeConfiguration  setSilentDetectTimeOut为true时，如触发静音超时，将触发此回调
    * 当setSilentDetectTimeOutAutoStop 为true时，触发此回调的同时会停止本次识别，此时任务还未中止，仍然会等待最终识别结果
    */
    @Override
    void onSilentDetectTimeOut(){
            //触发了静音检测事件
    }
};

public void writeContent(ContextPrompt contextPrompt) throws ClientException

ContextPrompt contextPrompt = new ContextPrompt();
contextPrompt.setContextType("context");
contextPrompt.setHotwordList("订金|11,订金1|11,订金2|11");

PromptItem scenePrompt = new PromptItem("scene");
scenePrompt.addContextData(new ContextDataItem("订金的胶带"))
        .addContextData(new ContextDataItem("订金"))
        .addContextData(new ContextDataItem("胶带反应"));

PromptItem domainPrompt = new PromptItem("domain");
domainPrompt.addContextData(new ContextDataItem("订金"))
        .addContextData(new ContextDataItem("订金"))
        .addContextData(new ContextDataItem("订金"));

contextPrompt.addPrompt(scenePrompt).addPrompt(domainPrompt);

try {
    aaiClient.writeContent(contextPrompt);
} catch (ClientException e) {
    AAILogger.e(TAG, "writeContent failed, code=" + e.getCode() + ", message=" + e.getMessage());
}

{
  "context_type": "context",
  "hotword_list": "订金|11,订金1|11",
  "prompt": [
    {"context_type": "scene", "context_data": [{"text": "..."}]},
    {"context_type": "domain", "context_data": [{"text": "..."}]}
  ]
}

public static void setNeedLogFile(boolean needLogFile, Context applicationContext);


/**
 * 注: 部分android机型可以通过该方式解决回音消除失效的问题
 * https://blog.csdn.net/wyw0000/article/details/125195997
 */
// 1. 设置音频模式为AudioManager.MODE_IN_COMMUNICATION可以起到回音消除的作用
AudioManager audioManager = (AudioManager)context.getSystemService(Context.AUDIO_SERVICE);
audioManager.setMode(AudioManager.MODE_IN_COMMUNICATION);

// 2. 音频源使用MediaRecorder.AudioSource.VOICE_COMMUNICATION可以起到回音消除的作用
int audioSource = MediaRecorder.AudioSource.VOICE_COMMUNICATION;
AudioRecord audioRecord = new AudioRecord(audioSource, sampleRate, channel, audioFormat, bufferSize);

/**
 * 注: 以下两个能力(AcousticEchoCanceler和NoiseSuppressor)和手机硬件能力相关，有些机型(比如小米11)即使isAvailable()==true，回音消除也不生效
 */
// AcousticEchoCanceler回音消除
if (AcousticEchoCanceler.isAvailable()) {
    Log.d(TAG, "AcousticEchoCanceler isAvailable.");
    AcousticEchoCanceler acousticEchoCanceler = AcousticEchoCanceler
            .create(audioRecord.getAudioSessionId());
    int resultCode = acousticEchoCanceler.setEnabled(true);
    if (AudioEffect.SUCCESS == resultCode) {
        Log.d(TAG, "AcousticEchoCanceler AudioEffect SUCCESS");
    }
}

// NoiseSuppressor噪音抑制
if (NoiseSuppressor.isAvailable()) {
    Log.d(TAG, "NoiseSuppressor isAvailable.");
    NoiseSuppressor noiseSuppressor = NoiseSuppressor
            .create(audioRecord.getAudioSessionId());
    int resultCode = noiseSuppressor.setEnabled(true);
    if (AudioEffect.SUCCESS == resultCode) {
        Log.d(TAG, "NoiseSuppressor AudioEffect SUCCESS");
    }
}