client.java

使用Exlipse编写的一个语音程序

/**
 * Copyright 2001 Sun Microsystems, Inc.
 * 
 * See the file "license.terms" for information on usage and
 * redistribution of this file, and for a DISCLAIMER OF ALL 
 * WARRANTIES.
 */


import com.sun.speech.freetts.audio.AudioPlayer;
import com.sun.speech.freetts.audio.JavaStreamingAudioPlayer;
import com.sun.speech.freetts.util.Utilities;

import java.io.BufferedReader;
import java.io.DataInputStream;
import java.io.InputStreamReader;
import java.io.IOException;
import java.io.PrintWriter;

import java.net.Socket;

import javax.sound.sampled.AudioFormat;


/**
 * Implements a Java Client for the Client/Server demo. For details about
 * the protocol between client and server, consult the file
 * <code>Protocol.txt</code>.
 */
public class Client {

    private String serverAddress = Utilities.getProperty("server", "localhost");
    private int serverPort = Utilities.getInteger("port", 5555).intValue();

    private static final int AUDIO_BUFFER_SIZE = 256;

    private boolean debug = Utilities.getBoolean("debug");

    private BufferedReader systemInReader;  // for reading user input text
    private BufferedReader reader;
    private DataInputStream dataReader;     // for reading raw bytes
    private PrintWriter writer;
    private AudioPlayer audioPlayer;
    private int sampleRate = Utilities.getInteger("sampleRate", 16000).intValue();
    private int sampleSize = 16;            // in bits
    private byte[] socketBuffer = new byte[AUDIO_BUFFER_SIZE];


    private boolean metrics = Boolean.getBoolean("metrics");
    private long sendTime;             // time the text is sent to server
    private long receiveTime;          // time the first byte is received
    private long firstSoundTime;       // time the first play to audio
    private boolean firstByteReceived = false;


    private static final String FIRST_SENTENCE =
	"Type in what you want me to say.";


    /**
     * Constructs a default Client. It connects to the speech server, and
     * constructs an AudioPlayer.
     */
    public Client() {
	if (!connect()) {
	    System.out.println("Error connecting to " + serverAddress +
			       " at " + serverPort);
	    System.exit(1);
	}
	this.audioPlayer = new JavaStreamingAudioPlayer();
	this.audioPlayer.setAudioFormat
	    (new AudioFormat(sampleRate, sampleSize, 1, true, true));
    }


    /**
     * Connects this client to the server.
     *
     * @return  <code>true</code>  if successfully connected
     *          <code>false</code>  if failed to connect
     */
    private boolean connect() {
        try {
            Socket socket = new Socket(serverAddress, serverPort);
	    dataReader = new DataInputStream(socket.getInputStream());
	    systemInReader = new BufferedReader
		(new InputStreamReader(System.in));
	    writer = new PrintWriter(socket.getOutputStream(), true);
            return true;
        } catch (IOException ioe) {
	    ioe.printStackTrace();
	    return false;
        }
    }


    /**
     * Reads a line of text from the Socket.
     *
     * @return a line of text without the end of line character
     */
    private String readLine() throws IOException {
	int i;
	char c;
	StringBuffer buffer = new StringBuffer();

	while ((c = (char) dataReader.readByte()) != '\n') {
	    if (debug) {
		System.out.println(c);
	    }
	    buffer.append(c);
	}

	int lastCharIndex = buffer.length() - 1;
	
	// remove trailing ^M for Windows-based machines
	byte lastByte = (byte) buffer.charAt(lastCharIndex);
	if (lastByte == 13) {
	    return buffer.substring(0, lastCharIndex);
	} else {
	    return buffer.toString();
	}
    }


    /**
     * Sends the given line of text to the Socket, appending an end of
     * line character to the end.
     *
     * @param the line of text to send
     */
    private void sendLine(String line) {
	if (debug) {
	    System.out.println(line);
	}
	line = line.trim();
	if (line.length() > 0) {
	    writer.print(line);
	    writer.print('\n');
	    writer.flush();
	}
    }


    /**
     * Run the TTS protocol.
     */
    public void runTTSProtocol() {
	try {
	    String readyLine = readLine();
	    if (readyLine.equals("READY")) {
		if (!sendTTSRequest(FIRST_SENTENCE)) {
		    return;
		}
		System.out.print("Say       : ");
		String input;
		while ((input = systemInReader.readLine()) != null) {
		    if (input.length() > 0 && !sendTTSRequest(input)) {
			return;
		    }
		    System.out.print("Say       : ");
		}
	    }
	    sendLine("DONE");

	    audioPlayer.drain();
	    audioPlayer.close();

	    System.out.println("ALL DONE");

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


    /**
     * Sends a TTS request on the given text.
     *
     * @param text the text to do TTS on
     *
     * @return <code>true</code> if the TTS transaction was successful
     *         <code>false</code> if an error occurred
     */
    private boolean sendTTSRequest(String text) {

	if (metrics) {
	    sendTime = System.currentTimeMillis();
	    firstByteReceived = false;
	}

	// send TTS request to server
	sendLine("TTS\n" +
		 String.valueOf(sampleRate) + "\n" +
		 text + "\n");

	// get response
	String numberSamplesStr = null;
	int numberSamples = 0;

	do {
	    try {
		numberSamplesStr = readLine();
		numberSamples = Integer.parseInt(numberSamplesStr);
				
		if (numberSamples == -2) { // error
		    System.err.println("Client.sendTTSRequest(): error!");
		    return false;
		}		    
		if (numberSamples > 0) {
		    System.out.println
			("Receiving : " + numberSamples + " samples");
		    receiveAndPlay(numberSamples);
		}
	    } catch (IOException ioe) {
		ioe.printStackTrace();
	    }
	}
	while (numberSamples > 0);

	if (metrics) {
	    System.out.println("FirstByte : " +
			       (receiveTime - sendTime) + " ms");
	}

	return true;
    }


    /**
     * Reads the given number of bytes from the socket, and plays them
     * with the AudioPlayer.
     *
     * @param numberSamples the number of bytes to read from the socket
     */
    private void receiveAndPlay(int numberSamples) {

	int bytesToRead;
	int bytesRemaining;

	bytesRemaining = numberSamples;

        audioPlayer.begin(0);

	while (bytesRemaining > 0) {
	    
	    // how many more bytes do we have to read?
	    if (bytesRemaining >= AUDIO_BUFFER_SIZE) {
		bytesToRead = AUDIO_BUFFER_SIZE;
	    } else {
		bytesToRead = bytesRemaining;
	    }
	    
	    try {
		// we want to fill the socketBuffer completely before playing
		int nRead = 0;
		do {
		    int read = dataReader.read
			(socketBuffer, nRead, bytesToRead);

		    if (metrics && !firstByteReceived) {
			receiveTime = System.currentTimeMillis();
		    }
		    nRead += read;
		    bytesToRead -= read;
		}
		while (bytesToRead > 0);
	       
		if (nRead < 0) {
		    System.err.println("error reading samples");
		} else {
		    bytesRemaining -= nRead;
		    
		    if (metrics && !firstByteReceived) {
			firstSoundTime = System.currentTimeMillis();
			firstByteReceived = true;
		    }
		    audioPlayer.write(socketBuffer, 0, nRead);
		}
	    } catch (IOException ioe) {
		ioe.printStackTrace();
	    }
	    
	    if (debug) {
		System.out.println("BytesRemaining: " + bytesRemaining);
	    }
	}

        audioPlayer.end();

	if (debug) {
	    System.out.println("finished");
	}
    }


    /**
     * Main program to run the client.
     */    
    public static void main(String[] argv) {
	Client client = new Client();
	client.runTTSProtocol();
	System.exit(0);
    }
}