PHPackages                             iry/async-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. iry/async-queue

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

iry/async-queue
===============

A simple asynchronous queue library.(一个简单php异步队列库)

v1.0.1(3y ago)265Apache-2.0PHPPHP >=5.4.0

Since Oct 29Pushed 3y ago1 watchersCompare

[ Source](https://github.com/imroychen/php-async-queue)[ Packagist](https://packagist.org/packages/iry/async-queue)[ RSS](/packages/iry-async-queue/feed)WikiDiscussions main Synced 3w ago

READMEChangelogDependenciesVersions (4)Used By (0)

中文简体 / [English](README-EN.md)

自述
==

[](#自述)

A simple asynchronous queue library.(一个简单php异步队列库)

安装
--

[](#安装)

composer require iry/queue

使用
--

[](#使用)

### 1. 队列配置

[](#1-队列配置)

> 创建一个class 实现以下方法即可。[示例](example/QueueConfig/SettingTest.php)一个项目中可以有多个队列，请为每个队列创建一个配置(Setting)

接口文档 [src/SettingInterface.php](src/SettingInterface.php)

```
namespace MyNamespace;//这您的项目应用的命名空间
//创建一个队列配置（Setting））
class MySetting extends \iry\queue\Setting{
    function storage(); // 返回异步任务存储驱动
    function tempPath(){}

    //[可选]
    //function beforeCreate($name, $client);// 任务入队前回调, return false 阻止任务继续入队

    //[可选]
    //function afterCreate($id);//任务成功入队后回调

    //[可选]
    //function i18n(){} //默认 en-US 系统自带 en-US，zh-CN or file://你的绝对路径
}
```

### 2.新任务入队/创建新任务 (客户端)

[](#2新任务入队创建新任务-客户端)

用于产生队列任务

```
use iry\queue\Client
Client::m(\MyNamespace\MySetting::class)->create($name,$args,$tags ,$execTime)
```

**create**(*$name, $args, $customID ,$tags ,$execTime, $unique=true*) [代码示例](./example/CreateTask.php)

参数名类型说明$namestring任务名称：（字母 数组 \_）等字符组成$argsarray参数，如:\['id'=>123\]$customIDstring自定义ID （便于管理和定位您的任务）$execTimearray执行时间 用来为队列延时使用的。### 3. 监听并处理步任务，仅仅支持CLI模式 (服务端)

[](#3-监听并处理步任务仅仅支持cli模式-服务端)

请在你的应用的CLI模式下执行

```
use iry\queue\Service

new Service()->listen()
```

---

注：
==

[](#注)

MySetting::storage
------------------

[](#mysettingstorage)

[详情](./src/Setting.php)

[示例](./example/Queue2Config/MyDbStorage.php)

###  Health Score

24

—

LowBetter than 31% of packages

Maintenance20

Infrequent updates — may be unmaintained

Popularity11

Limited adoption so far

Community9

Small or concentrated contributor base

Maturity47

Maturing project, gaining track record

 Bus Factor1

Top contributor holds 96.9% 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.

###  Release Activity

Cadence

Every ~220 days

Total

3

Last Release

1257d ago

### Community

Maintainers

![](https://www.gravatar.com/avatar/332367a6e49c4e91e2b816a39fdcecf212415f826cf0261981bc1db95075f6e2?d=identicon)[roychen](/maintainers/roychen)

---

Top Contributors

[![roy2chen](https://avatars.githubusercontent.com/u/4337618?v=4)](https://github.com/roy2chen "roy2chen (31 commits)")[![imroychen](https://avatars.githubusercontent.com/u/5027164?v=4)](https://github.com/imroychen "imroychen (1 commits)")

---

Tags

asyncphp-async-queuephp-queuequeuephp async queuephp-qeue

### Embed Badge

![Health badge](/badges/iry-async-queue/health.svg)

```
[![Health](https://phpackages.com/badges/iry-async-queue/health.svg)](https://phpackages.com/packages/iry-async-queue)
```

###  Alternatives

[league/geotools

Geo-related tools PHP 7.3+ library

1.4k5.5M29](/packages/league-geotools)[illuminate/bus

The Illuminate Bus package.

6045.5M504](/packages/illuminate-bus)[uecode/qpush-bundle

Asynchronous processing for Symfony using Push Queues

1672.5M2](/packages/uecode-qpush-bundle)

PHPackages © 2026

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