workerman 当做udp客户端的使用的问题

mazhaozi

workerman开启四个进程
1 开启一个进程去实时获取udp数据(通过while循环获取) 这个进程一直处于繁忙状态 这个怎么解决 用udp异步?
2 其他进程通过redis队列共享数据进行业务操作 ,在一个就是想让他提供对外连接
这样性能上会不会差一些
写过客户端连接测试 貌似只会连接到2 3 4进程 1处于繁忙状态 分配不了连接
如果这样不行 使用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)
{
    //循环出队
    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{
                     //接收不到数据 1 如果是收盘时间进行沉睡 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();
4148 1 0
1个回答

walkor 打赏

每个进程都有自己的职责好一些,你可以开两种进程,
专门一种进程处理udp,其它进程负责处理连接。

udp进程只负责取udp数据,while循环也可以,或者用定时器也行。

如果不需要客户端之间互发消息,完全不需要用gatewayWorker,workerman更简单高效。

start_businessworker.php 的onWorkerStart和Events的onWorkerStart功能一样,没有区别,手册有讲。

  • mazhaozi 2017-11-04

    怎么保证 过来的连接能 连接到 相应的进程呢

年代过于久远,无法发表回答
×
🔝