PHPackages                             simplephp/swoole-jobs - PHPackages - PHPackages  [Skip to content](#main-content)[PHPackages](/)[Directory](/)[Categories](/categories)[Trending](/trending)[Leaderboard](/leaderboard)[Changelog](/changelog)[Analyze](/analyze)[Collections](/collections)[Log in](/login)[Sign up](/register)

1. [Directory](/)
2. /
3. [Queues & Workers](/categories/queues)
4. /
5. simplephp/swoole-jobs

ActiveLibrary[Queues & Workers](/categories/queues)

simplephp/swoole-jobs
=====================

基于swoole的job调度组件，类似gearman的分布式任务处理系统

291PHP

Since Apr 1Pushed 8y ago1 watchersCompare

[ Source](https://github.com/simplephp/swoole-jobs)[ Packagist](https://packagist.org/packages/simplephp/swoole-jobs)[ RSS](/packages/simplephp-swoole-jobs/feed)WikiDiscussions master Synced 2mo ago

READMEChangelogDependenciesVersions (1)Used By (0)

swoole-jobs
===========

[](#swoole-jobs)

- 基于swoole类似gearman的分布式任务处理系统
- 高性能/动态多woker进程消费队列，加速后端耗时服
- 无需像gearman一个worker配置一条crontab，swoole-jobs负责管理所有worker状态

1. 说明
-----

[](#1-说明)

- web中较慢的逻辑，比如统计/email/短信/图片处理等；
- 支持redis/rabbitmq/zeromq等任何一种做队列消息存储；
- 比yii／laravel等框架自带队列更稳定更快\[消费进程可动态变化\]
- 自带yii2/phalcon/yaf/ThinkPHP5集成示例，其他框架可参考src/Action代码，
- [yii2完整示例](https://github.com/kcloze/swoole-jobs-yii2)
- [ThinkPHP5完整示例](https://github.com/kcloze/swoole-jobs-tp5)

2. 架构图
------

[](#2-架构图)

[![架构图](docs/images/jobs-archi.png)](docs/images/jobs-archi.png)[![进程模型](docs/images/jobs-process.png)](docs/images/jobs-process.png)

3. 特性
-----

[](#3-特性)

- 基于swoole的job调度组件；类似gearman的分布式任务处理系统；
- redis/rabbitmq/zeromq等任何一种做队列消息存储(目前只实现redis/rabbitmq)；
- 利用swoole的process实现多进程管理，进程个数可配置，worker进程退出后会自动拉起；
- 子进程循环次数可配置，防止业务代码内存泄漏；默认stop命令会等待子进程平滑退出；
- 支持topic特性，不同的job绑定不同的topic；
- 每个topic启动对应数量的子进程，杜绝不同topic之间相互影响;
- 根据队列积压情况，子进程动态启动进程数，最大子进程个数可配置；
- 支持composer，可以跟任意框架集成；
- 日志文件自动切割，默认最大100M，最多5个日志文件，防止日志刷满磁盘；
- 出现积压情况，支持钉钉机器人等消息提醒；

4. 安装
-----

[](#4-安装)

#### 4.1 composer

[](#41-composer)

```
git clone https://github.com/kcloze/swoole-jobs.git
cd swoole-jobs

```

#### 4.1.2 默认redis做队列；如果用rabbitmq做队列，需要增加包依赖：修改composer.json

[](#412-默认redis做队列如果用rabbitmq做队列需要增加包依赖修改composerjson)

```
    "require": {
        "php": ">=7.0",
        "ext-swoole": ">=1.8.9",
        "enqueue/amqp-ext": "0.8.9"
    },

```

```
composer install

```

#### 4.2 docker

[](#42-docker)

- git clone
- cd swoole-jobs and composer install
- 根据根目录Dockerfile构建镜像
- docker build -t swoole-jobs .
- docker run -it -v ~/data/code/php:/data swoole-jobs /bin/bash
- 进入容器之后，进入项目目录：php swoole-jobs.php start

5. 运行
-----

[](#5-运行)

### 5.1 示范

[](#51-示范)

```
1.修改配置config.php

2.启动服务
php ./swoole-jobs.php start >> log/system.log 2>&1

3.往队列推送任务
php ./test/testJobs.php

```

### 5.2 启动参数说明

[](#52-启动参数说明)

```
NAME
      php swoole-jobs - manage swoole-jobs

SYNOPSIS
      php swoole-jobs command [options]
          Manage swoole-jobs daemons.

WORKFLOWS

      help [command]
      Show this help, or workflow help for command.

      status [command]
      Show master and workers status.

      restart
      Stop, then start swoole-jobs master and workers.

      start
      Start swoole-jobs master and workers.

      stop
      Wait all running workers smooth exit, please check swoole-jobs status for a while.

      exit
      Kill all running workers and master PIDs.

```

6. 服务管理
-------

[](#6-服务管理)

### 线上启动和关闭服务,有两种方式:

[](#线上启动和关闭服务有两种方式)

#### 6.1 启动脚本加入到crontab定时任务，每分钟执行一次(swoole-jobs会自动检查是否在执行，避免重复启动)

[](#61-启动脚本加入到crontab定时任务每分钟执行一次swoole-jobs会自动检查是否在执行避免重复启动)

```
* * * * * /usr/local/bin/php /***/swoole-jobs.php start >> /***/log/system.log 2>&1

```

#### 6.2 使用systemd管理(故障重启、开机自启动)

[](#62-使用systemd管理故障重启开机自启动)

[更多systemd介绍](https://www.swoole.com/wiki/page/699.html)

```
1. 根据自己项目路径,修改 docs/systemd/swoole-jobs.service
2. sudo cp -f systemd/swoole-jobs.service /etc/systemd/system/
3. sudo systemctl --system daemon-reload
4. 服务管理
#启动服务
sudo systemctl start swoole-jobs.service
#reload服务
sudo systemctl reload swoole-jobs.service
#关闭服务
sudo systemctl stop swoole-jobs.service

```

7.系统截图
------

[](#7系统截图)

#### htop截图

[](#htop截图)

[![实例图](docs/images/demo.png)](docs/images/demo.png)

#### status

[](#status)

[![status](docs/images/status.png)](docs/images/status.png)

#### 钉钉提醒

[](#钉钉提醒)

[![message](docs/images/dingding.png)](docs/images/dingding.png)

8. change log
-------------

[](#8-change-log)

- [change log](docs/ChangeLog.md)

9. 注意事项
-------

[](#9-注意事项)

- 如果嵌入自己的框架，可参考src/Action代码，继承抽象类Kcloze\\Jobs\\Action\\BaseAction
- 各种框架服务启动会稍有不同，具体参考：`example/bin`项目的代码

10. 压测
------

[](#10-压测)

- 瓶颈: redis/rabbitmq队列存储本身和job执行速度

11. 感谢
------

[](#11-感谢)

- [swoole](http://www.swoole.com/)

12. 联系
------

[](#12-联系)

qq群：141059677

###  Health Score

21

—

LowBetter than 19% of packages

Maintenance20

Infrequent updates — may be unmaintained

Popularity8

Limited adoption so far

Community8

Small or concentrated contributor base

Maturity41

Maturing project, gaining track record

 Bus Factor1

Top contributor holds 100% of commits — single point of failure

How is this calculated?**Maintenance (25%)** — Last commit recency, latest release date, and issue-to-star ratio. Uses a 2-year decay window.

**Popularity (30%)** — Total and monthly downloads, GitHub stars, and forks. Logarithmic scaling prevents top-heavy scores.

**Community (15%)** — Contributors, dependents, forks, watchers, and maintainers. Measures real ecosystem engagement.

**Maturity (30%)** — Project age, version count, PHP version support, and release stability.

### Community

Maintainers

![](https://www.gravatar.com/avatar/5bc85954b85968faaebd19c2a95d42399e528ef9c8b792174ac2e79c0a21fb0d?d=identicon)[simplephp](/maintainers/simplephp)

---

Top Contributors

[![simplephp](https://avatars.githubusercontent.com/u/5026959?v=4)](https://github.com/simplephp "simplephp (3 commits)")

### Embed Badge

![Health badge](/badges/simplephp-swoole-jobs/health.svg)

```
[![Health](https://phpackages.com/badges/simplephp-swoole-jobs/health.svg)](https://phpackages.com/packages/simplephp-swoole-jobs)
```

###  Alternatives

[league/geotools

Geo-related tools PHP 7.3+ library

1.4k5.3M26](/packages/league-geotools)[amphp/parser

A generator parser to make streaming parsers simple.

14952.8M16](/packages/amphp-parser)[amphp/serialization

Serialization tools for IPC and data storage in PHP.

13451.1M18](/packages/amphp-serialization)[enqueue/enqueue

Message Queue Library

19820.0M56](/packages/enqueue-enqueue)[deliciousbrains/wp-background-processing

WP Background Processing can be used to fire off non-blocking asynchronous requests or as a background processing tool, allowing you to queue tasks.

1.1k409.8k6](/packages/deliciousbrains-wp-background-processing)[react/async

Async utilities and fibers for ReactPHP

2238.8M170](/packages/react-async)

PHPackages © 2026

[Directory](/)[Categories](/categories)[Trending](/trending)[Changelog](/changelog)[Analyze](/analyze)