MQK是一个简单、高性能的PHP后台任务框架。MQK把复杂的消息队列简化成RPC和事件处理，不需要关心复杂的队列、任务和进程等。
MQK在单核心的VPS上每秒可以处理20,000+数据量，在容错模式下每秒可处理6,000+。
composer require fatrellis/mqk
- php 5.6
- redis-server
- 第一步，使用
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的事件机制可以进行实时数据计算分析。