README

By google translate

MQK is a simple, high-performance PHP background task framework. MQK simplifies complex message queues to RPC and event handling, eliminating the need for complex queues, tasks, and processes. MQK can handle 20,000 + data per second on a single core VPS, and 6,000 + per second in fault tolerant mode.

Install

composer require mqk/mqk

Dependencies

php 5.6
redis-server

Usage

The first step is to use the K::invoke method to call the method and pass in the parameter\K::invoke ('\\ MQK\\Test\\Calculator::sum', 1, 2).

\K::invoke('Calculator::sum', 1, 2);

Create class and static methods

class Calculator
{
    public static function sum($a, $b)
    {
        return $a + $b;
    }
}

Start the consumer program. In debug mode, the console outputs the return result of the asynchronous task.

$ 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 [] []

Development status

Development, is not recommended for use in the production environment.

No rigorous testing, there may be a variety of problems.
Function parameters in json format serialization, can not use php objects

Documents

It is recommended to use MQK's event mechanism to perform real-time data analysis.

mqk / mqk

Maintainers

Details