task进程 ¶

介绍 ¶

使用worker执行task
使用worker写的异步任务模型

配置 ¶

配置 config/shiyun/worker_task.php

启动 ¶

php think worker:task start
php think worker:task start -d
php think worker:task stop

php think worker:task start
php think worker:task start -d
php think worker:task stop

然后命令行启动监听端口

然后调用

php

/**
 * @param array  $data 为参数数组
 * @param string $Processing 为处理数据的类或者类名字符串  
 */
worker_async_task_producer($data, $Processing)

/**
 * @param array  $data 为参数数组
 * @param string $Processing 为处理数据的类或者类名字符串  
 */
worker_async_task_producer($data, $Processing)

windows上为单进程,liunx上课设置成多进程处理进程的类必须实现public 的 fire方法

php

public function index()
{ 
    // 你的监听地址
    $address = '127.0.0.1:19345';
    for ( $i = 0; $i < 10 ; $i++){
        $gateway_buffer = [
            'id'=>10-$i,
            'name'=>17
        ];
        $obj = "\app\index\buss\Ces";
        worker_async_task_producer($address,$gateway_buffer,$obj);
    }
    echo '成功';exit;
}

public function index()
{ 
    // 你的监听地址
    $address = '127.0.0.1:19345';
    for ( $i = 0; $i < 10 ; $i++){
        $gateway_buffer = [
            'id'=>10-$i,
            'name'=>17
        ];
        $obj = "\app\index\buss\Ces";
        worker_async_task_producer($address,$gateway_buffer,$obj);
    }
    echo '成功';exit;
}