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

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

playcat/queue-tpswoole
======================

playcat queue with swoole for thinkphp

1.5.1(1y ago)45MITPHPPHP >7.2CI failing

Since Sep 14Pushed 1y ago1 watchersCompare

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

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

Playcat\\Queue\\Tpswoole
========================

[](#playcatqueuetpswoole)

基于Thinkphp6+和Swoole4+协程的消息队列服务 支持 Redis、Kafka 和 RabbitMQ等多种驱动，自带延迟消息和异常重试，开发简单

特性
--

[](#特性)

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

模块与版本
-----

[](#模块与版本)

- PHP >= 7.2
- Swoole扩展 >= 4.8.13
- Redis扩展
- RdKafka扩展
- php-amqplib/php-amqplib扩展

安装
--

[](#安装)

在Thinkphp项目下执行

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

使用方法
----

[](#使用方法)

### 1.配置

[](#1配置)

#### 1.1

[](#11)

编辑TP目录下的*config\\playcatqueue.php*文件,编辑相应内容为自己环境使用的配置。 如果你使用过1.4之前的版本需要手动对比下配置文件或使用新格式的重新配置一次。

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

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

```
php think playcatqueue:timerserver initdb

```

### 2.创建消费任务

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

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

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

```