import com.alibaba.dashscope.audio.ttsv2.SpeechSynthesisParam;
import com.alibaba.dashscope.audio.ttsv2.SpeechSynthesizer;
import com.alibaba.dashscope.utils.Constants;

import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.nio.ByteBuffer;

public class Main {
  private static String model = "cosyvoice-v3-flash";
  private static String voice = "longanyang";

  public static void streamAudioDataToSpeaker() {
    SpeechSynthesisParam param =
        SpeechSynthesisParam.builder()
            // 如果未配置环境变量，请将下一行替换为：.apiKey("sk-xxx")
            .apiKey(System.getenv("DASHSCOPE_API_KEY"))
            .model(model)
            .voice(voice)
            .build();

    // 同步模式：将回调（第二个参数）设为 null。
    SpeechSynthesizer synthesizer = new SpeechSynthesizer(param, null);
    ByteBuffer audio = null;
    try {
      // 阻塞直到音频返回。
      audio = synthesizer.call("今天天气怎么样？");
    } catch (Exception e) {
      throw new RuntimeException(e);
    } finally {
      // 任务完成后关闭 WebSocket 连接。
      synthesizer.getDuplexApi().close(1000, "bye");
    }
    if (audio != null) {
      File file = new File("output.mp3");
      // 首次调用的首包延迟包含 WebSocket 建连时间。
      System.out.println(
          "[Metric] Request ID: "
              + synthesizer.getLastRequestId()
              + ", First-packet latency (ms): "
              + synthesizer.getFirstPackageDelay());
      try (FileOutputStream fos = new FileOutputStream(file)) {
        // call() 返回的 ByteBuffer position=0 且 remaining=capacity，array() 返回完整音频数据。
        fos.write(audio.array());
      } catch (IOException e) {
        throw new RuntimeException(e);
      }
    }
  }

  public static void main(String[] args) {
    Constants.baseWebsocketApiUrl = "wss://dashscope.aliyuncs.com/api-ws/v1/inference";
    streamAudioDataToSpeaker();
    System.exit(0);
  }
}

import com.alibaba.dashscope.audio.tts.SpeechSynthesisResult;
import com.alibaba.dashscope.audio.ttsv2.SpeechSynthesisParam;
import com.alibaba.dashscope.audio.ttsv2.SpeechSynthesizer;
import com.alibaba.dashscope.common.ResultCallback;
import com.alibaba.dashscope.utils.Constants;

import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import java.util.concurrent.CountDownLatch;

class TimeUtils {
  private static final DateTimeFormatter formatter =
      DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss.SSS");

  public static String getTimestamp() {
    return LocalDateTime.now().format(formatter);
  }
}

public class Main {
  private static String model = "cosyvoice-v3-flash";
  private static String voice = "longanyang";

  public static void streamAudioDataToSpeaker() {
    CountDownLatch latch = new CountDownLatch(1);

    // 实现 ResultCallback 接口。
    ResultCallback<SpeechSynthesisResult> callback = new ResultCallback<SpeechSynthesisResult>() {
      @Override
      public void onEvent(SpeechSynthesisResult result) {
        // System.out.println("收到消息: " + result);
        if (result.getAudioFrame() != null) {
          // 在此添加音频处理逻辑。
          System.out.println(TimeUtils.getTimestamp() + " 收到音频");
        }
      }

      @Override
      public void onComplete() {
        System.out.println(TimeUtils.getTimestamp() + " 收到完成信号，语音合成结束。");
        latch.countDown();
      }

      @Override
      public void onError(Exception e) {
        System.out.println("发生异常：" + e.toString());
        latch.countDown();
      }
    };

    SpeechSynthesisParam param =
        SpeechSynthesisParam.builder()
            // 如果未配置环境变量，请将下一行替换为：.apiKey("sk-xxx")
            .apiKey(System.getenv("DASHSCOPE_API_KEY"))
            .model(model)
            .voice(voice)
            .build();
    // 将回调作为第二个参数传入，启用异步模式。
    SpeechSynthesizer synthesizer = new SpeechSynthesizer(param, callback);
    // 非阻塞：立即返回 null，结果通过 onEvent 回调返回。
    try {
      synthesizer.call("今天天气怎么样？");
      latch.await();
    } catch (Exception e) {
      throw new RuntimeException(e);
    } finally {
      // 任务完成后关闭 WebSocket 连接。
      synthesizer.getDuplexApi().close(1000, "bye");
    }
    // 首次调用的首包延迟包含 WebSocket 建连时间。
    System.out.println(
        "[Metric] Request ID: "
            + synthesizer.getLastRequestId()
            + ", First-packet latency (ms): "
            + synthesizer.getFirstPackageDelay());
  }

  public static void main(String[] args) {
    Constants.baseWebsocketApiUrl = "wss://dashscope.aliyuncs.com/api-ws/v1/inference";
    streamAudioDataToSpeaker();
    System.exit(0);
  }
}

import com.alibaba.dashscope.audio.tts.SpeechSynthesisResult;
import com.alibaba.dashscope.audio.ttsv2.SpeechSynthesisAudioFormat;
import com.alibaba.dashscope.audio.ttsv2.SpeechSynthesisParam;
import com.alibaba.dashscope.audio.ttsv2.SpeechSynthesizer;
import com.alibaba.dashscope.common.ResultCallback;
import com.alibaba.dashscope.utils.Constants;

import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;

class TimeUtils {
  private static final DateTimeFormatter formatter =
      DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss.SSS");

  public static String getTimestamp() {
    return LocalDateTime.now().format(formatter);
  }
}


public class Main {
  private static String[] textArray = {"流式语音合成 SDK ",
      "可以将输入文本 ", "转换为二进制音频数据。", "相比非流式合成，",
      "流式合成具有更好的实时性。", "您几乎可以在输入文本的同时听到音频输出，",
      "这极大地提升了用户体验 ", "并减少了等待时间。",
      "这非常适合使用大型 ", "语言模型（LLM）",
      "从文本流中合成语音的应用场景。"};
  private static String model = "cosyvoice-v3-flash";
  private static String voice = "longanyang";

  public static void streamAudioDataToSpeaker() {
    // 配置回调。
    ResultCallback<SpeechSynthesisResult> callback = new ResultCallback<SpeechSynthesisResult>() {
      @Override
      public void onEvent(SpeechSynthesisResult result) {
        // System.out.println("收到消息: " + result);
        if (result.getAudioFrame() != null) {
          // 在此添加音频处理逻辑。
          System.out.println(TimeUtils.getTimestamp() + " 收到音频");
        }
      }

      @Override
      public void onComplete() {
        System.out.println(TimeUtils.getTimestamp() + " 收到完成信号，语音合成结束。");
      }

      @Override
      public void onError(Exception e) {
        System.out.println("发生异常：" + e.toString());
      }
    };

    // 请求参数
    SpeechSynthesisParam param =
        SpeechSynthesisParam.builder()
            // 如果未配置环境变量，请将下一行替换为：.apiKey("sk-xxx")
            .apiKey(System.getenv("DASHSCOPE_API_KEY"))
            .model(model)
            .voice(voice)
            .format(SpeechSynthesisAudioFormat
                .PCM_22050HZ_MONO_16BIT) // 流式合成请使用 PCM 或 MP3 格式。
            .build();
    SpeechSynthesizer synthesizer = new SpeechSynthesizer(param, callback);
    try {
      for (String text : textArray) {
        // 发送文本片段，音频通过 onEvent 实时返回。
        synthesizer.streamingCall(text);
      }
      // 等待流式合成完成。
      synthesizer.streamingComplete();
    } catch (Exception e) {
      throw new RuntimeException(e);
    } finally {
      // 任务完成后关闭 WebSocket 连接。
      synthesizer.getDuplexApi().close(1000, "bye");
    }

    // 首次调用的首包延迟包含 WebSocket 建连时间。
    System.out.println(
        "[Metric] Request ID: "
            + synthesizer.getLastRequestId()
            + ", First-packet latency (ms): "
            + synthesizer.getFirstPackageDelay());
  }

  public static void main(String[] args) {
    Constants.baseWebsocketApiUrl = "wss://dashscope.aliyuncs.com/api-ws/v1/inference";
    streamAudioDataToSpeaker();
    System.exit(0);
  }
}

SpeechSynthesisParam param = SpeechSynthesisParam.builder()
  .model("cosyvoice-v3-flash")
  .voice("longanyang")
  .format(SpeechSynthesisAudioFormat.WAV_8000HZ_MONO_16BIT) // 音频格式和采样率
  .volume(50) // 音量：[0, 100]
  .speechRate(1.0f) // 语速：[0.5, 2]
  .pitchRate(1.0f) // 音调：[0.5, 2]
  .build();

ResultCallback<SpeechSynthesisResult> callback = new ResultCallback<SpeechSynthesisResult>() {
  @Override
  public void onEvent(SpeechSynthesisResult result) {
    System.out.println("Request ID: " + result.getRequestId());
    // 实时处理音频片段（如播放或写入缓冲区）。
  }

  @Override
  public void onComplete() {
    System.out.println("任务完成");
    // 处理合成完成逻辑（如释放播放器）。
  }

  @Override
  public void onError(Exception e) {
    System.out.println("任务失败：" + e.getMessage());
    // 处理异常（网络错误或服务端错误码）。
  }
};