Download the PHP package playcat/queue-webman without Composer
On this page you can find all versions of the php package playcat/queue-webman. It is possible to download/install these versions without Composer. Possible dependencies are resolved automatically.
Table of contents
Download playcat/queue-webman
More information about playcat/queue-webman
Files in playcat/queue-webman
Download playcat/queue-webman
More information about playcat/queue-webman
Files in playcat/queue-webman
Vendor playcat
Package queue-webman
Short Description playcat queue for webman
License MIT
Homepage https://github.com/nsnake/playcat-queue-webman
Package queue-webman
Short Description playcat queue for webman
License MIT
Homepage https://github.com/nsnake/playcat-queue-webman
Please rate this library. Is it a good library?
Informations about the package queue-webman
Playcat\Queue\Webman
基于Webman的消息队列服务 支持 Redis、Kafka 和 RabbitMQ等多种驱动,自带延迟消息和异常重试,开发简单
特性
- 支持Redis单机或集群 (redis >= 5.0)
- 支持Kafka
- 支持RabbitMQ
- 支持延迟消息数据持久化
- 自定义异常与重试流程
模块与版本
- PHP >= 7.2
- webman >= 1.4
- Redis扩展
- RdKafka扩展
- php-amqplib/php-amqplib扩展
安装
在Webman项目下执行
使用方法
1.配置
1.1
编辑 config\plugin\playcat\queue\ 目录下的app.php和process.php。修改相应内容为自己环境使用的配置。
1.2 初始化数据库(只需一次)
2.创建消费任务
新建一个php的文件并且添加以下内容:
ConsumerData方法
- getID: 当前消息的id
- getRetryCount(): 当前任务已经重试过的次数
- getQueueData(): 当前任务传入的参数
- getChannel(): 当前所执行的任务名称
-
- -
将上面编写好的任务文件保存项目中'app/queue/playcat/'下(如果目录不存在则自己手动创建)
启动服务:
启动:
php start.php start
重载:可在不重启服务的情况下更新业务
php start.php reload
停止:
php start.php stop
如果没有错误出现则表示启动完成
添加任务并且提交到队列中
ProducerData
方法:
- setChannel: 设置推入消息的队列名称
- setQueueData: 设置传入到消费任务的数据
- setDelayTime: 设置延迟时间(秒)
-
- -
Manager
方法:
- getInstance: 创建一个单例模式
- push(ProducerData): 推入生产者数据
- del
异常与重试机制
任务在执行过程中未抛出异常则默认执行成功,否则则进入重试阶段. 重试次数和时间由配置控制,重试间隔时间为当前重试次数的幂函数。 Playcat\Queue\Exceptions\DontRetry异常会忽略掉重试
其它
基于tp和swoole的队列系统 playcat-queue-tpswoole
基于webman的队列系统 playcat-queue-webman
更多说明: https://github.com/nsnake/playcat-queue-doc
联系
QQ:318274085
License
MIT
All versions of queue-webman with dependencies
PHP Build Version
Package Version
The package playcat/queue-webman contains the following files
Loading the files please wait ....