智能语音合成后，JAVA SDK的demo中是直接生成了wav音频文件，怎么样让他生成完成后直接播放

要实现语音播放，您需要将接收到的二进制语音数据通过音频播放器进行实时播放。以下是基于您提供的代码和知识库资料的详细解决方案：

1. 理解代码逻辑

在onMessage(ByteBuffer message)方法中，SDK通过回调的方式将语音合成的二进制数据传递给客户端。当前代码的主要功能是： - 计算首包语音流的延迟（firstRecvBinary标志位）。 - 将接收到的二进制数据写入文件（fout.write(bytesArray)）。

然而，这段代码并未实现语音播放功能。为了实现实时播放，需要将接收到的二进制数据推送到音频播放器进行处理。

2. 实现语音播放的关键步骤

2.1 准备音频播放器

使用Java的javax.sound.sampled包创建一个音频播放器。以下是一个示例代码片段，用于初始化音频播放器：

import javax.sound.sampled.*;

private AudioFormat audioFormat;
private SourceDataLine sourceDataLine;

public void preparePlayer(int sampleRate) throws LineUnavailableException {
    // 定义音频格式：采样率、16位深度、单声道、有符号、小端存储
    audioFormat = new AudioFormat(sampleRate, 16, 1, true, false);
    DataLine.Info info = new DataLine.Info(SourceDataLine.class, audioFormat);

    // 获取并打开音频输出设备
    sourceDataLine = (SourceDataLine) AudioSystem.getLine(info);
    sourceDataLine.open(audioFormat);
    sourceDataLine.start();
}

注意：sampleRate参数需要与语音合成请求中的采样率一致（默认为16000 Hz）。

2.2 实现语音播放逻辑

在onMessage(ByteBuffer message)方法中，将接收到的二进制数据推送到音频播放器进行实时播放。以下是修改后的代码：

@Override
public void onMessage(ByteBuffer message) {
    try {
        if (firstRecvBinary) {
            // 计算首包语音流的延迟
            firstRecvBinary = false;
            long now = System.currentTimeMillis();
            logger.info("tts first latency : " + (now - SpeechSynthesizerDemo.startTime) + " ms");
        }

        // 将ByteBuffer转换为字节数组
        byte[] bytesArray = new byte[message.remaining()];
        message.get(bytesArray, 0, bytesArray.length);

        // 将字节数组写入音频播放器
        if (sourceDataLine != null && sourceDataLine.isOpen()) {
            sourceDataLine.write(bytesArray, 0, bytesArray.length);
        }
    } catch (Exception e) {
        e.printStackTrace();
    }
}

2.3 停止播放

当语音合成完成后，服务端会触发onComplete()回调。在此回调中，可以停止音频播放器并释放资源：

@Override
public void onComplete(SpeechSynthesizerResponse response) {
    if (sourceDataLine != null) {
        sourceDataLine.drain();  // 等待缓冲区数据播放完毕
        sourceDataLine.stop();   // 停止播放
        sourceDataLine.close();  // 关闭音频设备
    }
    logger.info("语音播放完成");
}

3. 完整流程总结

以下是完整的语音播放流程： 1. 初始化音频播放器：调用preparePlayer(sampleRate)方法，设置音频格式并打开音频设备。 2. 接收语音数据：在onMessage(ByteBuffer message)方法中，将接收到的二进制数据推送到音频播放器。 3. 结束播放：在onComplete()回调中，停止并关闭音频播放器。

4. 注意事项

• 实时性要求：如果对实时性要求较高，建议采用流式播放方式，即边接收语音数据边播放，以减少延迟。
• 线程安全：SourceDataLine不是线程安全的，请确保在单一线程中操作音频播放器。
• 错误处理：在onError(Exception e)回调中，需妥善处理异常并停止播放器。

5. 参考代码整合

以下是整合后的完整代码示例：

import javax.sound.sampled.*;
import java.nio.ByteBuffer;

public class SpeechSynthesizerDemo {
    private boolean firstRecvBinary = true;
    private SourceDataLine sourceDataLine;

    public void preparePlayer(int sampleRate) throws LineUnavailableException {
        AudioFormat audioFormat = new AudioFormat(sampleRate, 16, 1, true, false);
        DataLine.Info info = new DataLine.Info(SourceDataLine.class, audioFormat);
        sourceDataLine = (SourceDataLine) AudioSystem.getLine(info);
        sourceDataLine.open(audioFormat);
        sourceDataLine.start();
    }

    @Override
    public void onMessage(ByteBuffer message) {
        try {
            if (firstRecvBinary) {
                firstRecvBinary = false;
                long now = System.currentTimeMillis();
                System.out.println("tts first latency : " + (now - startTime) + " ms");
            }

            byte[] bytesArray = new byte[message.remaining()];
            message.get(bytesArray, 0, bytesArray.length);

            if (sourceDataLine != null && sourceDataLine.isOpen()) {
                sourceDataLine.write(bytesArray, 0, bytesArray.length);
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    @Override
    public void onComplete(SpeechSynthesizerResponse response) {
        if (sourceDataLine != null) {
            sourceDataLine.drain();
            sourceDataLine.stop();
            sourceDataLine.close();
        }
        System.out.println("语音播放完成");
    }
}

通过上述步骤，您可以成功实现语音播放功能，并满足实时交互场景的需求。