1 changed files with 0 additions and 135 deletions
@ -1,135 +0,0 @@
@@ -1,135 +0,0 @@
|
||||
<?php |
||||
|
||||
//执行全部监控 |
||||
function node_monitor_all($targets){ |
||||
global $monitor_config; |
||||
$result = []; |
||||
$target_group_1 = []; |
||||
$target_group_2 = []; |
||||
foreach($targets as $target){ |
||||
if($target['node_group'] == '2') $target_group_2[] = $target; |
||||
else $target_group_1[] = $target; |
||||
} |
||||
if(count($monitor_config['group_1']) > 0 && count($target_group_1) > 0){ |
||||
foreach($monitor_config['group_1'] as $node){ |
||||
if($node['type'] == 'local'){ |
||||
foreach($target_group_1 as $target){ |
||||
$result[] = node_monitor_local($node['node_id'], $target); |
||||
} |
||||
}elseif($node['type'] == 'remote'){ |
||||
$result = array_merge($result, node_monitor_remote($node['node_id'], $node['api'], $target_group_1)); |
||||
} |
||||
} |
||||
} |
||||
if(count($monitor_config['group_2']) > 0 && count($target_group_2) > 0){ |
||||
foreach($monitor_config['group_2'] as $node){ |
||||
if($node['type'] == 'local'){ |
||||
foreach($target_group_2 as $target){ |
||||
$result[] = node_monitor_local($node['node_id'], $target); |
||||
} |
||||
}elseif($node['type'] == 'remote'){ |
||||
$result = array_merge($result, node_monitor_remote($node['node_id'], $node['api'], $target_group_2)); |
||||
} |
||||
} |
||||
} |
||||
return $result; |
||||
} |
||||
|
||||
//批量执行远程监控 |
||||
function node_monitor_remote($node_id, $apiurl, $targets){ |
||||
$json = json_encode($targets); |
||||
$data = send_request($apiurl, $json); |
||||
$arr = json_decode($data, true); |
||||
if(!$arr || !isset($arr['msg'])) return []; |
||||
$result = []; |
||||
foreach($arr['msg'] as $target){ |
||||
$target['node_id'] = $node_id; |
||||
$result[] = $target; |
||||
} |
||||
return $result; |
||||
} |
||||
|
||||
//单个执行本地监控 |
||||
function node_monitor_local($node_id, $target){ |
||||
$status = false; |
||||
if($target['type'] == 'http'){ |
||||
$status = check_http($target['target'], $target['port'], $target['path'], $target['host'], $target['timeout']); |
||||
}elseif($target['type'] == 'ping'){ |
||||
$status = check_ping($target['target'], $target['port'], $target['timeout']); |
||||
}else{ //tcp |
||||
$status = check_tcp($target['target'], $target['port'], $target['timeout']); |
||||
} |
||||
return ['node_id'=>$node_id, 'success'=>$status?1:0, 'target'=>$target['target']]; |
||||
} |
||||
|
||||
function check_http($target, $port, $path, $host = '', $timeout = 3){ |
||||
if($timeout > 3) $timeout = 3; |
||||
if(!$port) $port = 80; |
||||
if(!$path) $path = '/'; |
||||
if($port == 80){ |
||||
$url = 'http://'.$target.$path; |
||||
}else{ |
||||
$url = 'http://'.$target.':'.$port.$path; |
||||
} |
||||
$ch = curl_init(); |
||||
curl_setopt($ch, CURLOPT_URL, $url); |
||||
curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false); |
||||
curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false); |
||||
$httpheader[] = "Accept: */*"; |
||||
$httpheader[] = "Accept-Language: zh-CN,zh;q=0.8"; |
||||
$httpheader[] = "Connection: close"; |
||||
if(!empty($host)){ |
||||
$httpheader[] = "Host: ".$host; |
||||
} |
||||
curl_setopt($ch, CURLOPT_HTTPHEADER, $httpheader); |
||||
curl_setopt($ch, CURLOPT_USERAGENT, "Mozilla/5.0 (Windows NT 10.0; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/86.0.4240.198 Safari/537.36"); |
||||
curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1); |
||||
curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 1); |
||||
curl_setopt($ch, CURLOPT_TIMEOUT, $timeout); |
||||
curl_exec($ch); |
||||
$errno = curl_errno($ch); |
||||
if($errno) { |
||||
curl_close($ch); |
||||
return false; |
||||
} |
||||
$httpcode = curl_getinfo($ch, CURLINFO_HTTP_CODE); |
||||
curl_close($ch); |
||||
if($httpcode>=200 && $httpcode<400){ |
||||
return true; |
||||
} |
||||
return false; |
||||
} |
||||
|
||||
function check_tcp($target, $port, $timeout = 3){ |
||||
if($timeout > 3) $timeout = 3; |
||||
if(!$port) $port = 80; |
||||
$sock = socket_create(AF_INET, SOCK_STREAM, SOL_TCP); |
||||
socket_set_nonblock($sock); |
||||
socket_connect($sock, $target, $port); |
||||
socket_set_block($sock); |
||||
$status = socket_select($r = array($sock), $w = array($sock), $f = array($sock), $timeout); |
||||
return $status === 1; |
||||
} |
||||
|
||||
function check_ping($target, $port, $timeout = 2){ |
||||
if(!function_exists('exec') || PHP_OS == 'WINNT') return check_tcp($target, $port, $timeout); |
||||
if($timeout > 2) $timeout = 2; |
||||
exec('ping -c 1 -w '.$timeout.' '.$target.' > /dev/null', $output, $return_var); |
||||
if($return_var === 0) return true; |
||||
return false; |
||||
} |
||||
|
||||
function send_request($url, $json){ |
||||
$ch = curl_init(); |
||||
curl_setopt($ch, CURLOPT_URL, $url); |
||||
curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false); |
||||
curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false); |
||||
curl_setopt($ch, CURLOPT_USERAGENT, "Mozilla/5.0 (Windows NT 10.0; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/86.0.4240.198 Safari/537.36"); |
||||
curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1); |
||||
curl_setopt($ch, CURLOPT_POST, true); |
||||
curl_setopt($ch, CURLOPT_POSTFIELDS, $json); |
||||
curl_setopt($ch, CURLOPT_HTTPHEADER, ['Content-Type: application/json; charset=utf-8']); |
||||
$ret = curl_exec($ch); |
||||
curl_close($ch); |
||||
return $ret; |
||||
} |
Loading…
Reference in new issue