<?php
/**
 * Created by PhpStorm.
 * User: Joinsen
 * Date: 2017/9/9
 * Time: 1:09
 */

use Workerman\Worker;
use Workerman\Lib\Timer;
use Workerman\Connection\AsyncTcpConnection;
require_once __DIR__ . '/../Workerman/Autoloader.php';
require_once __DIR__ . '/../auto_loader.php';

$worker = new Worker();
$worker->name='REDISRECORD';
$worker->count=1;
$worker->onWorkerStart = function ($worker){
    if ($worker->id===0) {
        global $task_connection;
        $task_connection = new AsyncTcpConnection('Text://127.0.0.1:8731');
        $task_data=array(
            'type'=>'record_redis_data',
        );
        $time_interval = 5*60; //5分钟执行一次
        Timer::add($time_interval,function ()use($task_connection,$task_data){
            $json = json_encode($task_data,JSON_UNESCAPED_UNICODE);
            $task_connection->send($json);
            lg('redis_log',"请求服务端:".$json);
            $task_connection->onMessage = function($task_connection, $task_result)
            {
                // 结果
                var_dump($task_result);
//                if($task_result){
//                    // 获得结果后记得关闭异步链接
////                    $task_connection->close();
//                }
            };
            //执行异步链接
            $task_connection->connect();
        });
    }
};
Worker::runAll();