Java SDK
本文介紹如何使用智能語音交互流式文本語音合成的Java SDK,包括SDK的安裝方法及SDK代碼示例等。
前提條件
在使用SDK之前,請先閱讀接口說明。
下載安裝
從Maven服務(wù)器下載最新版本的SDKnls-sdk-java-demo+flowingtts+3.zip。
<dependency> <groupId>com.alibaba.nls</groupId> <artifactId>nls-sdk-tts</artifactId> <version>2.2.14</version> </dependency> <dependency> <groupId>com.alibaba.nls</groupId> <artifactId>nls-sdk-common</artifactId> <version>2.2.14</version> </dependency>
重要Java SDK 從 2.1.7 版本開始(含2.1.7),語音合成SDK(包括實時長文本語音合成)SpeechSynthesizer 的 waitForComplete 接口的超時時間單位從 秒 變更為 毫秒 。
解壓該ZIP文件。
在pom.xml文件所在的目錄運(yùn)行
mvn package
,會在target目錄生成可執(zhí)行JAR:nls-example-tts-2.0.0-jar-with-dependencies.jar。將JAR包拷貝到您應(yīng)用所在的服務(wù)器,用于快速驗證及壓測服務(wù)。
服務(wù)驗證。運(yùn)行如下代碼,并按提示提供相應(yīng)參數(shù)。運(yùn)行后在命令執(zhí)行目錄生成logs/nls.log,并且將合成的音頻保存在flowingTts.wav。
java -cp nls-example-flowing-tts-2.0.0-jar-with-dependencies.jar com.alibaba.nls.client.FlowingSpeechSynthesizerDemo <your-api-key> <your-token>
關(guān)鍵接口
NlsClient:語音處理客戶端,利用該客戶端可以進(jìn)行一句話識別、實時語音識別和語音合成的語音處理任務(wù)。該客戶端為線程安全,建議全局僅創(chuàng)建一個實例。
FlowingSpeechSynthesizer:流式文本語音合成實時語音合成處理類,通過該接口請求參數(shù),發(fā)送請求,非線程安全。
FlowingSpeechSynthesizerListener:流式文本語音合成實時語音合成監(jiān)聽類,監(jiān)聽返回結(jié)果。非線程安全。需要實現(xiàn)如下抽象方法:
/** * 服務(wù)端檢測到了一句話的開始 * @param response */ abstract public void onSentenceBegin(FlowingSpeechSynthesizerResponse response) ; /** * 接收到語音合成音頻數(shù)據(jù)流 * @param message 二進(jìn)制音頻數(shù)據(jù) */ abstract public void onAudioData(ByteBuffer message); /** * 服務(wù)端檢測到了一句話的結(jié)束,并返回這句話的起止位置與所有時間戳 * @param response */ abstract public void onSentenceEnd(FlowingSpeechSynthesizerResponse response) ; /** * 合成結(jié)束 * @param response */ abstract public void onSynthesisComplete(FlowingSpeechSynthesizerResponse response) ; /** * 失敗處理 * @param response */ abstract public void onFail(FlowingSpeechSynthesizerResponse response) ; /** * 增量在response=>payload中返回時間戳 * @param response */ abstract public void onSentenceSynthesis(FlowingSpeechSynthesizerResponse response) ;
SDK調(diào)用注意事項:
NlsClient使用Netty框架,NlsClient對象的創(chuàng)建會消耗一定時間和資源,一經(jīng)創(chuàng)建可以重復(fù)使用。建議調(diào)用程序?qū)lsClient的創(chuàng)建和關(guān)閉與程序本身的生命周期相結(jié)合。
SpeechSynthesizer對象不可重復(fù)使用,一個語音合成任務(wù)對應(yīng)一個SpeechSynthesizer對象。例如,大模型和用戶的N次對話要進(jìn)行N次語音合成任務(wù),創(chuàng)建N個SpeechSynthesizer對象。
SpeechSynthesizerListener對象和SpeechSynthesizer對象是一一對應(yīng)的,不能將一個SpeechSynthesizerListener對象設(shè)置到多個SpeechSynthesizer對象中,否則無法區(qū)分各語音合成任務(wù)。
Java SDK依賴Netty網(wǎng)絡(luò)庫,如果您的應(yīng)用依賴Netty,其版本需更新至4.1.17.Final及以上。
代碼示例
package com.alibaba.nls.client;
import com.alibaba.nls.client.protocol.NlsClient;
import com.alibaba.nls.client.protocol.OutputFormatEnum;
import com.alibaba.nls.client.protocol.SampleRateEnum;
import com.alibaba.nls.client.protocol.tts.FlowingSpeechSynthesizer;
import com.alibaba.nls.client.protocol.tts.FlowingSpeechSynthesizerListener;
import com.alibaba.nls.client.protocol.tts.FlowingSpeechSynthesizerResponse;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.nio.ByteBuffer;
/**
* 此示例演示了:
* 流式文本語音合成API調(diào)用。
*/
public class FlowingSpeechSynthesizerDemo {
private static final Logger logger = LoggerFactory.getLogger(FlowingSpeechSynthesizerDemo.class);
private static long startTime;
private String appKey;
NlsClient client;
public FlowingSpeechSynthesizerDemo(String appKey, String token, String url) {
this.appKey = appKey;
//創(chuàng)建NlsClient實例應(yīng)用全局創(chuàng)建一個即可。生命周期可和整個應(yīng)用保持一致,默認(rèn)服務(wù)地址為阿里云線上服務(wù)地址。
if(url.isEmpty()) {
client = new NlsClient(token);
} else {
client = new NlsClient(url, token);
}
}
private static FlowingSpeechSynthesizerListener getSynthesizerListener() {
FlowingSpeechSynthesizerListener listener = null;
try {
listener = new FlowingSpeechSynthesizerListener() {
File f=new File("flowingTts.wav");
FileOutputStream fout = new FileOutputStream(f);
private boolean firstRecvBinary = true;
//流式文本語音合成開始
public void onSynthesisStart(FlowingSpeechSynthesizerResponse response) {
System.out.println("name: " + response.getName() +
", status: " + response.getStatus());
}
//服務(wù)端檢測到了一句話的開始
public void onSentenceBegin(FlowingSpeechSynthesizerResponse response) {
System.out.println("name: " + response.getName() +
", status: " + response.getStatus());
System.out.println("Sentence Begin");
}
//服務(wù)端檢測到了一句話的結(jié)束,獲得這句話的起止位置和所有時間戳
public void onSentenceEnd(FlowingSpeechSynthesizerResponse response) {
System.out.println("name: " + response.getName() +
", status: " + response.getStatus() + ", subtitles: " + response.getObject("subtitles"));
}
//流式文本語音合成結(jié)束
@Override
public void onSynthesisComplete(FlowingSpeechSynthesizerResponse response) {
// 調(diào)用onSynthesisComplete時,表示所有TTS數(shù)據(jù)已經(jīng)接收完成,所有文本都已經(jīng)合成音頻并返回。
System.out.println("name: " + response.getName() + ", status: " + response.getStatus()+", output file :"+f.getAbsolutePath());
}
//收到語音合成的語音二進(jìn)制數(shù)據(jù)
@Override
public void onAudioData(ByteBuffer message) {
try {
if(firstRecvBinary) {
// 此處計算首包語音流的延遲,收到第一包語音流時,即可以進(jìn)行語音播放,以提升響應(yīng)速度(特別是實時交互場景下)。
firstRecvBinary = false;
long now = System.currentTimeMillis();
logger.info("tts first latency : " + (now - FlowingSpeechSynthesizerDemo.startTime) + " ms");
}
byte[] bytesArray = new byte[message.remaining()];
message.get(bytesArray, 0, bytesArray.length);
System.out.println("write array:" + bytesArray.length);
fout.write(bytesArray);
} catch (IOException e) {
e.printStackTrace();
}
}
//收到語音合成的增量音頻時間戳
@Override
public void onSentenceSynthesis(FlowingSpeechSynthesizerResponse response) {
System.out.println("name: " + response.getName() +
", status: " + response.getStatus() + ", subtitles: " + response.getObject("subtitles"));
}
@Override
public void onFail(FlowingSpeechSynthesizerResponse response){
// task_id是調(diào)用方和服務(wù)端通信的唯一標(biāo)識,當(dāng)遇到問題時,需要提供此task_id以便排查。
System.out.println(
"session_id: " + getFlowingSpeechSynthesizer().getCurrentSessionId() +
", task_id: " + response.getTaskId() +
//狀態(tài)碼
", status: " + response.getStatus() +
//錯誤信息
", status_text: " + response.getStatusText());
}
};
} catch (Exception e) {
e.printStackTrace();
}
return listener;
}
public void process(String[] textArray) {
FlowingSpeechSynthesizer synthesizer = null;
try {
//創(chuàng)建實例,建立連接。
synthesizer = new FlowingSpeechSynthesizer(client, getSynthesizerListener());
synthesizer.setAppKey(appKey);
//設(shè)置返回音頻的編碼格式。
synthesizer.setFormat(OutputFormatEnum.WAV);
//設(shè)置返回音頻的采樣率。
synthesizer.setSampleRate(SampleRateEnum.SAMPLE_RATE_16K);
//發(fā)音人。
synthesizer.setVoice("siyue");
//音量,范圍是0~100,可選,默認(rèn)50。
synthesizer.setVolume(50);
//語調(diào),范圍是-500~500,可選,默認(rèn)是0。
synthesizer.setPitchRate(0);
//語速,范圍是-500~500,默認(rèn)是0。
synthesizer.setSpeechRate(0);
//此方法將以上參數(shù)設(shè)置序列化為JSON發(fā)送給服務(wù)端,并等待服務(wù)端確認(rèn)。
long start = System.currentTimeMillis();
synthesizer.start();
logger.info("tts start latency " + (System.currentTimeMillis() - start) + " ms");
FlowingSpeechSynthesizerDemo.startTime = System.currentTimeMillis();
//設(shè)置連續(xù)兩次發(fā)送文本的最小時間間隔(毫秒),如果當(dāng)前調(diào)用send時距離上次調(diào)用時間小于此值,則會阻塞并等待直到滿足條件再發(fā)送文本
synthesizer.setMinSendIntervalMS(100);
for(String text :textArray) {
//發(fā)送流式文本數(shù)據(jù)。
synthesizer.send(text);
}
//通知服務(wù)端流式文本數(shù)據(jù)發(fā)送完畢,阻塞等待服務(wù)端處理完成。
synthesizer.stop();
} catch (Exception e) {
e.printStackTrace();
} finally {
//關(guān)閉連接
if (null != synthesizer) {
synthesizer.close();
}
}
}
public void shutdown() {
client.shutdown();
}
public static void main(String[] args) throws Exception {
String appKey = "your-api-key";
String token = "your-token";
// url取默認(rèn)值
String url = "wss://nls-gateway-cn-beijing.aliyuncs.com/ws/v1";
if (args.length == 2) {
appKey = args[0];
token = args[1];
} else if (args.length == 3) {
appKey = args[0];
token = args[1];
url = args[2];
} else {
System.err.println("run error, need params(url is optional): " + "<app-key> <token> [url]");
System.exit(-1);
}
String[] textArray = {"百草堂與三", "味書屋 魯迅 \n我家的后面有一個很", "大的園,相傳叫作百草園。現(xiàn)在是早已并屋子一起賣", "給朱文公的子孫了,連那最末次的相見也已經(jīng)",
"隔了七八年,其中似乎確鑿只有一些野草;但那時卻是我的樂園。\n不必說碧綠的菜畦,光滑的石井欄,高大的皂莢樹,紫紅的桑葚;也不必說鳴蟬在樹葉里長吟,肥胖的黃蜂伏在菜花",
"上,輕捷的叫天子(云雀)忽然從草間直竄向云霄里去了。\n單是周圍的短短的泥墻根一帶,就有無限趣味。油蛉在這里低唱,蟋蟀們在這里彈琴。翻開斷磚來,有時會遇見蜈蚣;還有斑",
"蝥,倘若用手指按住它的脊梁,便會啪的一聲,\n從后竅噴出一陣煙霧。何首烏藤和木蓮藤纏絡(luò)著,木蓮有蓮房一般的果實,何首烏有臃腫的根。有人說,何首烏根是有像人形的,吃了",
"便可以成仙,我于是常常拔它起來,牽連不斷地拔起來,\n也曾因此弄壞了泥墻,卻從來沒有見過有一塊根像人樣! 如果不怕刺,還可以摘到覆盆子,像小珊瑚珠攢成的小球,又酸又甜,",
"色味都比桑葚要好得遠(yuǎn)......"};
FlowingSpeechSynthesizerDemo demo = new FlowingSpeechSynthesizerDemo(appKey, token, url);
demo.process(textArray);
demo.shutdown();
}
}
常見問題
服務(wù)端返回“idle timeout”錯誤,應(yīng)如何解決?
該報錯是由于服務(wù)端在超過10s沒有收到客戶端消息,從而導(dǎo)致斷連,返回idle timeout
報錯。
可以通過調(diào)用FlowingSpeechSynthesizer.getConnection().sendPing()
定期向服務(wù)端發(fā)送ping包為連接保活。