PHPackages                             egret/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. [Caching](/categories/caching)
4. /
5. egret/queue

ActiveLibrary[Caching](/categories/caching)

egret/queue
===========

swoole pool mq

v1.0.1(6y ago)26MITPHPPHP ^7.1.3

Since Apr 9Pushed 6y ago1 watchersCompare

[ Source](https://github.com/egret135/queue)[ Packagist](https://packagist.org/packages/egret/queue)[ RSS](/packages/egret-queue/feed)WikiDiscussions master Synced 1mo ago

READMEChangelog (2)Dependencies (6)Versions (3)Used By (0)

queue
=====

[](#queue)

PHP的一个队列包，目前已有kafka和redis两种队列驱动，实现方式是用swoole的进程池 + symfony的console + enqueue的队列包

kafka队列使用需要先安装 rdkafka 拓展

redis队列的使用需要有一个redis的操作包，这里指定了predis

后续可能会继续拓展新的队列驱动，目前只存在这两种

### 版本要求

[](#版本要求)

```
"php": "^7.1.3",
"ext-swoole": "^2.0 || ^3.0 || ^4.0",
```

### 安装教程

[](#安装教程)

建议在composer.json里加上

```
{
    "require": {
        xxxxxx,
        "egret/queue": "^1.0"
    },
    "config": {
        "bin-dir": "bin"
    }
}
```

```
composer update egret/queue
```

当然也可以直接composer require，但是这样可执行文件就不会放到跟composer.json同级的bin目录下，比较难找

```
composer require egret/queue
```

### 使用指引

[](#使用指引)

创建一个简单的redis队列

```