PHPackages                             nasustop/hapi-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. nasustop/hapi-queue

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

nasustop/hapi-queue
===================

3.0.2(2y ago)010MITPHPPHP >=8.0

Since Apr 4Pushed 2y ago1 watchersCompare

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

READMEChangelogDependencies (11)Versions (4)Used By (0)

HapiQueue
=========

[](#hapiqueue)

hyperf的队列组件，兼容`hyperf/async-queue`和`hyperf/amqp`

安装
--

[](#安装)

```
composer require nasustop/hapi-queue

```

声称配置文件
------

[](#声称配置文件)

```
php bin/hyperf.php vendor:publish nasustop/hapi-queue

```

调用队列的方式
-------

[](#调用队列的方式)

```
$job = new DemoJob(['name' => 'hapi']);
(new Producer($job))->onQueue('test')->dispatcher();
```

监听队列
----

[](#监听队列)

### 命令行

[](#命令行)

```
php bin/hyperf.php hapi:queue:work [queue]
```

### Process进程

[](#process进程)

```
# 新建process文件DemoProcess.php
# queue配置文件中设置了几个队列，就建立几个process文件，$queue 为配置中的队列名称