async function init() {  // 从服务器获取临时密钥 - 参见下方服务器代码  const tokenResponse = await fetch("/session");  const data = await tokenResponse.json();  const EPHEMERAL_KEY = data.client_secret.value;  // 创建对等连接  const pc = new RTCPeerConnection();  // 设置播放模型返回的远程音频  const audioEl = document.createElement("audio");  audioEl.autoplay = true;  pc.ontrack = e => audioEl.srcObject = e.streams[0];  // 添加浏览器麦克风输入的本地音频轨道  const ms = await navigator.mediaDevices.getUserMedia({    audio: true  });  pc.addTrack(ms.getTracks()[0]);  // 设置用于发送和接收事件的数据通道  const dc = pc.createDataChannel("oai-events");  dc.addEventListener("message", (e) => {    // 这里接收实时服务器事件！    console.log(e);  });  // 使用会话描述协议(SDP)启动会话  const offer = await pc.createOffer();  await pc.setLocalDescription(offer);  const baseUrl = "https://newapi地址/v1/realtime";  const model = "gpt-4o-realtime-preview-2024-12-17";  const sdpResponse = await fetch(`${baseUrl}?model=${model}`, {    method: "POST",    body: offer.sdp,    headers: {      Authorization: `Bearer ${EPHEMERAL_KEY}`,      "Content-Type": "application/sdp"    },  });  const answer = {    type: "answer",    sdp: await sdpResponse.text(),  };  await pc.setRemoteDescription(answer);}init();

import express from "express";const app = express();// 创建一个端点用于生成临时令牌// 该端点与上面的客户端代码配合使用app.get("/session", async (req, res) => {  const r = await fetch("https://newapi地址/v1/realtime/sessions", {    method: "POST",    headers: {      "Authorization": `Bearer ${process.env.NEW_API_KEY}`,      "Content-Type": "application/json",    },    body: JSON.stringify({      model: "gpt-4o-realtime-preview-2024-12-17",      voice: "verse",    }),  });  const data = await r.json();  // 将从OpenAI REST API收到的JSON发送回客户端  res.send(data);});app.listen(3000);

// 从对等连接创建数据通道const dc = pc.createDataChannel("oai-events");// 监听数据通道上的服务器事件// 事件数据需要从JSON字符串解析dc.addEventListener("message", (e) => {  const realtimeEvent = JSON.parse(e.data);  console.log(realtimeEvent);});// 发送客户端事件：将有效的客户端事件序列化为// JSON，并通过数据通道发送const responseCreate = {  type: "response.create",  response: {    modalities: ["text"],    instructions: "Write a haiku about code",  },};dc.send(JSON.stringify(responseCreate));

import WebSocket from "ws";const url = "wss://地址/v1/realtime?model=gpt-4o-realtime-preview-2024-12-17";const ws = new WebSocket(url, {  headers: {    "Authorization": "Bearer " + process.env.NEW_API_KEY,    "OpenAI-Beta": "realtime=v1",  },});ws.on("open", function open() {  console.log("Connected to server.");});ws.on("message", function incoming(message) {  console.log(JSON.parse(message.toString()));});

/*注意：在浏览器等客户端环境中，我们建议使用WebRTC。但在Deno和Cloudflare Workers等类浏览器环境中，也可以使用标准WebSocket接口。*/const ws = new WebSocket(  "wss://newapi地址/v1/realtime?model=gpt-4o-realtime-preview-2024-12-17",  [    "realtime",    // 认证    "openai-insecure-api-key." + NEW_API_KEY,     // 可选    "openai-organization." + OPENAI_ORG_ID,    "openai-project." + OPENAI_PROJECT_ID,    // Beta协议，必需    "openai-beta.realtime-v1"  ]);ws.on("open", function open() {  console.log("Connected to server.");});ws.on("message", function incoming(message) {  console.log(message.data);});

// 接收服务器事件ws.on("message", function incoming(message) {  // 需要从JSON解析消息数据  const serverEvent = JSON.parse(message.data)  console.log(serverEvent);});// 发送事件，创建符合客户端事件格式的JSON数据结构const event = {  type: "response.create",  response: {    modalities: ["audio", "text"],    instructions: "Give me a haiku about code.",  }};ws.send(JSON.stringify(event));