tjqq/powerjob-server

PowerJob 分布式调度与计算框架

镜像概述与主要用途

PowerJob是一款基于Akka架构的强大分布式调度平台与分布式计算框架，旨在简化任务调度与分布式计算的实现过程。通过提供直观的Web管理界面、丰富的定时策略与执行模式，以及高可用的无锁调度设计，PowerJob可满足各类分布式场景下的任务调度与计算需求，广泛适用于数据同步、日志清理、大规模数据处理等业务场景。

核心功能与特性

易用性

• 提供前端Web界面，支持可视化完成定时任务的全生命周期管理（创建、删除、更新、查询）、任务运行状态监控及运行日志查看。

完整定时策略

• 支持四种定时调度策略：CRON表达式、固定频率、固定延迟及API触发。

丰富执行模式

• 支持四种执行模式：单机、广播、Map及MapReduce。其中Map/MapReduce处理器使开发者仅需少量代码即可获得集群分布式计算能力。

DAG工作流支持

• 支持在线配置任务依赖关系，可视化编排任务流程，并支持上下游任务间的数据传递。

广泛执行器支持

• 支持Spring Bean、普通Java对象、Shell、Python等多种处理器，适用于多样化场景（如广播执行+Shell脚本清理日志）。

便捷运维能力

• 提供在线日志功能，执行器生成的日志可实时显示于前端控制台页面，降低调试成本，提升开发效率。

依赖简化

• 最小化依赖仅需数据库（MySQL/Oracle/MS SQLServer等，支持Spring Data Jpa兼容的关系型数据库），扩展依赖为MongoDB（用于存储海量在线日志）。

高可用与高性能

• 调度服务器采用无锁设计，摒弃其他调度框架基于数据库锁的策略，部署多台调度服务器可同时实现高可用与性能提升（支持无限水平扩展）。

故障转移与恢复

• 任务执行失败后，可根据配置的重试策略完成重试，只要执行器集群有足够计算节点，任务即可成功完成。

使用场景与适用范围

定期执行需求场景

• 如每日凌晨全量同步数据、生成业务报表等需按固定周期执行的任务。

集群协同执行场景

• 如需要所有机器共同执行的日志清理、集群配置更新等任务（通过广播执行模式实现）。

分布式数据处理场景

• 如大规模数据更新、批量计算等单机执行耗时过长的任务，可通过Map/MapReduce处理器实现任务分发，调动整个集群加速计算。

类似产品对比

部署与使用方法

前置依赖

• 数据库：MySQL/Oracle/MS SQLServer等Spring Data Jpa兼容的关系型数据库（必选）。
• 日志存储（可选）：MongoDB（用于存储海量在线日志，小规模场景可忽略）。

Docker快速部署

单容器部署（基础示例）

bash
docker run -d \
  --name powerjob-server \
  -p 7700:7700 \
  -e SPRING_DATASOURCE_URL=jdbc:mysql://<数据库地址>:3306/powerjob?useSSL=false&serverTimezone=UTC&allowPublicKeyRetrieval=true \
  -e SPRING_DATASOURCE_USERNAME=<数据库用户名> \
  -e SPRING_DATASOURCE_PASSWORD=<数据库密码> \
  kfcfans/powerjob-server:latest

Docker Compose部署（含数据库）

yaml
version: '3'
services:
  mysql:
    image: mysql:8.0
    environment:
      MYSQL_ROOT_PASSWORD: root
      MYSQL_DATABASE: powerjob
    ports:
      - "3306:3306"
    volumes:
      - mysql-data:/var/lib/mysql
    healthcheck:
      test: ["CMD", "mysqladmin", "ping", "-h", "localhost"]
      interval: 10s
      timeout: 5s
      retries: 5

  powerjob-server:
    image: kfcfans/powerjob-server:latest
    depends_on:
      mysql:
        condition: service_healthy
    ports:
      - "7700:7700"
    environment:
      SPRING_DATASOURCE_URL: jdbc:mysql://mysql:3306/powerjob?useSSL=false&serverTimezone=UTC&allowPublicKeyRetrieval=true
      SPRING_DATASOURCE_USERNAME: root
      SPRING_DATASOURCE_PASSWORD: root
      # 如需启用MongoDB日志存储，添加以下配置
      # POWERJOB_LOG_STORAGE_TYPE: MONGODB
      # MONGODB_URI: mongodb://<mongodb地址>:27017/powerjob-logs

volumes:
  mysql-data:

访问与使用

• 部署完成后，通过 http://<服务器IP>:7700 访问Web管理界面。
• 首次登录使用默认账号密码（admin/admin），建议登录后修改密码。
• 在Web界面中可创建任务、配置定时策略、查看执行日志等，详细操作参见官方文档。

官方文档与支持

• GitHub Wiki：https://github.com/KFCFans/PowerJob/wiki
• 中文文档：[***]

开源说明

• 产品永久开源（Apache License, Version 2.0），免费使用。
• 开发者@KFCFans提供充足维护时间及免费技术支持，欢迎试用。
• 欢迎参与项目贡献（PR/Issue），如觉得产品不错，可给予Star支持。
• 技术支持与建议：联系开发者 tengjiqi@gmail.com。