Flutter

flutter pub add tencent_rtc_sdk             #安装 TRTC SDK
flutter pub add tencent_cloud_chat_sdk      #安装 IM SDK

# 在 pubspec.yaml 中找到 dependencies 添加以下依赖
dependencies:
  # 可在 https://pub.dev/packages/tencent_rtc_sdk 上查看 trtc sdk 的最新版本并使用
  tencent_rtc_sdk: "最新版本"
  # 可在 https://pub.dev/packages/tencent_cloud_chat_sdk 上查看 im sdk 的最新版本并使用
  tencent_cloud_chat_sdk: "最新版本"

flutter pub get

// 从即时通信 IM 控制台获取应用 SDKAppID。
int sdkAppID = 0;
// 添加 V2TimSDKListener 的事件监听器
V2TimSDKListener sdkListener = V2TimSDKListener(
  onConnecting: () {
    debugPrint("IM SDK 正在连接到腾讯云服务器");
  },
  onConnectSuccess: () {
    debugPrint("IM SDK 已经成功连接到腾讯云服务器");
  },
);
// 初始化SDK
V2TimValueCallback<bool> initSDKRes =
    await TencentImSDKPlugin.v2TIMManager.initSDK(
  sdkAppID: sdkAppID, // SDKAppID
  loglevel: LogLevelEnum.V2TIM_LOG_ALL, // 日志登记等级
  listener: sdkListener, // 事件监听器
);
if (initSDKRes.code == 0) {
  //初始化成功
}
// 反初始化 IM SDK
V2TimCallback uninitSDKRes = await TencentImSDKPlugin.v2TIMManager.unInitSDK();
if(uninitSDKRes.code == 0) {
  //反初始化成功
}

// 添加 V2TimSignalingListener 信令的事件监听器
V2TimSignalingListener signalListener = V2TimSignalingListener(
  onInviteeAccepted: (String inviteID, String invitee, String data) {
    // 远端接受通信请求回调逻辑
  },
);
TencentImSDKPlugin.v2TIMManager.getSignalingManager().addSignalingListener(listener: signalListener);
// 移除信令的事件监听器
TencentImSDKPlugin.v2TIMManager.getSignalingManager().removeSignalingListener(listener: signalListener);

// 创建 TRTC 实例
TRTCCloud trtcCloud = await TRTCCloud.sharedInstance();
// 来自 SDK 的各类事件通知（比如：错误码，警告码，音视频状态参数等）
TRTCCloudListener listener = TRTCCloudListener(
  // 根据需要实现对应的回调
  onError: (errCode, errMsg) {
    debugPrint("TRTC Error: $errCode, $errMsg");
  },
  onWarning: (int warningCode, String warningMsg){
    debugPrint("TRTC Warning: $warningCode, $warningMsg");
  }
);
// 添加 TRTC 事件监听器
trtcCloud.registerListener(listener);
// 移除 TRTC 事件监听器
trtcCloud.unRegisterListener(listener);
// 销毁 TRTC 实例
TRTCCloud.destroySharedInstance();

// 登录：userID 可自定义，userSig 参见步骤1生成获取
String userID = "your user id";
String userSig = "userSig from your server";
V2TimCallback loginRes = await TencentImSDKPlugin.v2TIMManager.login(userID: userID, userSig: userSig);
if(loginRes.code == 0){
  // 登录成功逻辑
} else {
  // 登出失败逻辑
  // 如果返回以下错误码，表示使用 UserSig 已过期，请您使用新签发的 UserSig 进行再次登录。
  // 1. ERR_USER_SIG_EXPIRED（6206）
  // 2. ERR_SVR_ACCOUNT_USERSIG_EXPIRED（70001）
  // 注意：其他的错误码，请不要在这里调用登录接口，避免 IM SDK 登录进入死循环。
  debugPrint("IM Login Error: ${loginRes.code}, ${loginRes.desc}");
}

V2TimCallback logoutRes = await TencentImSDKPlugin.v2TIMManager.logout();
if(logoutRes.code == 0){
  // 登出成功逻辑
} else {
  // 登出失败逻辑
  debugPrint("IM Login Error: ${logoutRes.code}, ${logoutRes.desc}");
}

V2TimValueCallback<String> createRes = 
  await TencentImSDKPlugin.v2TIMManager.getGroupManager().createGroup(
    groupID: groupID, groupType: "AVChatRoom", groupName: groupName
);

if(createRes.code == 0) {
  // 如果没有自定义群组 ID，则创建成功后回调返回系统会自动分配的 groupID
  String groupID = createRes.data!;
} else {
  // 创建群组失败
}

TencentImSDKPlugin.v2TIMManager.addGroupListener(
  listener: V2TimGroupListener(
    onGroupCreated: (String groupID) {
      // 群创建回调，groupID 为新创建群组的 ID
    },
  )
);

V2TimCallback joinRes = 
  await TencentImSDKPlugin.v2TIMManager.joinGroup(groupID: groupID, message: message);
if(joinRes.code == 0) {
  // 加入群组成功
} else {
  // 加入群组失败
}

TencentImSDKPlugin.v2TIMManager.addGroupListener(
  listener: V2TimGroupListener(
    onMemberEnter: (String groupID, List<V2TimGroupMemberInfo> memberList) {
      // 有人加入群组
    },
  )
);

TRTCParams params = TRTCParams(
  sdkAppId: SDKAPPID,           // TRTC应用标识, 在控制台获取
  userSig: USERSIG,             // TRTC鉴权凭证, 在服务端生成
  strRoomId: roomId,            // 以字符串房间号为例，建议和 IM 群组号保持一致
  userId: userId,               // 用户名, 建议和IM保持同步
  role: TRTCRoleType.audience   // 语聊互动场景进房需指定用户角色
);
// 场景为语音聊天房
trtcCloud.enterRoom(params, TRTCAppScene.voiceChatRoom);

trtcCloud.registerListener(
  TRTCCloudListener(
    onEnterRoom: (int result) {
      if (result > 0 ) {
        // 进房成功，result 代表加入房间所消耗的时间（毫秒）
      } else {
        // 进房失败，result 代表错误码
      }
    }
  )
);

V2TimCallback quitRes = await TencentImSDKPlugin.v2TIMManager.quitGroup(groupID: groupID);
if(quitRes.code == 0) {
  // 退出群组成功
} else {
  // 退出群组失败
}

TencentImSDKPlugin.v2TIMManager.addGroupListener(
  listener: V2TimGroupListener(
    onQuitFromGroup: (String groupID) {
      // 退群者会收到离开群组回调
    },
    onMemberLeave: (String groupID, V2TimGroupMemberInfo member) {
      // 群组内其他成员会收到群成员离开群组回调
    },
  )
);

void _exitRoom() {
  trtcCloud.stopLocalAudio();
  trtcCloud.exitRoom();
}

TRTCCloudListener(
  onExitRoom: (int reason) {
    if (reason == 0) {
      debugPrint("主动调用 exitRoom 退出房间");
    } else if (reason == 1) {
      debugPrint("被服务器踢出当前房间");
    } else if (reason == 2) {
      debugPrint("当前房间整个被解散");
    }
  }
);

V2TimCallback dismissRes = 
  await TencentImSDKPlugin.v2TIMManager.dismissGroup(groupID: groupID);
if(dismissRes.code == 0) {
  // 解散群组成功
} else {
  // 解散群组失败
}

TencentImSDKPlugin.v2TIMManager.addGroupListener(
  listener: V2TimGroupListener(
    onGroupDismissed: (String groupID, V2TimGroupMemberInfo opUser,) {
      // 群被解散回调
    }
  )
);

// 听众发送上麦请求，userId 为主播 ID，data 可传入标识信令的 json
V2TimValueCallback<String> inviteRes =  
  await TencentImSDKPlugin.v2TIMManager.getSignalingManager().invite(
    invitee: userId, data: data, timeout: timeout, onlineUserOnly: true, offlinePushInfo: null);
if(inviteRes.code == 0){
  // 发送请求上麦请求成功
} else {
  // 发送请求上麦请求失败
}

// 主播收到上麦请求, inviteID 为该条请求 ID，inviter 为请求者 ID
TencentImSDKPlugin.v2TIMManager.getSignalingManager().addSignalingListener(
  listener: V2TimSignalingListener(
    onReceiveNewInvitation: (String inviteID, String inviter,
                             String groupID, List<String> inviteeList, String data) {
      debugPrint("received invitation: $inviteID from $inviter");
    }
  )
);

// 同意上麦请求
V2TimCallback acceptRes = 
  await TencentImSDKPlugin.v2TIMManager.getSignalingManager().accept(inviteID: inviteID, data: data);
if(acceptRes.code == 0) {
  // 同意上麦请求成功
} else {
  // 同意上麦请求失败
}

// 拒绝上麦请求
V2TimCallback rejectRes =
  await TencentImSDKPlugin.v2TIMManager.getSignalingManager().reject(inviteID: inviteID, data: data);
if(rejectRes.code == 0) {
  // 拒绝上麦请求成功
} else {
  // 拒绝上麦请求失败
}

// 本地保存的全量麦位信息列表
List<SeatInfo> _SeatInfoList;

// 同意上麦请求的回调
TencentImSDKPlugin.v2TIMManager.getSignalingManager().addSignalingListener(
  listener: V2TimSignalingListener(
    onInviteeAccepted: (String inviteID, String invitee, String data) {
      debugPrint("received accept invitation: $inviteID from $invitee");
      _takeSeat(seatIndex);
    }
  )
);

void _takeSeat(int seatIndex) async {
  // 创建麦位信息实例，存储修改后的麦位信息
  SeatInfo localInfo = _SeatInfoList[seatIndex];
  SeatInfo seatInfo = new SeatInfo(
    status: SeatInfo.STATUS_USED,
    mute: localInfo.mute,
    userId: _UserId
  );

  // 将麦位信息对象序列化为 JSON 格式
  String jsonStr = json.encode(seatInfo);
  Map<String, String> map = { "seat$seatIndex": jsonStr };

  // 设置群属性，已有该群属性则更新其 value 值，没有该群属性则添加该属性
  V2TimCallback groupAttrRes =
    await TencentImSDKPlugin.v2TIMManager.getGroupManager().setGroupAttributes(groupID: groupID, attributes: map);
  if(groupAttrRes.code == 0) { 
    // 修改群属性成功，切换 TRTC 角色并开始推流
    trtcCloud.switchRole(TRTCRoleType.anchor);
    trtcCloud.startLocalAudio(TRTCAudioQuality.defaultMode);
  } else {
    // 修改群属性失败，上麦失败
  }
}

// 本地保存的全量麦位信息列表
List<SeatInfo> _SeatInfoList;

// 主播端调用该接口修改群属性保存的麦位信息
void _pickSeat(String userId, int seatIndex) async {
  SeatInfo localInfo = _SeatInfoList[seatIndex];
  SeatInfo seatInfo = new SeatInfo(
    status: SeatInfo.STATUS_USED,
    mute: localInfo.mute,
    userId: userId
  );

  // 将麦位信息对象序列化为 JSON 格式
  String jsonStr = json.encode(seatInfo);
  Map<String, String> map = { "seat$seatIndex": jsonStr };

  // 设置群属性，已有该群属性则更新其 value 值，没有该群属性则添加该属性
  V2TimCallback groupAttrRes =
    await TencentImSDKPlugin.v2TIMManager.getGroupManager().setGroupAttributes(groupID: groupID, attributes: map);
  if(groupAttrRes.code == 0) { 
    // 修改群属性成功，触发 onGroupAttributeChanged 回调
    trtcCloud.switchRole(TRTCRoleType.anchor);
    trtcCloud.startLocalAudio(TRTCAudioQuality.defaultMode);
  } else {
    // 修改群属性失败，抱麦失败
  }
}

// 听众端收到群属性变更回调，匹配自身信息成功后开始推流
TencentImSDKPlugin.v2TIMManager.addGroupListener(
  listener: V2TimGroupListener(
    onGroupAttributeChanged: (String groupID, Map<String, String> groupAttributeMap) {
      // 上一次本地保存的全量麦位信息列表
      final List<SeatInfo> oldSeatInfoList = _SeatInfoList;
      // 最新从 groupAttributeMap 中解析的全量麦位信息列表
      final List<SeatInfo> newSeatInfoList = getSeatListFromAttr(groupAttributeMap, seatSize);
      // 遍历全量麦位信息列表，对比新旧麦位信息
      for (int i = 0; i < seatSize; i++) {
        SeatInfo oldInfo = oldSeatInfoList[i];
        SeatInfo newInfo = newSeatInfoList[i];
        if (oldInfo.status != newInfo.status && newInfo.status == SeatInfo.STATUS_USED) {
          if (newInfo.userId == _mUserId) {
            // 匹配自身信息成功，切换 TRTC 角色并开始推流
            trtcCloud.switchRole(TRTCRoleType.anchor);
            trtcCloud.startLocalAudio(TRTCAudioQuality.defaultMode);
          } else {
            // 更新本地麦位列表，渲染本地麦位视图
          }
        }
      } 
    }
  )
);

// 本地保存的全量麦位信息列表
List<SeatInfo> _SeatInfoList;

void _leaveSeat(int seatIndex) async {
  // 创建麦位信息实例，存储修改后的麦位信息
  SeatInfo localInfo = _SeatInfoList[seatIndex];
  SeatInfo seatInfo = new SeatInfo(
    status: SeatInfo.STATUS_UNUSED,
    mute: localInfo.mute,
    userId: ""
  );
    
  // 将麦位信息对象序列化为 JSON 格式
  String jsonStr = json.encode(seatInfo);
  Map<String, String> map = { "seat$seatIndex": jsonStr };
    
  // 设置群属性，已有该群属性则更新其 value 值，没有该群属性则添加该属性
  V2TimCallback groupAttrRes =
    await TencentImSDKPlugin.v2TIMManager.getGroupManager().setGroupAttributes(groupID: groupID, attributes: map);
  if(groupAttrRes.code == 0) { 
    // 修改群属性成功，切换 TRTC 角色并停止推流
    trtcCloud.switchRole(TRTCRoleType.audience);
    trtcCloud.stopLocalAudio();
  } else {
    // 修改群属性失败，抱麦失败
  }
}