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();
每个进程都有自己的职责好一些,你可以开两种进程,
专门一种进程处理udp,其它进程负责处理连接。
udp进程只负责取udp数据,while循环也可以,或者用定时器也行。
如果不需要客户端之间互发消息,完全不需要用gatewayWorker,workerman更简单高效。
start_businessworker.php 的onWorkerStart和Events的onWorkerStart功能一样,没有区别,手册有讲。
怎么保证 过来的连接能 连接到 相应的进程呢