npm install zego-express-engine-miniprogram

<view class="container">
  <!-- 本地推流（自己的画面） -->
  <live-pusher
    id="local-pusher"
    url="{{pushUrl}}"
    mode="RTC"
    autopush
    muted="{{isMuted}}"
    enable-camera="{{cameraOn}}"
    class="local-video"
  />

  <!-- 远端拉流（对方的画面） -->
  <live-player
    wx:for="{{remoteStreams}}"
    wx:key="streamID"
    src="{{item.playUrl}}"
    mode="RTC"
    autoplay
    class="remote-video"
  />
</view>

const ZegoExpressEngine = require('../../miniprogram_npm/zego-express-engine-miniprogram/index');

Page({
  data: {
    pushUrl: '',
    remoteStreams: [],
    isMuted: false,
    cameraOn: true,
  },

  onLoad(options) {
    this.roomID = options.roomID || 'room_001';
    this.userID = options.userID || `user_${Date.now()}`;
    this.streamID = `stream_${this.userID}`;
    this.initEngine();
  },

  initEngine() {
    this.engine = ZegoExpressEngine.createEngine(APP_ID, APP_SIGN, true, {});
    this.registerCallbacks();
    this.joinRoom();
  },

  registerCallbacks() {
    // 监听房间内流的变化
    this.engine.on('roomStreamUpdate', (roomID, updateType, streamList) => {
      if (updateType === 'ADD') {
        const newStreams = streamList.map(stream => ({
          streamID: stream.streamID,
          playUrl: this.engine.startPlayingStream(stream.streamID),
        }));
        this.setData({
          remoteStreams: [...this.data.remoteStreams, ...newStreams],
        });
      } else if (updateType === 'DELETE') {
        const deletedIDs = new Set(streamList.map(s => s.streamID));
        this.setData({
          remoteStreams: this.data.remoteStreams.filter(s => !deletedIDs.has(s.streamID)),
        });
      }
    });
  },

  async joinRoom() {
    // 登录房间
    await this.engine.loginRoom(this.roomID, token, {
      userID: this.userID,
      userName: `用户${this.userID}`,
    });

    // 拉取已在房间内的流
    const existingStreams = await this.engine.getRoomStreamList(this.roomID);
    const remoteStreams = existingStreams.map(stream => ({
      streamID: stream.streamID,
      playUrl: this.engine.startPlayingStream(stream.streamID),
    }));
    this.setData({ remoteStreams });

    // 开始推送本地流
    const pushUrl = this.engine.startPublishingStream(this.streamID);
    this.setData({ pushUrl });
  },

  // 静音切换
  toggleMute() {
    this.setData({ isMuted: !this.data.isMuted });
  },

  // 摄像头切换
  toggleCamera() {
    this.setData({ cameraOn: !this.data.cameraOn });
  },

  onUnload() {
    this.engine.stopPublishingStream();
    this.engine.logoutRoom(this.roomID);
    ZegoExpressEngine.destroyEngine();
  },
});

// 启动语音识别
wx.startVoiceRecognition({
  lang: 'zh_CN',
  success: () => {
    console.log('识别服务启动成功');
  },
  fail: (err) => {
    console.error('启动失败', err);
  }
});

// 实时接收识别结果
wx.onVoiceRecognitionResult((res) => {
  this.setData({
    transcription: res.result
  });
});