实现音频通话
功能简介
本文将介绍如何快速实现一个简单的实时音频通话。
- ZEGO 提供了
<zego-pusher>和<zego-player>,可以帮助开发者更快地实现实时音频。用户也可以选择使用微信原生小程序推拉流组件<live-pusher>和<live-player>进行推拉流,参考 使用微信原生组件实现通话。 - 微信开发者工具只支持本地预览,不支持推拉流,推荐使用真机调试。
相关概念解释:
- ZEGO Express SDK:由 ZEGO 提供的实时音频 SDK,能够为开发者提供便捷接入、高清流畅、多平台互通、低延迟、高并发的音频服务。
- 推流:把采集阶段封包好的音频数据流推送到 ZEGO 实时音频云的过程。
- 拉流:从 ZEGO 实时音频云将已有音频数据流拉取播放的过程。
- 房间:是 ZEGO 提供的音频空间服务,用于组织用户群,同一房间内的用户可以互相收发实时音频及消息。
- 用户需要先登录某个房间,才能进行推流、拉流操作。
- 用户只能收到自己所在房间内的相关消息(用户进出、音频流变化等)。
更多相关概念请参考 术语说明。
如下实现流程支持的是 SDK 需为 2.10.0 及以上版本,如使用 2.10.0 以下版本的 SDK 请参考旧版方案 实现流程。
前提条件
在实现基本的实时音频功能之前,请确保:
- 已在项目中集成 ZEGO Express SDK,详情请参考 微信小程序 - 集成 SDK。
- 已在 ZEGO 控制台 创建项目,申请有效的 AppID 和 Server 地址,详情请参考 控制台 - 项目信息。
实现流程
用户通过 ZEGO Express SDK 进行音频通话的基本流程为:
用户 A、B 加入房间,用户 B 预览并将音频流推送到 ZEGO 云服务(推流),用户 A 收到用户 B 推送音频流的通知之后,在通知中播放用户 B 的音频流(拉流)。

配置微信小程序后台
在初始化 SDK 前,需要在 微信公众平台 中进行如下配置:
-
服务器域名配置:在“小程序后台 > 开发管理 > 开发设置 > 服务器域名”中,按照协议分类,将即构
Server 地址、LogUrl、以及用户业务需要用到的地址填到指定的“socket合法域名”或“request合法域名”中,详情请参考 控制台 - 项目信息。注意- 控制台提供的
Server 地址格式为:wss://xxxxxxxxxx.com/ws。在 微信公众平台 填写时,不能直接复制原地址,需要删除原地址的 “/ws”,应填入地址的格式为:wss://xxxxxxxxxx.com。 - 控制台提供的
LogUrl地址格式为:https://xxxxxxxxxx.com/httplog。在 微信公众平台 填写时,不能直接复制原地址,需要删除原地址的 “/httplog”,应填入地址的格式为:https://xxxxxxxxxx.com。 - 如果您使用 3.0.0 或以上版本(包括 3.6.0 及以上版本)的 SDK,还需要添加一些 socket 域名,详情请参考 3.0.0 及以上版本升级指南。

- 控制台提供的
-
相关功能开启:在“小程序后台 > 开发管理 > 接口设置 > 接口权限”中,打开 实时播放音频流 和 实时录制音频流 功能开关。

-
由于使用麦克风涉及到用户隐私,请参考微信官方文档 配置小程序用户隐私保护指引 补充相应用户隐私保护指引。否则,当您的项目部署到正式环境时,将无法推流。
初始化
1. 创建引擎
创建 ZegoExpressEngine 引擎实例,将申请到的 AppID 传入参数 “appID”,将获取到的 Server 地址传入参数 “server”。
// 初始化实例
zg = new ZegoExpressEngine(appID, server);2.设置回调
创建引擎后,开发者可根据实际需要,通过引擎实例的 on 方法设置回调。
为避免错过事件通知,建议在创建引擎后立即监听回调
zg.on('roomStateUpdate', (roomID, state, errorCode, extendedData) => {
if (state == 'DISCONNECTED') {
// 与房间断开了连接
// ...
}
if (state == 'CONNECTING') {
// 与房间尝试连接中
// ...
}
if (state == 'CONNECTED') {
// 与房间连接成功
// ...
}
})我在房间内的连接状态变化通知
roomStateUpdate:本地调用 loginRoom 加入房间时,您可通过监听该回调实时监控自己在本房间内的连接状态。
zg.on('roomStateUpdate', (roomID, state, errorCode, extendedData) => {
if (state == 'DISCONNECTED') {
// 与房间断开了连接
// ...
}
if (state == 'CONNECTING') {
// 与房间尝试连接中
// ...
}
if (state == 'CONNECTED') {
// 与房间连接成功
// ...
}
})| 状态 | 含义 |
|---|---|
| DISCONNECTED | 未连接状态,在登录房间前/退出房间后进入该状态。如果登录房间的过程中出现稳态异常,比如 AppID 不正确,或者有相同用户名在其他地方登录导致本端被 KickOut,都会进入该状态。 |
| CONNECTING | 正在请求连接状态,登录房间动作执行成功后会进入该状态。通常情况下,可通过该状态进行 UI 界面的展示。如果是因为网络质量不佳产生的中断,SDK 内部会进行重试,也会进入正在请求连接状态。 |
| CONNECTED | 连接成功状态,成功登录房间后进入该状态。此时,用户可以正常收到房间内的用户和流信息增删变化的回调通知。 |
其他用户进出房间的通知
roomUserUpdate:同一房间内的其他用户进出房间时,您可通过此回调收到通知。登录房间后,当房间内有用户新增或删除时,SDK 会通过该回调通知。
只有调用 loginRoom 接口登录房间时传入 ZegoRoomConfig 配置,且 “userUpdate” 参数取值为 “true” 时,用户才能收到 roomUserUpdate 回调。
// 用户状态更新回调
zg.on('roomUserUpdate', (roomID, updateType, userList) => {
console.warn(
`roomUserUpdate: room ${roomID}, user ${updateType === 'ADD' ? 'added' : 'left'} `,
JSON.stringify(userList),
);
});房间内流状态变更的通知
roomStreamUpdate:流状态更新回调。登录房间后,当房间内有用户新推送或删除音频流时,SDK 会通过该回调通知。
// 流状态更新回调
zg.on('roomStreamUpdate', async (roomID, updateType, streamList, extendedData) => {
if (updateType == 'ADD') {
// 流新增,开始拉流
} else if (updateType == 'DELETE') {
// 流删除,停止拉流
}
});用户推送音频流的状态通知
-
推流状态事件
// 推流后,服务器主动推过来的,流状态更新 // NO_PUBLISH:未推流状态,PUBLISH_REQUESTING:正在请求推流状态,PUBLISHING:正在推流状态 // state: "PUBLISHING" | "NO_PUBLISH" | "PUBLISH_REQUESTING"; zg.on("publisherStateUpdate", (result) => { console.log("publishStateUpdate", result.state); }); -
推流网络事件
// SDK 推流网络质量回调 zg.on("publishQualityUpdate", (streamID, publishStats) => { console.log("publishQualityUpdate", streamID, publishStats); });
用户拉取音频流的状态通知
-
拉流状态事件
// 服务器主动推过来的流的播放状态 // 视频播放状态通知;state: "NO_PLAY" | "PLAY_REQUESTING" | "PLAYING"; zg.on("playerStateUpdate", (result) => { console.log("playStateUpdate", result.state); }); -
拉流网络事件
// SDK 拉流网络质量回调 zg.on("playQualityUpdate", (playStreamID, playStats) => { console.log("playQualityUpdate", playStreamID, playStats); });
登录房间
1. 获取登录 Token
登录房间需要用于验证身份的 Token,获取方式请参考 用户权限控制。如需快速调试,建议使用控制台生成的临时 Token,生成临时 Token 的具体操作请参考 控制台 - 项目管理。
2. 登录房间
您可以调用 SDK 的 loginRoom 接口,传入房间 ID 参数 “roomID”、“token” 和用户参数 “user”,登录房间。如果房间不存在,调用该接口时会创建并登录此房间。
您可通过监听 roomStateUpdate 回调实时监控自己在本房间内的连接状态,具体请参考 常见通知回调 中的“我在房间内的连接状态变化通知”。
roomID 和 user 的参数由您本地生成,但是需要满足以下条件:
- 同一个 AppID 内,需保证 “roomID” 全局唯一。
- 同一个 AppID 内,需保证 “userID” 全局唯一,建议开发者将 “userID” 与自己业务的账号系统进行关联。
- “userID” 必须与生成 token 时传入的 userID 保持一致,否则登录失败。
为避免错过任何通知,建议在登录房间前先设置监听回调(如房间状态、用户状态、流状态、推拉流状态等),具体请参考 常见通知回调。
// 登录房间,成功则返回 true
const result = await zg.loginRoom(roomID, token, {
userID: "user1", // userID,需用户自己定义,保证全局唯一,建议设置为业务系统中的用户唯一标识
userName: "user1_name" // userName 用户名
}, {
userUpdate: true // 是否接收用户进出房间的回调,设置为 true 才能接收到房间内其他用户进出房间的回调
});初始化小程序组件实例
调用 initContext 接口初始化小程序组件。
组件中用于存储推流属性 pusher 和拉流属性列表 playerList 的两个字段需要传给 SDK,SDK 后续将通过传入的两个字段对相应的推拉流作状态及视图更新处理。
- pusher 字段中的属性值请参考 ZegoWxPusherAttributes。
- playerlist 字段中的属性值请参考 ZegoWxPlayerAttributes。
zg.initContext({
wxContext: this,
pushAtr: "pusher", // pushAtr 配置的变量名,必须与传给 <zego-pusher> 组件 pusher 属性的变量名完全一致。
playAtr: "playerList" // playAtr 配置的变量名,必须与传给 <zego-player> 组件 playerList 属性的变量名完全一致。
})创建对应业务场景的 WXML
- 复制组件代码到项目工程中
将示例代码 components 文件夹下的 zego-player 和 zego-pusher 两个文件夹,复制到您的业务代码 components 文件夹中。
- 在项目 JSON 文件中引入组件
根据您的项目结构,在对应的 JSON 文件中引入 <zego-pusher> 和 <zego-player> 组件。
// 在 JSON 文件中引入组件
{
"usingComponents": {
"zego-pusher": "../../components/zego-pusher/zego-pusher",
"zego-player": "../../components/zego-player/zego-player"
}
}在 WXML 文件中使用推拉流组件
在 WXML 文件中使用推拉流组件 <zego-pusher> 和 <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}}" />推送音频流到 ZEGO 音视频云
必须完成初始化小程序组件实例和创建业务场景的 WXML 之后,才能调用 SDK 接口创建推流和拉流实例。
用户先获取 <zego-pusher> 组件的实例对象,再调用该对象的 startPush 方法传入 SDK 实例和 streamID 参数即可发起推流。
// 获取 <zego-pusher> 组件实例对象
const zegoPusher = this.selectComponent("#zegoPusher");
// 调用 <zego-pusher> 实例对象的 startPush 方法进行推流。zg 为 SDK 实例对象,"streamID_xxx" 为 streamID。
await zegoPusher.startPush(zg, "streamID_xxx",undefined,{enableCamera: false});-
您可通过监听 publisherStateUpdate 回调知晓推流是否成功,具体请参考 常见通知回调 中的“用户推送音频流的状态通知”。
-
streamID由您本地生成,但是需要保证:- 同一个 AppID 下,
streamID全局唯一。如果同一个 AppID 下,不同用户各推了一条streamID相同的流,后推流的用户推流失败。 streamID长度不超过 256 字节的字符串。仅支持数字、英文字符和 "-"、"_"。
- 同一个 AppID 下,
拉取其他用户的音频
进行视频通话时,我们需要拉取到其他用户的音频。
用户先获取 <zego-player> 组件实例对象,再调用 该对象的 startPlay 方法传入 SDK 实例和 streamID 参数即可发起推流。
远端用户推送的 “streamID” 可以从 roomStreamUpdate 回调中获得,具体回调设置请参考 常见通知回调 中的“房间内流状态变更的通知”。
// 在 SDK 的回调 roomStreamUpdate 中获取拉流 streamID
// 当房间内其他用户推的流增加或减少时触发
zg.on("roomStreamUpdate", async (roomID, updateType, streamList) => {
if (updateType === "ADD") {
// ----- 使用 zego-player 组件的 startPlay 接口播放 -----
for (let i = 0; i < streamList.length; i++) {
try {
// 设置 zego-player 组件属性
const zegoPlayerAttr = {
componentID: `zego-${streamList[i].streamID}`,
playerId: streamList[i].streamID
}
// 添加到组件列表中
this.data.zegoPlayerList.push(zegoPlayerAttr)
// 更新,并渲染组件列表
this.setData({
zegoPlayerList:this.data.zegoPlayerList
})
// 在zegoPlayerList更新后, 将zg实例传入对应的流id的组件内
const zegoPlayer = this.selectComponent(`#${zegoPlayerAttr.componentID}`)
if (!zegoPlayer) return console.warn("未能获取到组件节点", streamList[i].streamID)
// 开始播放
console.warn("开始拉流", roomID, streamList[i].streamID);
await zegoPlayer.startPlay(zg, streamList[i].streamID)
} catch (error) {
console.error("拉流出错,等待房间重连恢复", error)
}
}
} else if (updateType === 'DELETE') {
// 流删除,停止拉流
}
});如果用户在音频通话的过程中遇到相关错误,可查询 常见错误码。
停止音频通话
停止推送和拉取音频流
1. 停止推流
用户先获取 <zego-pusher> 组件实例对象,再调用该对象的 stopPush 方法结束拉流。
// 停止推流
// 获取 <zego-pusher> 组件实例对象
const zegoPusher = this.selectComponent("#zegoPusher");
// 调用 <zego-pusher> 实例对象的 stopPush 方法停止推流。
await zegoPusher.stopPush();2. 停止拉流
用户先获取 <zego-player> 组件实例对象,再调用该对象的 stopPlay 方法结束拉流。
// 停止拉流
// 获取 <zego-player> 组件实例对象
const zegoPlayer = this.selectComponent(`#${zegoPlayerAttr.componentID}`);
// 调用 <zego-player> 实例对象的 stopPlay 方法停止拉流。
await zegoPlayer.stopPlay();3. 退出房间
调用 SDK 的 logoutRoom 接口退出房间。
zg.logoutRoom(roomID);4. 销毁引擎
如果用户彻底不使用音频功能时,可调用 destroyEngine 接口销毁引擎,释放麦克风、摄像头、内存、CPU 等资源。
zg.destroyEngine();
zg = null;视频通话 API 调用时序
整个推拉流过程的 API 调用时序可参考下图:
调试视频通话功能
在真机中运行项目,运行成功后,可以看到本端视频画面。
为方便体验,ZEGO 提供了一个 Web 端调试示例,在该页面下,输入相同的 AppID、RoomID,输入不同的 UserID、以及对应的 Token,即可加入同一房间与真机设备互通。当成功开始音频通话时,可以听到远端的音频,看到远端的视频画面。
错误码
如果需要了解 API 返回的错误码,请参考 常见错误码。
