|
@ -24,6 +24,7 @@ abstract class dealBase extends publicBase { |
|
|
private $deal_flag=''; // 队列类别标识 |
|
|
private $deal_flag=''; // 队列类别标识 |
|
|
private $proc_code; // 当前队列自定义进程数号码标识 |
|
|
private $proc_code; // 当前队列自定义进程数号码标识 |
|
|
private $close_path; // 开关标识文件 |
|
|
private $close_path; // 开关标识文件 |
|
|
|
|
|
protected $server_ip; |
|
|
|
|
|
|
|
|
public function __construct() { |
|
|
public function __construct() { |
|
|
$this->path_conf = dirname(dirname(__FILE__))."/config/daemonconf.php"; |
|
|
$this->path_conf = dirname(dirname(__FILE__))."/config/daemonconf.php"; |
|
@ -44,6 +45,8 @@ abstract class dealBase extends publicBase { |
|
|
|
|
|
|
|
|
include_once($this->path_conf); |
|
|
include_once($this->path_conf); |
|
|
|
|
|
|
|
|
|
|
|
$this->server_ip = $this->getServerIp(); |
|
|
|
|
|
|
|
|
$this->setPara(); |
|
|
$this->setPara(); |
|
|
if($this->processnum+0==0) $this->processnum = 1; |
|
|
if($this->processnum+0==0) $this->processnum = 1; |
|
|
|
|
|
|
|
@ -92,6 +95,10 @@ abstract class dealBase extends publicBase { |
|
|
protected function setProcHealth() { |
|
|
protected function setProcHealth() { |
|
|
$proc_path = sprintf($this->path_proc, $this->proc_code.'_'.md5($this->path_deal)); |
|
|
$proc_path = sprintf($this->path_proc, $this->proc_code.'_'.md5($this->path_deal)); |
|
|
|
|
|
|
|
|
|
|
|
$obj = new mBase(); |
|
|
|
|
|
$rdobj = $obj->initRedis(); |
|
|
|
|
|
$res = $rdobj->set(sprintf(_DAEMON_HEALTH, $this->server_ip, $this->deal_flag, $this->proc_code), time()); |
|
|
|
|
|
|
|
|
$handle = fopen($proc_path, 'w'); |
|
|
$handle = fopen($proc_path, 'w'); |
|
|
if(!$handle) { |
|
|
if(!$handle) { |
|
|
return false; |
|
|
return false; |
|
|