PHPackages                             playcat/queue-webman - 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. playcat/queue-webman

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

playcat/queue-webman
====================

playcat queue for webman

2.0(6mo ago)4191[1 issues](https://github.com/nsnake/playcat-queue-webman/issues)MITPHPPHP >=8.1

Since Mar 12Pushed 6mo ago1 watchersCompare

[ Source](https://github.com/nsnake/playcat-queue-webman)[ Packagist](https://packagist.org/packages/playcat/queue-webman)[ Docs](https://github.com/nsnake/playcat-queue-webman)[ RSS](/packages/playcat-queue-webman/feed)WikiDiscussions main Synced 1mo ago

READMEChangelogDependencies (1)Versions (12)Used By (0)

**Playcat\\Queue\\Webman**
==========================

[](#playcatqueuewebman)

#### 简单易用的消息队列处理系统

[](#简单易用的消息队列处理系统)

特性
--

[](#特性)

- 支持Redis单机或集群 (redis >= 5.0)
- 支持Kafka
- 支持RabbitMQ
- 支持延迟消息数据持久化
- 自定义异常与重试流程

依赖版本
----

[](#依赖版本)

- PHP >= 8.1
- webman >= 1.6
- msgpack
- Redis
- RdKafka
- php-amqplib/php-amqplib

### 依赖安装

[](#依赖安装)

```
#RH,CentOS 7
sudo yum install php-pecl-redis5 php-pecl-msgpack
sudo yum install php-pecl-rdkafka5 #(使用Kafka必须)

#RH,CentOS,Rock 8及以上
sudo dnf install php-pecl-redis6 php-pecl-msgpack
sudo dnf install php-pecl-rdkafka6 #(使用Kafka必须)
```

安装
--

[](#安装)

在Webman项目下执行

```
$ composer require "playcat/queue-webman"
```

使用方法
----

[](#使用方法)

### 1.配置

[](#1配置)

#### 1.1

[](#11)

编辑 **config\\plugin\\playcat\\queue\** 目录下的app.php*\*和*process.php*。修改相应内容为自己环境使用的配置。

#### 1.2 初始化数据库(只需一次)

[](#12-初始化数据库只需一次)

```
php webman timerserver:initdb

```

### 2.创建消费任务

[](#2创建消费任务)

#### 创建一个php的文件并添加以下内容:

[](#创建一个php的文件并添加以下内容)

```