fatrellis/mqk

There is no license information available for the latest version (v0.0.4-alpha) of this package.

Maintainers

Details

github.com/fatrellis/mqk

Source

Issues

Installs: 36

Dependents: 0

Suggesters: 0

Security: 0

Stars: 15

Watchers: 1

Forks: 2

Open Issues: 4

v0.0.4-alpha 2017-08-11 16:17 UTC

Requires

Requires (Dev)

Unknown License 0a056b6d3c7fc80ebac4ecc47ce8839d161f5321

  • Fatrellis <fa.trellis.woop@gmail.com>

This package is not auto-updated.

Last update: 2025-04-21 10:02:32 UTC

README

MQK是一个简单、高性能的PHP后台任务框架。MQK把复杂的消息队列简化成RPC和事件处理，不需要关心复杂的队列、任务和进程等。 MQK在单核心的VPS上每秒可以处理20,000+数据量，在容错模式下每秒可处理6,000+。

Install

composer require fatrellis/mqk

Dependencies

  • php 5.6
  • redis-server

Usage

  1. 第一步，使用K::invoke方法调用方法并传入参数\K::invoke('\\MQK\\Test\\Calculator::sum', 1, 2)。
\K::invoke('Calculator::sum', 1, 2);
  1. 创建任意的类文件和静态方法
class Calculator
{
    public static function sum($a, $b)
    {
        return $a + $b;
    }
}
  1. 启动消费程序。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的事件机制可以进行实时数据计算分析。