PHPackages                             ctfang/swoft-queue - 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. ctfang/swoft-queue

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

ctfang/swoft-queue
==================

Queue Component for Swoft

0.0.1(6y ago)016[1 issues](https://github.com/ctfang/swoft-queue/issues)Apache-2.0PHPCI failing

Since Nov 4Pushed 6y ago2 watchersCompare

[ Source](https://github.com/ctfang/swoft-queue)[ Packagist](https://packagist.org/packages/ctfang/swoft-queue)[ RSS](/packages/ctfang-swoft-queue/feed)WikiDiscussions master Synced 3d ago

READMEChangelogDependencies (3)Versions (2)Used By (0)

Swoft Process
=============

[](#swoft-process)

基于redis的队列组件

数据流程
----

[](#数据流程)

[![image](https://github.com/ctfang/images/raw/master/queue/QQ%E5%9B%BE%E7%89%8720191103225258.png)](https://github.com/ctfang/images/blob/master/queue/QQ%E5%9B%BE%E7%89%8720191103225258.png)

Install
-------

[](#install)

- composer command

```
composer require ctfang/swoft-queue
```

配置,在`bean.php`新增
----------------

[](#配置在beanphp新增)

```
'queueServer' => [
    'class' => QueuePool::class,
    'queue' => [
        'test' => [ // test 队列名称
           'class' => JobsManager::class,// job分发类
           'worker_num' => 4,// 队列开启进程数量,设置比cpu数量多一两个就好了
           'coroutine_num' => 1,// 每个进程内同时处理多少个job
           'queue_key' => 1,// swoole内置功能queue_key,int类型
           'redis_key' => "queue",// redis key
        ],
    ],
]
```

启动
--

[](#启动)

```
php bin/swoft queue:start
```

Job 处理工作
--------

[](#job-处理工作)

job是处理任务的最小单位，job是挂靠在queue上的，每个queue可以挂靠很多Job

```