快速发起语音通话

import { ZegoExpressEngine } from "zego-express-engine-webrtc";

const appID = 1234567 // 从即构控制台获取
const server = 'xxx' // 从即构控制台获取

// 实例化 ZegoExpressEngine 传入 appId 和 server 等配置
// !mark
const zg = new ZegoExpressEngine(appID, server);
// 检查系统要求
// !mark
const checkSystemRequirements = async () => {
    // 检测是否支持webRTC
    const rtc_sup = await zg.checkSystemRequirements("webRTC");
    if (!rtc_sup.result) {
      // 浏览器不支持webrtc
  }
    // 检测是否开启麦克风权限
    const mic_sup = await zg.checkSystemRequirements("microphone");
    if (!mic_sup.result) {
      // 未开启麦克风权限
  }
}
checkSystemRequirements()

import { ZegoExpressEngine } from "zego-express-engine-miniprogram";

const appID = 1234567 // 从即构控制台获取
const server = 'xxx' // 从即构控制台获取的 Server 地址

// 实例化 ZegoExpressEngine 传入 appId 和 server 等配置
// !mark
const zg = new ZegoExpressEngine(appID, server);
// 初始化小程序组件实例
zg.initContext({
  wxContext: context,
  pushAtr: "pusher", // pushAtr 配置的变量名，必须与传给 <zego-pusher> 组件 pusher 属性的变量名完全一致。
  playAtr: "playerList" // playAtr 配置的变量名，必须与传给 <zego-player> 组件 playerList 属性的变量名完全一致。
})

// 检查系统要求
// !mark
const checkSystemRequirements = async () => {
  const rtc_sup = await zg.checkSystemRequirements();
  if (res.code === 10002) {
    // 未开启麦克风权限
  }
  if (res.code === 10001) {
    // 当前微信版本过低，无法使用相关组件
  }
}
checkSystemRequirements()

// 在 JSON 文件中引入组件
{
  "usingComponents": {
    "zego-pusher": "../../components/zego-pusher/zego-pusher",
    "zego-player": "../../components/zego-player/zego-player"
  }
}

// 在 WXML 文件中使用组件
// 传给 <zego-pusher> 组件 pusher 属性的变量名，必须与 initContext 配置中 pushAtr 的参数值完全一致。
  <zego-pusher id="zegoPusher" pusher="{{pusher}}" />
// 传给 <zego-player> 组件 playerList 属性的变量名，必须与 initContext 配置中 playAtr 的参数值完全一致。zegoPlayerList 见 “拉取其他用户的音频” 章节。
  <zego-player wx:for="{{zegoPlayerList}}" wx:key="id" id="{{item.componentID}}" playerId="{{item.playerId}}" playerList="{{playerList}}" />

客户端登录房间并推流

const userId = "" // 登录 ZEGO Express SDK房间用户ID
const roomId = "" // RTC 房间 ID
const userStreamId = "" // 用户推流 ID
async function enterRoom() {
  try {
    // 生成 RTC Token
    const token = await Api.getToken();
    // 登录房间
    await zg.loginRoom(roomId, token, {
      userID: userId,
      userName: "",
    });

    // 创建本地音频流
    const localStream = await zg.createZegoStream({
      camera: {
        video: false,
        audio: true,
      },
    });
    if (localStream) {
// !mark(1:2)
      // 推送本地流
      await zg.startPublishingStream(userStreamId, localStream);
    }
  } catch (error) {
    console.error("进入房间失败:", error);
    throw error;
  }
}
enterRoom()

客户端登录房间并推流

const userId = "" // 登录 ZEGO Express SDK房间用户ID
const roomId = "" // RTC 房间 ID
const userStreamId = "" // 用户推流 ID
async function enterRoom() {
  try {
    // 生成 RTC Token
    const token = await Api.getToken();
    // 登录房间
    await zg.loginRoom(roomId, token, {
      userID: userId,
      userName: "",
    });

    // 创建本地音频流
    const zegoPusher = this.selectComponent("#zegoPusher");
// !mark(1:2)
    // 推送本地流
    await zegoPusher.startPush(zg, userStreamId, {}, {enableCamera: false, mode: 'RTC'});
  } catch (error) {
    console.error("进入房间失败:", error);
    throw error;
  }
}
enterRoom()

客户端拉智能体的流

// 监听远端流更新事件
function setupEvent() {
  zg.on("roomStreamUpdate",
    async (roomID, updateType, streamList) => {
      if (updateType === "ADD" && streamList.length > 0) {
        try {
          for (const stream of streamList) {
            // 拉智能体流
// !mark
            const mediaStream = await zg.startPlayingStream(stream.streamID);
            if (!mediaStream) return;
            const remoteView = await zg.createRemoteStreamView(mediaStream);
            if (remoteView) {
             // 这里需要页面上有个id为remoteSteamView的容器接收智能体流
              remoteView.play("remoteSteamView", {
                enableAutoplayDialog: false,
              });
            }
          }
        } catch (error) {
          console.error("拉流失败:", error);
        }
      }
    }
  );
}

客户端拉智能体的流

// 监听远端流更新事件
function setupEvent() {
  zg.on("roomStreamUpdate",
    async (roomID, updateType, streamList) => {
      if (updateType === "ADD" && streamList.length > 0) {
        try {
          for (const stream of streamList) {
            // 设置 zego-player 组件属性
            const zegoPlayerAttr = {
              componentID: `zego-${stream.streamID}`,
              playerId: stream.streamID
            };
            // 更新，并渲染组件列表
            this.setData({
              zegoPlayerList: this.data.zegoPlayerList
            })
            const zegoPlayer = wxContext.selectComponent(`#${zegoPlayerAttr.componentID}`);
            if (zegoPlayer) {
// !mark
              await zg.startPlayingStream(zegoPlayer, stream.streamID);
            }
          }
        } catch (error) {
          console.error("拉流失败:", error);
        }
      }
    }
  );
}

// 退出房间
async function stopCall() {
  try {
// !mark
    const response = await fetch(`${YOUR_SERVER_URL}/api/stop`, { // YOUR_SERVER_URL 为您的业务后台地址
      method: 'POST',
      headers: {
        'Content-Type': 'application/json',
      }
    });

    const data = await response.json();
    console.log('结束通话结果:', data);
    return data;
  } catch (error) {
    console.error('结束通话失败:', error);
    throw error;
  }
}
stopCall();
zg.destroyStream(localStream);
// !mark
zg.logoutRoom();

// 退出房间
async function stopCall() {
  try {
// !mark
    const response = await fetch(`${YOUR_SERVER_URL}/api/stop`, { // YOUR_SERVER_URL 为您的业务后台地址
      method: 'POST',
      headers: {
        'Content-Type': 'application/json',
      }
    });

    const data = await response.json();
    console.log('结束通话结果:', data);
    return data;
  } catch (error) {
    console.error('结束通话失败:', error);
    throw error;
  }
}
stopCall();
zg.stopPublishingStream();
if (zegoPlayerList.length) {
  for (const player of zegoPlayerList) {
    zg.stopPlayingStream(player.playerId);
  }
}
// !mark
zg.logoutRoom();

// 引入必要的模块
import { ZegoExpressEngine } from "zego-express-engine-webrtc";
import { VoiceChanger } from "zego-express-engine-webrtc/voice-changer";

// 引入音量闪避插件包，请使用 3.11.0-aiagent.187.187 版本
// !mark(1:2)
import { AudioRendererManager } from "/AudioRendererManager/AudioRendererManager";
import { MediaElementRenderer } from "/AudioRendererManager/mediaElementRenderer";

// 加载音频处理模块，需要在 new ZegoExpressEngine 前调用
ZegoExpressEngine.use(VoiceChanger);

// 实例化 ZegoExpressEngine，设置房间的使用场景为高品质语聊房场景
// !mark
const zg = new ZegoExpressEngine(appid, server, { scenario: 7 })

// 传统音频 3A 处理，SDK 默认开启

// 创建本地媒体流
const localStream = await zg.createZegoStream();

// 开启音量闪避
zg.callExperimentalAPI({
  method: "enableVolumeDucking",
  params: {
    localStream,
    enable: true
  }
});

// 将播放器传入音量闪避插件包
let renderer;
zg.callExperimentalAPI({ method: "getAudioContext" }).then((ac) => {
  const audioMgr = AudioRendererManager.create(ac);
  // 获取播放器元素
  const audio = document.querySelector("audio");
  renderer = audioMgr.getMediaElementRenderer(audio);
});

// 注册音量闪避更新回调
zg.callExperimentalAPI({ method: "onVolumeDuckingUpdate", params: {} });
zg.on("recvExperimentalAPI", (result) => {
 const { method, content } = result;
 if (method === "onVolumeDuckingUpdate") {
  console.warn("onVolumeDuckingUpdate", content.gain);
  // 设置智能体流音量为回调返回的 content.gain，假设 remoteView 为你在步骤 拉智能体流 时创建的 remoteView
  remoteView.setVolume(content.gain * 100); // volume 取值范围 [0,100]
  // 设置播放器音量为回调返回的 content.gain
  renderer.setVolume(content.gain * 100); // volume 取值范围 [0,100]
 }
});

// 推送本地媒体流，需要设置自动切换为可用的 videoCodec
await zg.startPublishingStream(userStreamId, localStream, {
  // !mark
  enableAutoSwitchVideoCodec: true,
});

// 检查系统要求
async function checkSystemRequirements() {
  // 检测是否支持WebRTC
  const rtcSupport = await zg.checkSystemRequirements("webRTC");
  if (!rtcSupport.result) {
    console.error("浏览器不支持WebRTC");
    return false;
  }

  // 检测麦克风权限
  const micSupport = await zg.checkSystemRequirements("microphone");
  if (!micSupport.result) {
    console.error("未获得麦克风权限");
    return false;
  }

  return true;
}

// 引入必要的模块
import { ZegoExpressEngine } from "zego-express-engine-webrtc";

// 实例化 ZegoExpressEngine
const zg = new ZegoExpressEngine(appID, server);

// 创建本地音频流
const zegoPusher = this.selectComponent("#zegoPusher");
// 推送本地流
// !mark
await zegoPusher.startPush(zg, userStreamId, {}, {enableCamera: false, mode: 'RTC'});

// 检查系统要求
const checkSystemRequirements = async () => {
  const rtc_sup = await zg.checkSystemRequirements();
  if (res.code === 10002) {
    // 未开启麦克风权限
    return false;
  }
  if (res.code === 10001) {
    // 当前微信版本过低，无法使用相关组件
    return false;
  }
  return true;
}