科大讯飞语音识别音频转文字

package com.iflytek.test; import java.io.File; import java.io.FileInputStream; import java.io.IOException; import java.util.ArrayList; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import com.iflytek.cloud.speech.RecognizerListener; import com.iflytek.cloud.speech.RecognizerResult; import com.iflytek.cloud.speech.Setting; import com.iflytek.cloud.speech.SpeechConstant; import com.iflytek.cloud.speech.SpeechError; import com.iflytek.cloud.speech.SpeechRecognizer; import com.iflytek.cloud.speech.SpeechUtility; /** * 音频文件识别 * * @author zxh * */ public class MscRecognition { private static final Log logger = LogFactory.getLog(MscRecognition.class); // 账号ID private static final String APPID = "5a290e4a"; private StringBuffer mResult = new StringBuffer(); /** 最大等待时间， 单位ms */ private int maxWaitTime = 600; /** 每次等待时间 */ private int perWaitTime = 100; /** 音频文件 */ private String fileName = ""; static { Setting.setShowLog(false); SpeechUtility.createUtility("appid=" + APPID); } public String voiceTowords(String fileName) { return initVoiceTowords(fileName, true); } /** * * @param fileName * @param init * 初始化最大等待时间 * @return */ public String initVoiceTowords(String fileName, boolean init) { if (init) { maxWaitTime = 6000; } this.fileName = fileName; return recognize(); } // *************************************音频流听写************************************* /** * 听写 * * @return */ private String recognize() { if (SpeechRecognizer.getRecognizer() == null) SpeechRecognizer.createRecognizer(); return RecognizePcmfileByte(); } /** * 自动化测试注意要点 如果直接从音频文件识别，需要模拟真实的音速，防止音频队列的堵塞 * */ private String RecognizePcmfileByte() { // 1、读取音频文件 FileInputStream fis = null; byte[] voiceBuffer = null; try { fis = new FileInputStream(new File(fileName)); voiceBuffer = new byte[fis.available()]; fis.read(voiceBuffer); } catch (Exception e) { e.printStackTrace(); } finally { try { if (null != fis) { fis.close(); fis = null; } } catch (IOException e) { e.printStackTrace(); } } // 2、音频流听写 if (0 == voiceBuffer.length) { mResult.append("no audio avaible!"); } else { // 解析之前将存出结果置为空 mResult.setLength(0); SpeechRecognizer recognizer = SpeechRecognizer.getRecognizer(); // 设置参数，详见《MSC Reference Manual》SpeechConstant类 // 应用领域用于听写和语音语义服务 recognizer.setParameter(SpeechConstant.DOMAIN, "iat"); // 语言区域 recognizer.setParameter(SpeechConstant.LANGUAGE, "zh_cn"); // 方言 每一种语言区域 recognizer.setParameter(SpeechConstant.ACCENT, "mandarin"); // 音频源 recognizer.setParameter(SpeechConstant.AUDIO_SOURCE, "-1"); // 音频采样率 recognizer.setParameter(SpeechConstant.SAMPLE_RATE, "8000"); // 返回格式 recognizer.setParameter(SpeechConstant.RESULT_TYPE, "plain"); // 开始听写 recognizer.startListening(recListener); // voiceBuffer为音频数据流，splitBuffer为自定义分割接口，将其以4.8k字节分割成数组 ArrayList<byte[]> buffers = splitBuffer(voiceBuffer, voiceBuffer.length, 4800); for (int i = 0; i < buffers.size(); i++) { // 每次写入msc数据4.8K,相当150ms录音数据 recognizer.writeAudio(buffers.get(i), 0, buffers.get(i).length); } recognizer.stopListening(); // 在原有的代码基础上主要添加了这个while代码等待音频解析完成，recognizer.isListening()返回true，说明解析工作还在进行 while (recognizer.isListening()) { try { Thread.sleep(perWaitTime); } catch (InterruptedException e) { e.printStackTrace(); } maxWaitTime -= perWaitTime; } } return mResult.toString(); } /** * 将字节缓冲区按照固定大小进行分割成数组 * * @param buffer * 缓冲区 * @param length * 缓冲区大小 * @param spsize * 切割块大小 * @return */ private ArrayList<byte[]> splitBuffer(byte[] buffer, int length, int spsize) { ArrayList<byte[]> array = new ArrayList<byte[]>(); if (spsize <= 0 || length <= 0 || buffer == null || buffer.length < length) return array; int size = 0; // 截断识别5秒得数据 /*int fiveMsec = 93946; if (length >= fiveMsec) { length = fiveMsec; } */ while (size < length) { int left = length - size; if (spsize < left) { byte[] sdata = new byte[spsize]; System.arraycopy(buffer, size, sdata, 0, spsize); array.add(sdata); size += spsize; } else { byte[] sdata = new byte[left]; System.arraycopy(buffer, size, sdata, 0, left); array.add(sdata); size += left; } } return array; } /** * 听写监听器 */ private RecognizerListener recListener = new RecognizerListener() { // 开始录音 public void onBeginOfSpeech() { } // 结束录音 public void onEndOfSpeech() { } // 音量值0~30 public void onVolumeChanged(int volume) { } public void onResult(RecognizerResult result, boolean islast) { mResult.append(result.getResultString()); } // 会话发生错误回调接口 public void onError(SpeechError error) { System.out.println("---------------error"); error.getErrorDescription(true);// 获取错误码描述 logger.debug(fileName + "-xf错误码:-" + error.getErrorCode()); } // 扩展用接口 public void onEvent(int eventType, int arg1, int agr2, String msg) { } }; }