PHP项目虚拟会议如何后端管理房间状态

wen PHP项目 2026-06-28 208

本文目录导读：

PHP项目虚拟会议如何后端管理房间状态

核心状态定义
数据存储方案（MySQL示例）
核心管理接口（RESTful API）
WebSocket实时状态推送（Laravel + Pusher/Soketi）
状态机与安全策略
高级功能建议
性能优化

针对PHP项目的虚拟会议房间状态管理,通常需要结合实时通信（如WebSocket）和数据库来实现，以下是一个完整的后端设计方案，包含核心逻辑、代码示例和注意事项：

核心状态定义

房间状态应包括：

waiting（等待开始）
active（进行中）
paused（暂停/锁定）
ended（已结束）
archived（归档）

数据存储方案（MySQL示例）

CREATE TABLE rooms (
    id VARCHAR(64) PRIMARY KEY,
    name VARCHAR(255) NOT NULL,
    status ENUM('waiting','active','paused','ended','archived') DEFAULT 'waiting',
    created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
    started_at TIMESTAMP NULL,
    ended_at TIMESTAMP NULL,
    max_participants INT DEFAULT 50,
    host_id INT NOT NULL,
    FOREIGN KEY (host_id) REFERENCES users(id)
);
CREATE TABLE room_participants (
    id INT AUTO_INCREMENT PRIMARY KEY,
    room_id VARCHAR(64),
    user_id INT,
    status ENUM('joined','left','kicked','muted') DEFAULT 'joined',
    joined_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
    left_at TIMESTAMP NULL,
    FOREIGN KEY (room_id) REFERENCES rooms(id),
    FOREIGN KEY (user_id) REFERENCES users(id)
);

核心管理接口（RESTful API）

创建房间（初始化状态）

// POST /api/rooms
public function createRoom($request) {
    $roomId = uniqid('room_');
    DB::insert('rooms', [
        'id' => $roomId,
        'name' => $request->name,
        'host_id' => auth()->id(),
        'status' => 'waiting'
    ]);
    // 创建者默认加入
    DB::insert('room_participants', [
        'room_id' => $roomId,
        'user_id' => auth()->id(),
        'status' => 'joined'
    ]);
    return response()->json(['room_id' => $roomId, 'status' => 'waiting']);
}

开始会议（状态变更）

// POST /api/rooms/{id}/start
public function startRoom($roomId) {
    $room = Room::findOrFail($roomId);
    // 权限校验（仅房主/管理员）
    if ($room->host_id !== auth()->id() && !auth()->user()->isAdmin()) {
        abort(403);
    }
    // 状态机校验
    if (!in_array($room->status, ['waiting', 'paused'])) {
        return response()->json(['error' => 'Invalid status transition'], 400);
    }
    $room->update([
        'status' => 'active',
        'started_at' => now()
    ]);
    // 通过WebSocket广播状态变更
    broadcast(new RoomStatusChanged($room));
    return response()->json(['status' => 'active']);
}

结束会议

// POST /api/rooms/{id}/end
public function endRoom($roomId) {
    $room = Room::findOrFail($roomId);
    $room->update([
        'status' => 'ended',
        'ended_at' => now()
    ]);
    // 清理参与者状态
    Participant::where('room_id', $roomId)
        ->where('status', 'joined')
        ->update(['status' => 'left', 'left_at' => now()]);
    broadcast(new RoomStatusChanged($room));
    return response()->json(['status' => 'ended']);
}

房间心跳（检测存活）

// POST /api/rooms/{id}/heartbeat (每30秒由发布者发送)
public function heartbeat($roomId) {
    $room = Room::findOrFail($roomId);
    // 更新最后活跃时间
    Cache::put("room:{$roomId}:heartbeat", now(), 60);
    // 自动清理僵尸房间（可选）
    if ($room->status === 'active' && 
        Cache::get("room:{$roomId}:heartbeat") < now()->subMinutes(2)) {
        $this->endRoom($roomId);
    }
    return response()->json(['success' => true]);
}

WebSocket实时状态推送（Laravel + Pusher/Soketi）

// 事件类
class RoomStatusChanged implements ShouldBroadcast
{
    public $room;
    public function broadcastOn() {
        return new PresenceChannel('room.'.$this->room->id);
    }
    public function broadcastAs() {
        return 'status.changed';
    }
    public function broadcastWith() {
        return [
            'room_id' => $this->room->id,
            'status' => $this->room->status,
            'participant_count' => $this->room->participants()->count()
        ];
    }
}

前端监听示例（JavaScript）：

const channel = pusher.subscribe('presence-room.room123');
channel.bind('status.changed', (data) => {
    updateRoomUI(data.status);
    if (data.status === 'ended') {
        redirectToLobby();
    }
});

状态机与安全策略

状态转换矩阵

当前状态	允许转换至	触发条件
waiting	active, ended	房主点击开始/结束
active	paused, ended	房主锁定/超时自动结束
paused	active, ended	房主恢复/强制结束
ended	archived（仅限）	管理员手动归档

并发控制

// 使用数据库乐观锁防止状态并发修改
$room = Room::where('id', $roomId)
    ->where('status', 'waiting')
    ->first();
if ($room && $room->update(['status' => 'active'])) {
    // 成功
} else {
    // 冲突处理
}

自动清理任务（Cron Job）

* * * * * php artisan rooms:cleanup

// 清理僵尸房间（无心跳超过3分钟）
$rooms = Room::where('status', 'active')
    ->where('updated_at', '<', now()->subMinutes(3))
    ->get();
foreach ($rooms as $room) {
    $room->update(['status' => 'ended']);
    Participant::where('room_id', $room->id)
        ->update(['status' => 'left']);
}

高级功能建议

录制状态：增加 recording 状态字段
观众模式：区分参会者与观众权限
断线重连：使用 room_participants 表的 last_seen 时间戳
房间锁定：增加 locked 布尔字段，配合密码验证

实时人数统计：通过Redis维护在线用户计数

// 参与者加入/离开时更新Redis Set
$redis->sadd("room:{$roomId}:online", $userId);
$redis->srem("room:{$roomId}:online", $userId);
$onlineCount = $redis->scard("room:{$roomId}:online");