Java实现的百度语音识别功能示例

package com.baidu.speech.serviceapi;

import java.io.bufferedreader;

import java.io.dataoutputstream;

import java.io.file;

import java.io.fileinputstream;

import java.io.ioexception;

import java.io.inputstream;

import java.io.inputstreamreader;

import java.io.unsupportedencodingexception;

import java.net.httpurlconnection;

import java.net.url;

import java.net.urldecoder;

import java.net.urlencoder;

import javax.xml.bind.datatypeconverter;

import org.json.jsonobject;

public class sample {

   private static final string serverurl = "http://vop.baidu.com/server_api" ;

   private static string token = "" ;

   private static final string testfilename = "test.pcm" ; // 百度语音提供技术支持

   //put your own params here

   // 下面3个值要填写自己申请的app对应的值

   private static final string apikey = "" ;

   private static final string secretkey = "" ;

   private static final string cuid = "" ;

   public static void main(string[] args) throws exception {

     gettoken();

     method1();

     method2();

   }

   private static void gettoken() throws exception {

     string gettokenurl = "https://openapi.baidu.com/oauth/2.0/token?grant_type=client_credentials" +

       "&client_id=" + apikey + "&client_secret=" + secretkey;

     httpurlconnection conn = (httpurlconnection) new url(gettokenurl).openconnection();

     token = new jsonobject(printresponse(conn)).getstring( "access_token" );

   }

   private static void method1() throws exception {

     file pcmfile = new file(testfilename);

     httpurlconnection conn = (httpurlconnection) new url(serverurl).openconnection();

     // construct params

     jsonobject params = new jsonobject();

     params.put( "format" , "pcm" );

     params.put( "rate" , 8000 );

     params.put( "channel" , "1" );

     params.put( "token" , token);

     params.put( "lan" , "zh" );

     params.put( "cuid" , cuid);

     params.put( "len" , pcmfile.length());

     params.put( "speech" , datatypeconverter.printbase64binary(loadfile(pcmfile)));

     // add request header

     conn.setrequestmethod( "post" );

     conn.setrequestproperty( "content-type" , "application/json; charset=utf-8" );

     conn.setdoinput( true );

     conn.setdooutput( true );

     // send request

     dataoutputstream wr = new dataoutputstream(conn.getoutputstream());

     wr.writebytes(params.tostring());

     wr.flush();

     wr.close();

     printresponse(conn);

   }

   private static void method2() throws exception {

     file pcmfile = new file(testfilename);

     httpurlconnection conn = (httpurlconnection) new url(serverurl

         + "?cuid=" + cuid + "&token=" + token).openconnection();

     // add request header

     conn.setrequestmethod( "post" );

     conn.setrequestproperty( "content-type" , "audio/pcm; rate=8000" );

     conn.setdoinput( true );

     conn.setdooutput( true );

     // send request

     dataoutputstream wr = new dataoutputstream(conn.getoutputstream());

     wr.write(loadfile(pcmfile));

     wr.flush();

     wr.close();

     system.out.println(getutf8string(printresponse(conn)));

   }

   private static string printresponse(httpurlconnection conn) throws exception {

     if (conn.getresponsecode() != 200 ) {

       // request error

      system.out.println( "conn.getresponsecode() = " + conn.getresponsecode());

       return "" ;

     }

     inputstream is = conn.getinputstream();

     bufferedreader rd = new bufferedreader( new inputstreamreader(is));

     string line;

     stringbuffer response = new stringbuffer();

     while ((line = rd.readline()) != null ) {

       response.append(line);

       response.append( '\r' );

     }

     rd.close();

     system.out.println( new jsonobject(response.tostring()).tostring( 4 ));

     return response.tostring();

   }

   private static byte [] loadfile(file file) throws ioexception {

     inputstream is = new fileinputstream(file);

     long length = file.length();

     byte [] bytes = new byte [( int ) length];

     int offset = 0 ;

     int numread = 0 ;

     while (offset < bytes.length

         && (numread = is.read(bytes, offset, bytes.length - offset)) >= 0 ) {

       offset += numread;

     }

     if (offset < bytes.length) {

       is.close();

       throw new ioexception( "could not completely read file " + file.getname());

     }

     is.close();

     return bytes;

   }

   // gbk编码转为utf-8

   private static string getutf8string(string s) throws unsupportedencodingexception

   {

    stringbuffer sb = new stringbuffer();

    sb.append(s);

    string xmlstring = "" ;

    string xmlutf8 = "" ;

  xmlstring = new string(sb.tostring().getbytes( "gbk" ));

  xmlutf8 = urlencoder.encode(xmlstring , "gbk" );

    return urldecoder.decode(xmlutf8, "utf-8" );

   }

}