fatrellis / mqk
There is no license information available for the latest version (v0.0.4-alpha) of this package.
v0.0.4-alpha
2017-08-11 16:17 UTC
Requires
- php: >= 5.6
- ad7six/dsn: ^0.4.0
- monolog/monolog: ^1.23
- symfony/console: ^3.3
Requires (Dev)
- phpunit/phpunit: ^6.2
This package is not auto-updated.
Last update: 2025-03-24 09:41:22 UTC
README
MQK是一个简单、高性能的PHP后台任务框架。MQK把复杂的消息队列简化成RPC和事件处理,不需要关心复杂的队列、任务和进程等。
MQK在单核心的VPS上每秒可以处理20,000+
数据量,在容错模式下每秒可处理6,000+
。
Install
composer require fatrellis/mqk
Dependencies
- php 5.6
- redis-server
Usage
- 第一步,使用
K::invoke
方法调用方法并传入参数\K::invoke('\\MQK\\Test\\Calculator::sum', 1, 2)
。
\K::invoke('Calculator::sum', 1, 2);
- 创建任意的类文件和静态方法
class Calculator { public static function sum($a, $b) { return $a + $b; } }
- 启动消费程序。debug模式下控制台会输出异步任务的返回结果。
$ vendor/bin/mqk run
[2017-07-11 08:14:52] 14327 .NOTICE: Master work on 14327 [] []
[2017-07-11 08:14:56] 14331 .INFO: Message finished and result is 2 [] []
开发状态
开发中,不推荐用在生产环境中使用。
- 未进行严格的测试,可能存在各种问题。
- 函数参数以json格式进行序列化,不能使用php对象
文档
推荐使用MQK的事件机制可以进行实时数据计算分析。