pabloromeo/clusterplex_orchestrator

ClusterPlex Orchestrator

概述

ClusterPlex Orchestrator是ClusterPlex分布式媒体转码系统的核心协调组件，作为Node.js应用程序运行，负责接收Plex Media Server (PMS)的转码请求，并通过WebSocket协议将任务分发到集群中可用的转码工作节点(Workers)。该组件支持工作节点的动态注册与状态管理，实现转码任务的分布式处理，已在Kubernetes和Docker Swarm集群环境中验证。

核心功能与特性

• 转码任务协调：接收PMS发送的所有转码请求，智能分发至可用工作节点
• 工作节点管理：监控工作节点的注册状态、可用性及负载情况，支持节点动态上下线
• 实时通信：通过WebSocket协议与PMS及工作节点建立低延迟通信通道
• 集群兼容性：兼容Kubernetes和Docker Swarm等容器编排平台，支持集群化部署
• 高可用性：可作为集群服务部署，支持故障自动恢复

在ClusterPlex架构中的角色

ClusterPlex系统由三个核心组件构成，Orchestrator承担转码任务的协调中枢功能：

1. Plex Media Server (PMS)
   提供媒体服务，其原生转码器被替换为shim程序，负责将转码请求发送至Orchestrator

2. 转码协调器(Orchestrator)
   接收PMS的转码请求，管理工作节点池，分配任务并监控进度

3. 转码工作节点(Workers)
   执行实际的媒体转码任务，通过WebSocket接收Orchestrator分配的任务并反馈进度

工作原理

!系统架构

1. 请求发起：PMS中的自定义shim程序拦截转码请求，通过WebSocket发送至Orchestrator

2. 任务分配：Orchestrator接收请求后，根据工作节点的可用性和负载状态，选择合适的节点分配任务

3. 转码执行：工作节点接收任务后启动转码进程，并通过PMS上的Local Relay（NGINX正向代理）将进度数据反馈至PMS

4. 节点管理：Orchestrator持续跟踪工作节点的注册状态，自动处理节点上线/下线事件，确保任务分配的准确性

系统要求

网络要求

• Orchestrator需与PMS及所有工作节点保持网络连通，建议使用专用集群网络
• 确保WebSocket通信端口（默认3000）在集群内可访问
• 节点间网络延迟应尽可能低，以保证任务分发和进度反馈的实时性

存储要求

Orchestrator本身无持久化存储需求，但PMS与工作节点需通过支持ReadWriteMany (RWX)的存储系统（如NFS、SMB、Ceph、GlusterFS或Longhorn）共享：

• 媒体库目录（确保所有节点访问路径一致）
• 转码临时目录（路径需在PMS和所有工作节点间保持一致）

部署与配置

镜像信息

转码协调器官方镜像：ghcr.io/pabloromeo/clusterplex_orchestrator:latest

部署示例

Docker Swarm部署

yaml
version: '3.8'
services:
  orchestrator:
    image: ghcr.io/pabloromeo/clusterplex_orchestrator:latest
    deploy:
      replicas: 1
      restart_policy:
        condition: on-failure
        max_attempts: 3
      placement:
        constraints: [node.role == manager]
    ports:
      - "3000:3000"  # WebSocket通信端口
    environment:
      - LOG_LEVEL=info  # 日志级别：debug/info/warn/error
      - WORKER_TIMEOUT=30000  # 工作节点超时时间(毫秒)
    networks:
      - clusterplex_network

networks:
  clusterplex_network:
    driver: overlay
    attachable: true

Kubernetes部署

yaml
apiVersion: apps/v1
kind: Deployment
metadata:
  name: clusterplex-orchestrator
  namespace: clusterplex
spec:
  replicas: 1
  selector:
    matchLabels:
      app: orchestrator
  template:
    metadata:
      labels:
        app: orchestrator
    spec:
      containers:
      - name: orchestrator
        image: ghcr.io/pabloromeo/clusterplex_orchestrator:latest
        ports:
        - containerPort: 3000
        env:
        - name: LOG_LEVEL
          value: "info"
        - name: PORT
          value: "3000"
        resources:
          requests:
            cpu: "100m"
            memory: "128Mi"
          limits:
            cpu: "500m"
            memory: "256Mi"
---
apiVersion: v1
kind: Service
metadata:
  name: orchestrator
  namespace: clusterplex
spec:
  selector:
    app: orchestrator
  ports:
  - port: 3000
    targetPort: 3000
  type: ClusterIP

配置参数

Orchestrator支持通过环境变量进行配置，主要参数如下：

相关文档

• 完整配置参数
• Kubernetes部署指南
• Docker Swarm部署指南
• Grafana监控仪表盘
• https://pabloromeo.github.io/clusterplex