我希望能够查询Gearman服务器以确定我正在运行的工作程序的实例数(基本上,我想确保RunTaskA
可用,如果没有工作人员来处理这些任务,则RunTaskB
是可用的,我希望能够发送警报。
有什么办法吗?
另外:如果您知道使用PHP来查询Gearman服务器的方式,则可以使用疯狂 Prop 。
编辑:我知道 native 可用的PHP Gearman扩展,但是我不是在寻找任务提交扩展,我需要一些可以查询Gearman服务器并查看有多少 worker 在执行特定任务的东西。
最佳答案
class Waps_Gearman_Server {
/**
* @var string
*/
protected $host = "127.0.0.1";
/**
* @var int
*/
protected $port = 4730;
/**
* @param string $host
* @param int $port
*/
public function __construct($host=null,$port=null){
if( !is_null($host) ){
$this->host = $host;
}
if( !is_null($port) ){
$this->port = $port;
}
}
/**
* @return array | null
*/
public function getStatus(){
$status = null;
$handle = fsockopen($this->host,$this->port,$errorNumber,$errorString,30);
if($handle!=null){
fwrite($handle,"status\n");
while (!feof($handle)) {
$line = fgets($handle, 4096);
if( $line==".\n"){
break;
}
if( preg_match("~^(.*)[ \t](\d+)[ \t](\d+)[ \t](\d+)~",$line,$matches) ){
$function = $matches[1];
$status['operations'][$function] = array(
'function' => $function,
'total' => $matches[2],
'running' => $matches[3],
'connectedWorkers' => $matches[4],
);
}
}
fwrite($handle,"workers\n");
while (!feof($handle)) {
$line = fgets($handle, 4096);
if( $line==".\n"){
break;
}
// FD IP-ADDRESS CLIENT-ID : FUNCTION
if( preg_match("~^(\d+)[ \t](.*?)[ \t](.*?) : ?(.*)~",$line,$matches) ){
$fd = $matches[1];
$status['connections'][$fd] = array(
'fd' => $fd,
'ip' => $matches[2],
'id' => $matches[3],
'function' => $matches[4],
);
}
}
fclose($handle);
}
return $status;
}
}
关于php - 有什么方法可以访问Gearman管理?,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/2752431/