workerman開啟四個進(jìn)程
1 開啟一個進(jìn)程去實時獲取udp數(shù)據(jù)(通過while循環(huán)獲取) 這個進(jìn)程一直處于繁忙狀態(tài) 這個怎么解決 用udp異步？
2 其他進(jìn)程通過redis隊列共享數(shù)據(jù)進(jìn)行業(yè)務(wù)操作 ,在一個就是想讓他提供對外連接
這樣性能上會不會差一些
寫過客戶端連接測試 貌似只會連接到2 3 4進(jìn)程 1處于繁忙狀態(tài) 分配不了連接
如果這樣不行 使用gateway會不會好一些
使用gateway的話 怎么處理這個udp呢
在一個就是 start_businessworker.php 的onWorkerStart和Events的onWorkerStart 有什么不一樣的么

function is_close()
{
    if(date("w")=="6"&&date("H")>=5){
        return true;
    }elseif(date("w")=="0"){
        return true;
    }elseif(date("w")=="1"&&date("H")<7){
        return true;
    }
    return false;
}

function checkorder($redis,$link,$task)
{
    //循環(huán)出隊
    while(true)
    {
        $value = $redis->lpop('mylist');
        if($value){
            echo "出隊的值".$value."\n";
            foreach($task->connections as $connection_)
            {
                if(isset($connection_->name)){
                    $connection_->send($result);
                }
            }
            $sql = "INSERT INTO `option` (value) VALUES ('$value');";
            mysql_query($sql,$link);
        }else{
             Timer::add(0.5, 'checkorder', array($redis,$link), false);
             break;
        }
    }
}

$task = new Worker('tcp://0.0.0.0:4406');
$task->count = 4;
$task->onWorkerStart = function($task)
{
    if(!@$link){
        $link = mysql_connect('127.0.0.1', 'root', 'root');
        mysql_select_db('test', $link);
        mysql_query("set names utf8");
    }

    if(!@$redis){
        $redis = new Redis();
    }
    $redis->pconnect('127.0.0.1',6379);
    if($task->id === 0){
        while(1)
        {
             $handle = stream_socket_client("udp://ip:port", $errno, $errstr);
             stream_set_timeout($handle, 30);
             if( !$handle ){  
                error_log(time().":ERROR: {$errno} - {$errstr}\n",3,'errors.log');
             }
             fwrite($handle, "Login");
             while(1)
             {
                 $result = fread($handle,1024);
                 if($result){
                     /*foreach($task->connections as $connection_)
                     {
                        if(isset($connection_->name)){
                            $connection_->send($result);
                        }
                     }*/
                     var_dump("入隊:".$result);
                     $redis->rpush("mylist",$result);

                 }else{
                     //接收不到數(shù)據(jù) 1 如果是收盤時間進(jìn)行沉睡 2 開盤時間重連
                    if(is_close())
                    {
                        while(is_close())
                        {
                            sleep(30);
                        }
                    }else{
                        error_log(time().":recive data error!\n",3,'errors.log');
                        goto err_jmp;
                    }
                 }

             }
             err_jmp:
             fclose($handle);
        }
    }else{
        //邏輯處理
        checkorder($redis,$link,$task);
    }
};

// 運行worker
Worker::runAll();