开始直播（Flutter）

dependencies:
  atomic_x_core: ^3.6.0

class _YourAnchorPageState extends State<YourAnchorPage> {
  // 核心控制器
  late final LiveCoreController _controller;
  // 状态标记：false = 预览中; true = 直播中
  bool _isLiveStarted = false; 

  @override
  void initState() {
    super.initState();
    _controller = LiveCoreController.create(CoreViewType.pushView);
    _controller.setLiveID(widget.liveId);
    
    // 初始化时直接打开设备（详见下一步）
    _openDevices();
  }
}

void _openDevices() {
    // 1. 打开前置摄像头 (true 表示前置)
    DeviceStore.shared.openLocalCamera(true);
    // 2. 打开麦克风
    DeviceStore.shared.openLocalMicrophone();
  }

// 3.1 封装预览视图组件
  Widget _buildLocalPreview() {
    return Container(
      color: Colors.black,
      child: VideoView(
        onViewCreated: (viewId) {
          // 关键：将本地摄像头画面绑定到预览 View
          TUIRoomEngine.sharedInstance().setLocalVideoView(viewId);
        },
        onViewDisposed: (viewId) {
          // 销毁时解绑
          TUIRoomEngine.sharedInstance().setLocalVideoView(0);
        },
      ),
    );
  }

  // 3.2 组合主视图
  @override
  Widget build(BuildContext context) {
    return Scaffold(
      body: Stack(
        children: [
          // 视图层：根据状态自动切换
          Positioned.fill(
            child: _isLiveStarted 
                ? LiveCoreWidget(controller: _controller) // 直播中：用核心组件
                : _buildLocalPreview(),                   // 预览中：用 VideoView
          ),
          
          // UI 层：开播按钮（仅在预览时显示）
          if (!_isLiveStarted)
            Positioned(
              bottom: 50, left: 0, right: 0,
              child: Center(
                child: ElevatedButton(
                  onPressed: _startLive, // 下一步实现此方法
                  child: const Text('开始直播'),
                ),
              ),
            ),
        ],
      ),
    );
  }

Future<void> _startLive() async {
    // 1. 配置直播间参数
    final liveInfo = LiveInfo(
      liveID: widget.liveId,         // 房间唯一标识
      liveName: "Atomic Live Demo",  // 房间标题
      // 布局模式：videoDynamicGrid9Seats 代表动态 9 宫格布局
      seatTemplate: SeatLayoutTemplate.videoDynamicGrid9Seats,
    );

    // 2. 发起开播请求
    final result = await LiveListStore.shared.createLive(liveInfo);

    if (result.isSuccess) {
      debugPrint("开播成功");
      // 3. 关键步骤：更新状态
      // 将 _isLiveStarted 置为 true，触发 build 方法重新构建，
      // 从而将 UI 从 VideoView（预览）切换为 LiveCoreWidget（直播）。
      setState(() {
        _isLiveStarted = true;
      });
    } else {
      debugPrint("开播失败: ${result.errorMessage}");
      // 可以在此处添加 Toast 提示用户
    }
  }

Future<void> _stopLive() async {
    // 1. 调用接口结束直播
    // SDK 内部会自动停止推流、销毁房间并清理媒体资源
    final result = await LiveListStore.shared.endLive();

    if (result.isSuccess) {
      debugPrint("关播成功");
      // 2. 退出当前页面
      if (mounted) {
        Navigator.of(context).pop();
      }
    } else {
      debugPrint("关播失败: ${result.errorMessage}");
    }
  }

import 'package:flutter/material.dart';
import 'package:atomic_x_core/atomicxcore.dart';
import 'package:rtc_room_engine/rtc_room_engine.dart'; // 引入 RTC 引擎

class YourAnchorPage extends StatefulWidget {
  final String liveId;
  const YourAnchorPage({super.key, required this.liveId});

  @override
  State<YourAnchorPage> createState() => _YourAnchorPageState();
}

class _YourAnchorPageState extends State<YourAnchorPage> {
  late final LiveCoreController _controller;
  bool _isLiveStarted = false; // 直播状态标记

  @override
  void initState() {
    super.initState();
    _controller = LiveCoreController.create(CoreViewType.pushView);
    _controller.setLiveID(widget.liveId);
    _openDevices(); // 步骤2：打开设备
  }

  void _openDevices() {
    DeviceStore.shared.openLocalCamera(true);
    DeviceStore.shared.openLocalMicrophone();
  }

  // 步骤3：构建预览
  Widget _buildLocalPreview() {
    return Container(
      color: Colors.black,
      child: VideoView(
        onViewCreated: (viewId) => TUIRoomEngine.sharedInstance().setLocalVideoView(viewId),
        onViewDisposed: (viewId) => TUIRoomEngine.sharedInstance().setLocalVideoView(0),
      ),
    );
  }

  // 步骤4：开播逻辑
  Future<void> _startLive() async {
    final liveInfo = LiveInfo(
      liveID: widget.liveId,
      liveName: "Test Live",
      seatTemplate: SeatLayoutTemplate.videoDynamicGrid9Seats,
      keepOwnerOnSeat: true,
    );

    final result = await LiveListStore.shared.createLive(liveInfo);
    if (result.isSuccess) {
      setState(() {
        _isLiveStarted = true; // 切换 UI 状态
      });
    }
  }

  @override
  Widget build(BuildContext context) {
    return Scaffold(
      body: Stack(
        children: [
          // 视图自动切换
          Positioned.fill(
            child: _isLiveStarted
                ? LiveCoreWidget(controller: _controller)
                : _buildLocalPreview(),
          ),
          // 开播按钮
          if (!_isLiveStarted)
            Positioned(
              bottom: 50, left: 0, right: 0,
              child: Center(
                child: ElevatedButton(onPressed: _startLive, child: const Text('开始直播')),
              ),
            ),
        ],
      ),
    );
  }
}

import 'package:flutter/material.dart';
import 'package:atomic_x_core/atomicxcore.dart';

/// YourAudiencePage 代表您的观众观看页面
class _YourAudiencePageState extends State<YourAudiencePage> {
  late final LiveCoreController _controller;
  bool _isJoining = true;

  @override
  void initState() {
    super.initState();
    _controller = LiveCoreController.create(CoreViewType.playView);
    _controller.setLiveID(widget.liveId);
    
    // 修正：在第一帧渲染完成后再进房，确保 LiveCoreWidget 已完成 init() 
    WidgetsBinding.instance.addPostFrameCallback((_) {
      _joinLive();
    });
  }

  Future<void> _joinLive() async {
    final result = await LiveListStore.shared.joinLive(widget.liveId);
    if (result.isSuccess) {
      debugPrint("joinLive success");
      if (mounted) setState(() => _isJoining = false);
    } else {
      debugPrint("joinLive error: ${result.errorMessage}");
    }
  }

  @override
  Widget build(BuildContext context) {
    return Scaffold(
      body: Stack(
        children: [
          // 必须始终渲染，不可根据 _isJoining 状态移除，否则会导致监听失效
          LiveCoreWidget(controller: _controller),
          
          if (_isJoining)
            const Center(child: CircularProgressIndicator(color: Colors.white)),
        ],
      ),
    );
  }
}

import 'package:flutter/material.dart';
import 'package:atomic_x_core/atomicxcore.dart';

/// YourAudiencePage 代表您的观众观看页面
class YourAudiencePage extends StatefulWidget {
  final String liveId;

  const YourAudiencePage({super.key, required this.liveId});

  @override
  State<YourAudiencePage> createState() => _YourAudiencePageState();
}

class _YourAudiencePageState extends State<YourAudiencePage> {
  late final LiveCoreController _controller;

  @override
  void initState() {
    super.initState();
    _controller = LiveCoreController.create();
    _controller.setLiveID(widget.liveId);
    // 进入直播间
    _joinLive();
  }

  Future<void> _joinLive() async {
    // 调用 LiveListStore.shared.joinLive 进入直播间
    // - liveId: 与主播开播同样的 liveId
    final result = await LiveListStore.shared.joinLive(widget.liveId);

    if (result.isSuccess) {
      debugPrint("joinLive success");
    } else {
      debugPrint("joinLive error: ${result.errorMessage}");
      // 进房失败，也需要退出页面
      // if (mounted) Navigator.of(context).pop();
    }
  }

  @override
  Widget build(BuildContext context) {
    return Scaffold(
      body: Stack(
        children: [
          LiveCoreWidget(controller: _controller),
        ],
      ),
    );
  }
}

import 'package:flutter/material.dart';
import 'package:atomic_x_core/atomicxcore.dart';

/// YourAudiencePage 代表您的观众观看页面
class YourAudiencePage extends StatefulWidget {
  final String liveId;

  const YourAudiencePage({super.key, required this.liveId});

  @override
  State<YourAudiencePage> createState() => _YourAudiencePageState();
}

class _YourAudiencePageState extends State<YourAudiencePage> {
  // ... 其他代码 ...

  // 退出直播
  Future<void> _leaveLive() async {
    final result = await LiveListStore.shared.leaveLive();

    if (result.isSuccess) {
      debugPrint("leaveLive success");
    } else {
      debugPrint("leaveLive error: ${result.errorMessage}");
    }
  }

  // ... 其他代码 ...
}