1.进入会议后，将获取token接口调整到第一顺序

2.初始化声网SDK，调用SDK加入会议室
2024-11-26 17:22:29 +08:00 · 2024-11-26 17:22:29 +08:00 · 15321c4d61
parent 68e8c5c1c9
commit 15321c4d61
4 changed files with 104 additions and 21 deletions
--- a/wgshare/lib/pages/homePage/home_logic.dart
+++ b/wgshare/lib/pages/homePage/home_logic.dart
@ -16,7 +16,7 @@ class HomeLogic extends GetxController with RequestToolMixin {
  }

  /// 直接进入会议（匿名登录）
-  void doHttpGetMeetingRoomList(int pageIndex, int pageSize) async {
+  Future<void> doHttpGetMeetingRoomList(int pageIndex, int pageSize) async {
    BaseStructureResult<MeetingRoomItem> res = await getClient().getMeetingRoomList(pageIndex,pageSize);
    if(null != res.data){
      if(state.pageIndex == 1){
--- a/wgshare/lib/pages/loginPage/login_logic.dart
+++ b/wgshare/lib/pages/loginPage/login_logic.dart
@ -26,7 +26,7 @@ class LoginLogic extends GetxController with RequestToolMixin {
  }

  /// 登录
-  void doHttpLogin() async {
+  Future<void> doHttpLogin() async {
    if(state.userNameController.text.isEmpty){
      ToastUtils.showError("请输入账号");
    }else if(state.passwordController.text.isEmpty){
@ -46,7 +46,7 @@ class LoginLogic extends GetxController with RequestToolMixin {
  }

  /// 直接进入会议（匿名登录）
-  void doHttpAnonymousLogin() async {
+  Future<void> doHttpAnonymousLogin() async {
    if(state.meetingCodeController.text.isEmpty){
      ToastUtils.showError("请输入会议号");
    }else if(state.meetingCodeController.text.length != 8){
--- a/wgshare/lib/pages/metting/meeting_main_logic.dart
+++ b/wgshare/lib/pages/metting/meeting_main_logic.dart
@ -1,6 +1,9 @@
 import 'dart:async';

+import 'package:agora_rtc_engine/agora_rtc_engine.dart';
+import 'package:flutter/foundation.dart';
 import 'package:get/get.dart';
+import 'package:permission_handler/permission_handler.dart';
 import 'package:signalr_core/signalr_core.dart';
 import 'package:wgshare/common/store/user_store.dart';

@ -16,14 +19,14 @@ class MeetingMainLogic extends GetxController with RequestToolMixin{
  final MeetingMainState state = MeetingMainState();

  @override
-  void onInit() async {
+  void onInit() {
    super.onInit();

    // 接收参数
    var data = Get.arguments;
    state.roomNumber.value = data["roomNumber"];

-    signalRSocket();
+    doHttpGetMeetingToken();
  }

  @override
@ -31,24 +34,22 @@ class MeetingMainLogic extends GetxController with RequestToolMixin{
    super.onClose();
    state.memberNameSearchController.dispose();
    stopTime();
+    leaveMeeting();
    state.hubConnection.value?.stop();
  }

  /// 合并请求
  /// 1.获取会议室信息
  /// 2.获取会议室所有用户
-  /// 3.获取会议室Token
-  void mergeFetch() async {
+  Future<void> mergeFetch() async {
    ToastUtils.showLoading();

    var results = await Future.wait([
      getClient().getMeetingRoomInfo(state.roomNumber.value),
-      getClient().getMeetingRoomAllUser(state.roomNumber.value),
-      getClient().getMeetingToken(state.roomNumber.value)]);
+      getClient().getMeetingRoomAllUser(state.roomNumber.value)]);

-    doHttpGetMeetingRoomInfo(results[0].data as MeetingRoomInfo);
-    doHttpGetMeetingRoomAllUser(results[1].data as List<MeetingRoomUser>);
-    doHttpGetMeetingToken(results[2].data as String);
+    getMeetingRoomInfo(results[0].data as MeetingRoomInfo);
+    getMeetingRoomAllUser(results[1].data as List<MeetingRoomUser>);

    ToastUtils.dismiss();
  }
@ -64,11 +65,11 @@ class MeetingMainLogic extends GetxController with RequestToolMixin{

    await state.hubConnection.value?.start();

-    joinChannel();
+    joinChannelToSocket();
  }

  /// 加入会议室
-  void joinChannel() async {
+  Future<void> joinChannelToSocket() async {
    await state.hubConnection.value?.invoke("joinChannel", args: [state.roomNumber.value, false, false, false]);
    mergeFetch();
  }
@ -89,20 +90,24 @@ class MeetingMainLogic extends GetxController with RequestToolMixin{
  }

  /// 获取会议室信息
-  void doHttpGetMeetingRoomInfo(MeetingRoomInfo meetingRoomInfo) async {
+  void getMeetingRoomInfo(MeetingRoomInfo meetingRoomInfo) async {
    state.meetingRoomInfo.value = meetingRoomInfo;
    startTime();
  }

  /// 获取会议室所有用户
-  void doHttpGetMeetingRoomAllUser(List<MeetingRoomUser> meetingRoomUsers) async {
+  void getMeetingRoomAllUser(List<MeetingRoomUser> meetingRoomUsers) async {
    state.users.value = meetingRoomUsers;
    state.cacheUsers.value = meetingRoomUsers;
  }

  /// 获取会议室Token
-  void doHttpGetMeetingToken(String meetingToken) async {
-    state.meetingToken.value = meetingToken;
+  Future<void> doHttpGetMeetingToken() async {
+    BaseStructureResult<String> res = await getClient().getMeetingToken(state.roomNumber.value);
+    state.meetingToken.value = res.data!;
+
+    initRtc();
+    signalRSocket();
  }

  /// 启动计时
@ -141,4 +146,69 @@ class MeetingMainLogic extends GetxController with RequestToolMixin{
      state.users.value = state.cacheUsers.value;
    }
  }
+
+  /// 初始化声网SDK
+  Future<void> initRtc() async {
+    // 请求麦克风权限
+    if (defaultTargetPlatform == TargetPlatform.android) {
+      await [Permission.microphone].request();
+    }
+
+    // 创建 RtcEngine 对象
+    state.rctEngine.value = createAgoraRtcEngine();
+
+    // 初始化 RtcEngine，设置频道场景为 channelProfileLiveBroadcasting（直播场景）
+    await state.rctEngine.value?.initialize(RtcEngineContext(
+      appId: state.appId,
+      channelProfile: ChannelProfileType.channelProfileLiveBroadcasting,
+    ));
+
+    joinChannelToRtc();
+
+    // 回调
+    state.rctEngine.value?.registerEventHandler(
+      RtcEngineEventHandler(
+        // 成功加入频道回调
+        onJoinChannelSuccess: (RtcConnection connection, int elapsed) {
+          debugPrint("自己加入会议室，ID：${connection.localUid}");
+        },
+        // 远端用户或主播加入当前频道回调
+        onUserJoined: (RtcConnection connection, int remoteUid, int elapsed) {
+          debugPrint("远端用户或主播加入会议室，用户或主机的ID：$remoteUid");
+        },
+        // 远端用户或主播离开当前频道回调
+        onUserOffline: (RtcConnection connection, int remoteUid, UserOfflineReasonType reason) {
+          debugPrint("远端用户或主播离开会议室，用户或主机的ID：$remoteUid");
+        },
+      ),
+    );
+  }
+
+  /// 加入会议室
+  Future<void> joinChannelToRtc() async {
+    await state.rctEngine.value?.joinChannel(
+      token: state.meetingToken.value,
+      channelId: state.roomNumber.value,
+      uid: 0,
+      options: const ChannelMediaOptions(
+        // 自动订阅所有视频流
+        autoSubscribeVideo: false,
+        // 自动订阅所有音频流
+        autoSubscribeAudio: true,
+        // 发布摄像头采集的视频
+        publishCameraTrack: false,
+        // 发布麦克风采集的音频
+        publishMicrophoneTrack: false,
+        // 设置用户角色为clientRoleAudience（观众）
+        clientRoleType: ClientRoleType.clientRoleAudience),
+    );
+  }
+
+  /// 离开会议室
+  Future<void> leaveMeeting() async {
+    // 离开
+    await state.rctEngine.value?.leaveChannel();
+    // 释放资源
+    await state.rctEngine.value?.release();
+  }
 }
--- a/wgshare/lib/pages/metting/meeting_main_state.dart
+++ b/wgshare/lib/pages/metting/meeting_main_state.dart
@ -1,5 +1,6 @@
 import 'dart:async';

+import 'package:agora_rtc_engine/agora_rtc_engine.dart';
 import 'package:flutter/cupertino.dart';
 import 'package:get/get.dart';
 import 'package:get/get_rx/src/rx_types/rx_types.dart';
@ -30,6 +31,9 @@ class MeetingMainState {

  /// 会议室编号
  late RxString roomNumber = "".obs;
+
+  /// 会议室token
+  late RxString meetingToken = "".obs;
  
  /// 会议室信息
  late Rx<MeetingRoomInfo?> meetingRoomInfo = Rx(null);
@ -45,10 +49,19 @@ class MeetingMainState {
  /// 搜索用户时，缓存会议室所有用户原始数据
  late RxList<MeetingRoomUser> cacheUsers = RxList([]);

-  /// 会议室Token
-  late RxString meetingToken = "".obs;
-
  /// signalR 长连接相关
  late RxString serviceUrl = "http://192.168.2.9:5192/session-manage".obs;
  late Rx<HubConnection?> hubConnection = Rx(null);
+
+  /// 声网相关
+  final String appId = "4a4f7be64fa1404ebda74784fe9ac381";
+  late Rx<RtcEngine?> rctEngine = Rx(null);
+  /// 是否自动订阅所有视频流
+  late RxBool isAutoSubscribeVideo = false.obs;
+  /// 是否自动订阅所有音频流
+  late RxBool isAutoSubscribeAudio = false.obs;
+  /// 是否发布摄像头采集的视频
+  late RxBool isPublishCameraTrack = false.obs;
+  /// 是否发布麦克风采集的音频
+  late RxBool isPublishMicrophoneTrack = false.obs;
 }