flussonic/watcher

Flussonic流媒体服务Docker部署方案

镜像概述和主要用途

本方案提供Flussonic流媒体服务的完整Docker化部署配置，集成了流媒体服务器、数据库（PostgreSQL）、缓存（Redis）及配套管理组件（Central、Watcher系列服务）。通过Docker Compose实现多服务协同部署，支持流媒体的接收、转码、分发、录像及集群管理，适用于快速搭建企业级流媒体服务环境。

核心功能和特性

• 流媒体处理：基于Flussonic流媒体服务器，支持HTTP、RTMP（1935端口）、RTSP（554端口）等协议的音视频流接收与分发
• 数据存储：PostgreSQL数据库持久化存储服务配置与业务数据，Redis提供高性能缓存支持
• 集群管理：Central组件实现流媒体集群配置管理与API接口服务
• 录像与任务调度：Watcher系列服务处理视频录像（episodes）、任务调度（scheduler）及工作节点任务（worker）
• 多服务协同：通过Docker Compose定义服务依赖关系，实现健康检查、自动重启及服务初始化（如数据库迁移）
• 数据持久化：专用存储卷（dvr_storage）保存录像文件，支持本地时间同步（/etc/localtime挂载）

使用场景和适用范围

• 企业级流媒体平台部署
• 视频监控系统音视频流处理
• 直播服务搭建与内容分发
• 需要集群管理的分布式流媒体环境
• 快速原型验证与开发测试环境

使用方法和配置说明

1. 环境准备

需预先准备以下环境变量：

• LICENSE_KEY: Flussonic服务授权密钥
• DOMAIN: 部署服务的域名或IP地址
• CLUSTER_KEY: 集群认证密钥
• CENTRAL_API_KEY: Central组件API访问密钥

2. 创建Docker Compose配置文件

创建docker-compose.yml文件，内容如下：

yaml
version: "3.7"

volumes:
  dvr_storage:
    driver: local

services:
  db:
    image: flussonic/postgres:16
    restart: always
    environment:
      POSTGRES_USER: watcher
      POSTGRES_PASSWORD: watcher
      POSTGRES_DB: watcher
    ports:
      - "5432:5432"
    expose:
      - 5432
    healthcheck:
      test: "pg_isready -q -d ${POSTGRES_DB} -U ${POSTGRES_USER}"
      interval: 10s
      timeout: 20s
      retries: 3
      start_period: 5s

  redis:
    image: flussonic/redis:7
    restart: always
    ports:
      - "6379:6379"
    expose:
      - 6379

  flussonic:
    image: flussonic/flussonic:latest
    container_name: flussonic
    restart: always
    environment:
        LICENSE_KEY: ${LICENSE_KEY}
        STREAMER_CLUSTER_KEY: ${CLUSTER_KEY}
        STREAMER_HTTP: 80
    ports:
      - "80:80"
      - "1935:1935"
      - "554:554"
      - "443:443"
    volumes:
      - "/etc/localtime:/etc/localtime:ro"
      - dvr_storage:/storage

  central-migrate:
    image: flussonic/central:latest
    depends_on:
      db:
        condition: service_healthy
    environment:
      CENTRAL_DATABASE_URL: postgres://watcher:watcher@db.:5432/watcher?sslmode=disable&search_path=central
    command: ['bin/central', '--migrate']

  central:
    image: flussonic/central:latest
    restart: always
    depends_on:
      db:
        condition: service_healthy
      central-migrate:
        condition: service_completed_successfully
    environment:
      CENTRAL_DATABASE_URL: postgres://watcher:watcher@db.:5432/watcher?sslmode=disable&search_path=central
      CENTRAL_HTTP_PORT: 9019
      CENTRAL_API_KEY: ${CENTRAL_API_KEY}
      CENTRAL_API_URL: http://${DOMAIN}:9019
      CENTRAL_UPSTREAM_URL: http://${CLUSTER_KEY}@flussonic:80
      CENTRAL_REDIS_URL: redis://redis:6379/2
    ports:
      - "9019:9019"
    expose:
      - 9019

  watcher-migrate:
    image: flussonic/watcher:latest
    depends_on:
      db:
        condition: service_healthy
    environment:
      LICENSE_KEY: ${LICENSE_KEY}
      DATABASE_URL: postgresql://watcher:watcher@db/watcher
      REDIS: redis://redis:6379
      CENTRAL_URL: http://${CENTRAL_API_KEY}@central:9019/streamer/api/v3
      FLUSSONIC_MASTER: http://${CLUSTER_KEY}@flussonic:80
      API_URL: http://${DOMAIN}
      WATCHER_ADMIN_LOGIN: admin
      WATCHER_ADMIN_PASSWORD: admin
    entrypoint: [""]
    command: >
      bash -c "/opt/flussonic/contrib/watcher db upgrade &&
      /opt/flussonic/contrib/watcher create_local_streamer &&
      /opt/flussonic/contrib/watcher firstrun &&
      /opt/flussonic/bin/watcher-sync.sh"

  watcher-vms:
    image: flussonic/watcher:latest
    container_name: watcher
    restart: always
    depends_on:
      db:
        condition: service_healthy
      watcher-migrate:
        condition: service_completed_successfully
      redis:
        condition: service_started
      central:
        condition: service_started
    environment:
      LICENSE_KEY: ${LICENSE_KEY}
      DATABASE_URL: postgresql://watcher:watcher@db/watcher
      REDIS: redis://redis:6379
      CENTRAL_URL: http://${CENTRAL_API_KEY}@central:9019/streamer/api/v3
      FLUSSONIC_MASTER: http://${CLUSTER_KEY}@flussonic:80
      API_URL: http://${DOMAIN}
      LISTEN_HOST: 0.0.0.0
      PORT: 9025
    entrypoint: [""]
    command: ['/opt/flussonic/bin/watcher.sh', 'run']
    ports:
      - "9025:9025"

  watcher-episodes:
    image: flussonic/watcher:latest
    restart: always
    depends_on:
      db:
        condition: service_healthy
      watcher-migrate:
        condition: service_completed_successfully
      redis:
        condition: service_started
      central:
        condition: service_started
    environment:
      LICENSE_KEY: ${LICENSE_KEY}
      DATABASE_URL: postgresql://watcher:watcher@db/watcher
      REDIS: redis://redis:6379
      CENTRAL_URL: http://${CENTRAL_API_KEY}@central:9019/streamer/api/v3
      FLUSSONIC_MASTER: http://${CLUSTER_KEY}@flussonic:80
    entrypoint: [""]
    command: ['/opt/flussonic/bin/watcher.sh', 'episodes']

  watcher-scheduler:
    image: flussonic/watcher:latest
    restart: always
    depends_on:
      db:
        condition: service_healthy
      watcher-migrate:
        condition: service_completed_successfully
      redis:
        condition: service_started
      central:
        condition: service_started
    environment:
      LICENSE_KEY: ${LICENSE_KEY}
      DATABASE_URL: postgresql://watcher:watcher@db/watcher
      REDIS: redis://redis:6379
      CENTRAL_URL: http://${CENTRAL_API_KEY}@central:9019/streamer/api/v3
    entrypoint: [""]
    command: ['/opt/flussonic/bin/watcher.sh', 'scheduler']

  watcher-worker-default:
    image: flussonic/watcher:latest
    restart: always
    depends_on:
      db:
        condition: service_healthy
      watcher-migrate:
        condition: service_completed_successfully
      redis:
        condition: service_started
      central:
        condition: service_started
    environment:
      LICENSE_KEY: ${LICENSE_KEY}
      DATABASE_URL: postgresql://watcher:watcher@db/watcher
      REDIS: redis://redis:6379
      CENTRAL_URL: http://${CENTRAL_API_KEY}@central:9019/streamer/api/v3
    entrypoint: [""]
    command: ['/opt/flussonic/bin/watcher.sh', 'worker']

  watcher-worker-high:
    image: flussonic/watcher:latest
    restart: always
    depends_on:
      db:
        condition: service_healthy
      watcher-migrate:
        condition: service_completed_successfully
      redis:
        condition: service_started
      central:
        condition: service_started
    environment:
      LICENSE_KEY: ${LICENSE_KEY}
      DATABASE_URL: postgresql://watcher:watcher@db/watcher
      REDIS: redis://redis:6379
      CENTRAL_URL: http://${CENTRAL_API_KEY}@central:9019/streamer/api/v3
    entrypoint: [""]
    command: ['/opt/flussonic/bin/watcher.sh', 'worker', 'high']

  watcher-go:
    image: flussonic/watcher:latest
    restart: always
    depends_on:
      db:
        condition: service_healthy
      watcher-migrate:
        condition: service_completed_successfully
      redis:
        condition: service_started
      central:
        condition: service_started
    environment:
      LICENSE_KEY: ${LICENSE_KEY}
      DATABASE_URL: postgresql://watcher:watcher@db/watcher
      REDIS: redis://redis:6379
      CENTRAL_URL: http://${CENTRAL_API_KEY}@central:9019/streamer/api/v3
      API_URL: http://${DOMAIN}
    entrypoint: [""]
    command: ['/opt/flussonic/bin/watcher-go.sh']

3. 部署步骤

1. 准备环境变量：替换以下变量值

   • LICENSE_KEY: 从Flussonic获取的授权密钥
   • DOMAIN: 部署服务的域名或服务器IP
   • CLUSTER_KEY: 集群认证密钥
   • CENTRAL_API_KEY: Central服务API访问密钥

2. 启动服务：执行以下命令启动所有服务

   bash
   DOMAIN=<你的域名> CLUSTER_KEY=<集群密钥> CENTRAL_API_KEY=<中央API密钥> LICENSE_KEY=<授权密钥> docker compose -f docker-compose.yml up -d
   

4. 服务更新

如需更新镜像版本，执行以下命令：

bash
# 拉取最新镜像
docker compose -f docker-compose.yml pull

# 重启服务应用更新
DOMAIN=<你的域名> CLUSTER_KEY=<集群密钥> CENTRAL_API_KEY=<中央API密钥> LICENSE_KEY=<授权密钥> docker compose -f docker-compose.yml up -d

核心服务配置说明

• flussonic: 流媒体服务器主服务，监听80(HTTP)、1935(RTMP)、554(RTSP)、443(HTTPS)端口，通过dvr_storage卷持久化存储录像数据
• db: PostgreSQL数据库服务，存储业务数据，配置健康检查确保服务可用性
• redis: Redis缓存服务，提供数据缓存支持
• central: 集群管理服务，提供API接口（9019端口），协调集群节点
• **watcher-: 系列服务处理录像管理、任务调度、工作节点任务执行等辅助功能，依赖数据库迁移完成后启动

所有服务通过环境变量注入配置，支持灵活定制部署参数，确保服务间协同工作。