1 Star 0 Fork 64

贵宾网络 / 百夫长统计

forked from WM Jonssen / 百夫长统计 
加入 Gitee
与超过 1200万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
克隆/下载
command.php 14.42 KB
一键复制 编辑 原始数据 按行查看 历史
WM Jonssen 提交于 2018-05-23 23:00 . modified: api/api_ca.php
<?php
/*!
* ATTENTION: THIS FREE LICENSE IS ONLY FOR PERSONAL NON-COMMERCIAL USER. FOR COMMERCIAL PURPOSES, PLEASE PURCHASE A COMMERCIAL LICENSE! *
* module: Centcount Analyticsb Free Contorl Host Command PHP Code *
* version: 1.00 Free *
* author: WM Jonssen *
* date: 05/23/2018 *
* copyright 2015-2018 WM Jonssen <wm.jonssen@gmail.com> - All rights reserved.*
* license: Dual licensed under the Free License and Commercial License. *
* https://www.centcount.com *
*/
header('Access-Control-Allow-Origin:*');
header('Content-type: text/html; charset=utf-8');
@require './config/config_common.php';
$uid = SDATA_OUT('uid', 6, 'EXIT');
$t = SDATA_OUT('t', 6, 'EXIT');
$v = SDATA_OUT('v', 4, 'EXIT', 32);
$q = SDATA_OUT('q', 0, '', 32);
verify_admin($uid, $t, $v);
$REDIS_0 = new Redis();
if ($REDIS_0->CONNECT(REDIS_IP_0, REDIS_PORT_0) !== true) exit('Conect REDIS_0 Failed.');
$REDIS_0->SELECT(REDIS_DB_0);
switch ($q) {
case 'process info':
$REDIS_2 = new Redis();
if ($REDIS_2->CONNECT(REDIS_IP_2, REDIS_PORT_2) !== true) exit('Conect REDIS_2 Failed.');
$REDIS_2->SELECT(REDIS_DB_2);
$arr_data = array();
$PROCESS_ARRAY = $REDIS_0->MGET(array('ProcessGlobalCount','ProcessGlobalConsume','ProcessMax','ProcessMin','ProcessLimit','KernelVersion','PersistenceStatus', 'PersistenceVersion'));
$Requests = $REDIS_0->LLEN('TicketListL');
$TotalProcessed = $PROCESS_ARRAY[0];
$TotalConsume = $PROCESS_ARRAY[1];
$FatalErrors = $REDIS_0->LLEN('ErrorFatal');
$BadRequests = $REDIS_2->LLEN('BadRequests');
$ExecuteFailures = $REDIS_0->LLEN('ErrorExecute');
$PROCESS_MAX= $PROCESS_ARRAY[2];
$PROCESS_MIN = $PROCESS_ARRAY[3];
$PROCESS_LIMIT = $PROCESS_ARRAY[4];
$KERNEL_VERSION = $PROCESS_ARRAY[5];
$PERSISTENCE_STATUS = $PROCESS_ARRAY[6];
$PERSISTENCE_VERSION = $PROCESS_ARRAY[7];
$arr_data[0] = array((int)$Requests, (int)$TotalProcessed, (int)$TotalConsume, (int)$FatalErrors, (int)$BadRequests, (int)$ExecuteFailures, (int)$PROCESS_MAX, (int)$PROCESS_MIN, (int)$PROCESS_LIMIT, $KERNEL_VERSION, (int)$PERSISTENCE_STATUS, $PERSISTENCE_VERSION);
$PROCESS_ARRAY = $REDIS_0->SMEMBERS('ProcessList');
if (count($PROCESS_ARRAY) > 0) {
foreach ($PROCESS_ARRAY as $PID) {
$PROCESS_STRUCTURE = $REDIS_0->HGETALL($PID);
if (count($PROCESS_STRUCTURE) === 11) {
$arr_data[] = array($PROCESS_STRUCTURE['PID'], $PROCESS_STRUCTURE['Status'], $PROCESS_STRUCTURE['StartTime'], $PROCESS_STRUCTURE['LastResponseTime'], $PROCESS_STRUCTURE['TotalCount'], $PROCESS_STRUCTURE['TotalConsume'], $PROCESS_STRUCTURE['CurrentCount'], $PROCESS_STRUCTURE['PeakCount'], $PROCESS_STRUCTURE['MaxConsume'], $PROCESS_STRUCTURE['MinConsume'], $PROCESS_STRUCTURE['MemoryUsage']);
}
}
}
$PROCESS_ARRAY = $REDIS_0->ZREVRANGEBYSCORE('SSIDS', '+INF', '-INF', array('withscores'=>true, 'limit'=>array(0, 20)));
$arr_data[] = $PROCESS_ARRAY;
$PROCESS_ARRAY = $REDIS_0->MGET(array('PerformanceCountJS', 'PerformanceConsumeJS', 'PerformanceCount0', 'PerformanceConsume0','PerformanceCount1', 'PerformanceConsume1','PerformanceCount2', 'PerformanceConsume2','PerformanceCount3', 'PerformanceConsume3','PerformanceCount4', 'PerformanceConsume4','PerformanceCount5', 'PerformanceConsume5','PerformanceCount6', 'PerformanceConsume6','PerformanceCount7', 'PerformanceConsume7','PerformanceCount8', 'PerformanceConsume8','PerformanceCount9', 'PerformanceConsume9','PerformanceCount10', 'PerformanceConsume10','PerformanceCount11', 'PerformanceConsume11','PerformanceCount12', 'PerformanceConsume12', 'TotalMemory','UsedMemory','FreeMemory', 'TotalDisk','UsedDisk'));
$arr_data[] = $PROCESS_ARRAY;
echo json_encode($arr_data);
break;
case 'process sum':
$REDIS_2 = new Redis();
if ($REDIS_2->CONNECT(REDIS_IP_2, REDIS_PORT_2) !== true) exit('Conect REDIS_2 Failed.');
$REDIS_2->SELECT(REDIS_DB_2);
$arr_data = array();
$PROCESS_ARRAY = $REDIS_0->MGET(array('ProcessGlobalCount','ProcessGlobalConsume','ProcessMax','ProcessMin','ProcessLimit','KernelVersion','PersistenceStatus', 'PersistenceVersion'));
$Requests = $REDIS_0->LLEN('TicketListL');
$TotalProcessed = $PROCESS_ARRAY[0];
$TotalConsume = $PROCESS_ARRAY[1];
$FatalErrors = $REDIS_0->LLEN('ErrorFatal');
$BadRequests = $REDIS_2->LLEN('BadRequests');
$ExecuteFailures = $REDIS_0->LLEN('ErrorExecute');
$PROCESS_MAX= $PROCESS_ARRAY[2];
$PROCESS_MIN = $PROCESS_ARRAY[3];
$PROCESS_LIMIT = $PROCESS_ARRAY[4];
$KERNEL_VERSION = $PROCESS_ARRAY[5];
$PERSISTENCE_STATUS = $PROCESS_ARRAY[6];
$PERSISTENCE_VERSION = $PROCESS_ARRAY[7];
$arr_data[0] = array((int)$Requests, (int)$TotalProcessed, (int)$TotalConsume, (int)$FatalErrors, (int)$BadRequests, (int)$ExecuteFailures, (int)$PROCESS_MAX, (int)$PROCESS_MIN, (int)$PROCESS_LIMIT, $KERNEL_VERSION, (int)$PERSISTENCE_STATUS, $PERSISTENCE_VERSION);
$PROCESS_ARRAY = $REDIS_0->SMEMBERS('ProcessList');
if (count($PROCESS_ARRAY) > 0) {
foreach ($PROCESS_ARRAY as $PID) {
$PROCESS_STRUCTURE = $REDIS_0->HGETALL($PID);
if (count($PROCESS_STRUCTURE) === 11) {
$arr_data[] = array($PROCESS_STRUCTURE['PID'], $PROCESS_STRUCTURE['Status'], $PROCESS_STRUCTURE['StartTime'], $PROCESS_STRUCTURE['LastResponseTime'], $PROCESS_STRUCTURE['TotalCount'], $PROCESS_STRUCTURE['TotalConsume'], $PROCESS_STRUCTURE['CurrentCount'], $PROCESS_STRUCTURE['PeakCount'], $PROCESS_STRUCTURE['MaxConsume'], $PROCESS_STRUCTURE['MinConsume'], $PROCESS_STRUCTURE['MemoryUsage']);
}
}
}
echo json_encode($arr_data);
break;
case 'set process':
$opt = SDATA_OUT('opt', 6, 'EXIT');
$pid = SDATA_OUT('pid', 0, 'EXIT', 32);
switch ($opt) {
case 0:
$REDIS_0->HSET($pid, 'Status', 0);
echo $pid . ' is terminated successful!';
break;
case 1:
$REDIS_0->HSET($pid, 'Status', 1);
echo $pid . ' is running now!';
break;
case 2:
$REDIS_0->HSET($pid, 'Status', 2);
echo $pid . ' is paused successful!';
break;
case 4:
$PROCESS_MIN = $REDIS_0->GET('ProcessMin');
if ((int)$pid > 8) {
echo 'Error: Max Processes is setted up 8 by administrator!';
exit;
}
if ((int)$PROCESS_MIN <= (int)$pid) {
$REDIS_0->SET('ProcessMax', (int)$pid);
echo 'Max Processes is ' . $pid . ' now!';
} else {
echo 'Error: Max Processes must be larger than Min Processes!';
}
break;
case 5:
$PROCESS_MAX = $REDIS_0->GET('ProcessMax');
if ((int)$PROCESS_MAX >= (int)$pid) {
$REDIS_0->SET('ProcessMin', (int)$pid);
echo 'Min Processes is ' . $pid . ' now!';
} else {
echo 'Error: Min Processes must be less than Max Processes!';
}
break;
case 13:
$PROCESS_COUNT = $REDIS_0->SCARD('ProcessList');
$PROCESS_MAX = $REDIS_0->GET('ProcessMax');
if ($PROCESS_COUNT < $PROCESS_MAX) {
pclose(popen('php -f ' . __DIR__ . '/kernel.php &', 'r'));
echo 'A new process is running now!';
} else {
echo 'Error: The count of process exceeds maximum limit.';
}
break;
case 14:
$REDIS_0->SET('ProcessLimit', 1);
$PROCESS_COUNT = $REDIS_0->SCARD('ProcessList');
if ((int)$PROCESS_COUNT > 0) {
$PROCESS_ARRAY = $REDIS_0->LRANGE('ProcessList',0,($PROCESS_COUNT - 1));
for ($i = 0; $i < $PROCESS_COUNT; $i++) {
$PID = $PROCESS_ARRAY[$i];
$REDIS_0->LSET($PID, 1, 0);
}
}
sleep(3);
$PROCESS_ARRAY = $REDIS_0->KEYS('PID*');
$PROCESS_COUNT = count($PROCESS_ARRAY);
if ($PROCESS_COUNT > 0) for ($i = 0; $i < $PROCESS_COUNT; $i++) {
$REDIS_0->DEL($PROCESS_ARRAY[$i]);
}
$REDIS_0->DEL('ProcessList');
echo 'This host is disabled now!';
break;
case 15:
$REDIS_0->SET('ProcessLimit', 0);
$PROCESS_MAX = $REDIS_0->GET('ProcessMax');
for ($i = 0; $i < (int)$PROCESS_MAX; $i++) {
pclose(popen('php -f ' . __DIR__ . '/kernel.php &', 'r'));
}
echo 'This host is enabled now!';
break;
case 20:
$REDIS_0->SET('PersistenceStatus', 1);
sleep(3);
echo 'Persistence is disabled now!';
break;
case 21:
$REDIS_0->SET('PersistenceStatus', 0);
$REDIS_0->DEL('PersistenceMutualExclusion');
pclose(popen('php -f ' . __DIR__ . '/persistence.php &', 'r'));
echo 'Persistence is enabled now!';
break;
case 30:
$REDIS_0->SET('ProcessLimit', 1);
$PROCESS_ARRAY = $REDIS_0->SMEMBERS('ProcessList');
if (count($PROCESS_ARRAY) > 0) {
foreach ($PROCESS_ARRAY as $PID) {
$REDIS_0->HSET($PID, 'Status', 0);
}
}
sleep(3);
$PROCESS_ARRAY = $REDIS_0->KEYS('PID*');
if (count($PROCESS_ARRAY) > 0) {
foreach ($PROCESS_ARRAY as $PID) $REDIS_0->DEL($PID);
}
$REDIS_0->DEL('ProcessList');
$REDIS_0->SET('PersistenceStatus', 1);
sleep(3);
echo 'This host is disabled now!';
break;
case 31:
$REDIS_0->SET('ProcessLimit', 0);
$PROCESS_MAX = (int)$REDIS_0->GET('ProcessMax');
for ($i = 0; $i < $PROCESS_MAX; $i++) {
pclose(popen('php -f ' . __DIR__ . '/kernel.php &', 'r'));
}
$REDIS_0->SET('PersistenceStatus', 0);
$REDIS_0->DEL('PersistenceMutualExclusion');
pclose(popen('php -f ' . __DIR__ . '/persistence.php &', 'r'));
echo 'This host is enabled now!';
break;
case 90:
$REDIS_0->DEL('PerformanceCountJS', 'PerformanceConsumeJS','PerformanceCount0', 'PerformanceConsume0','PerformanceCount1', 'PerformanceConsume1','PerformanceCount2', 'PerformanceConsume2','PerformanceCount3', 'PerformanceConsume3','PerformanceCount4', 'PerformanceConsume4','PerformanceCount5', 'PerformanceConsume5','PerformanceCount6', 'PerformanceConsume6','PerformanceCount7', 'PerformanceConsume7','PerformanceCount8', 'PerformanceConsume8','PerformanceCount9', 'PerformanceConsume9','PerformanceCount10', 'PerformanceConsume10','PerformanceCount11', 'PerformanceConsume11','PerformanceCount12', 'PerformanceConsume12','ProcessGlobalCount','ProcessGlobalConsume', 'MissedCA', 'MissedVA', 'MissedVC', 'MissedVID', 'MissedIND');
$REDIS_0->DEL('SSIDS');
echo 'Clean all log successfully!';
break;
case 91:
$REDIS = new Redis();
$REDIS->CONNECT(REDIS_IP_2, REDIS_PORT_2) !== true AND exit;
$REDIS->SELECT(REDIS_DB_2);
$RETURN_ARRAY = $REDIS->KEYS('1*');
$REDIS->DEL($RETURN_ARRAY);
echo 'Clean settings cache successfully!';
break;
case 99:
$REDIS_0->SET('ProcessLimit', 1);
$PROCESS_ARRAY = $REDIS_0->SMEMBERS('ProcessList');
if (count($PROCESS_ARRAY) > 0) {
foreach ($PROCESS_ARRAY as $PID) {
$REDIS_0->HSET($PID, 'Status', 0);
}
}
$REDIS_0->SET('PersistenceStatus', 1);
sleep(3);
$PROCESS_ARRAY = $REDIS_0->KEYS('PID*');
if (count($PROCESS_ARRAY) > 0) {
foreach ($PROCESS_ARRAY as $PID) $REDIS_0->DEL($PID);
}
$REDIS_0->DEL('ProcessList');
$REDIS_ARR = $REDIS_0->SMEMBERS('DayPeriod');
if (count($REDIS_ARR) > 0) $REDIS_0->DEL($REDIS_ARR);
$REDIS_0->DEL('DayPeriod', 'TimeLine');
$REDIS_1 = new Redis();
if ($REDIS_1->CONNECT(REDIS_IP_1, REDIS_PORT_1) !== true) exit('Clean today data failed from redis 1.');
$REDIS_1->SELECT(REDIS_DB_1);
$REDIS_1->FLUSHDB();
$REDIS_3 = new Redis();
if ($REDIS_3->CONNECT(REDIS_IP_3, REDIS_PORT_3) !== true) exit('Clean today data failed from redis 3.');
$REDIS_3->SELECT(REDIS_DB_3);
$REDIS_3->FLUSHDB();
$DB = con_db(DB_HOST_LOCAL, ROOT_USER_LOCAL, ROOT_PASSWORD_LOCAL);
if ($DB === false) exit('Clean today data failed from connecting database');
foreach($REDIS_ARR AS $redis_tb) {
$TMP = explode('-', $redis_tb);
$SID = $TMP[0];
$TB_DATE = $TMP[1];
if (use_db($DB, 'site' . $SID)) {
$sql = "DROP TABLE log{$TB_DATE}";
mysqli_query($DB, $sql);
$sql = "DROP TABLE act{$TB_DATE}";
mysqli_query($DB, $sql);
$sql = "DROP TABLE clk{$TB_DATE}";
mysqli_query($DB, $sql);
$sql = "DROP TABLE vid{$TB_DATE}";
mysqli_query($DB, $sql);
$sql = "DROP TABLE ind{$TB_DATE}";
mysqli_query($DB, $sql);
}
}
echo 'Clean today data successfully!';
break;
}
break;
case 'error':
$REDIS = $REDIS_0;
$opt = SDATA_OUT('opt', 6, 'EXIT');
switch ($opt) {
case 1:
$error_type = 'ErrorExecute';
break;
case 2:
$error_type = 'ErrorFatal';
break;
case 3:
$REDIS = new Redis();
if ($REDIS->CONNECT(REDIS_IP_2, REDIS_PORT_2) !== true) exit('Conect REDIS_2 Failed.');
$REDIS->SELECT(REDIS_DB_2);
$error_type = 'BadRequests';
break;
case 101:
$error_type = 'ErrorExecute';
break;
case 102:
$error_type = 'ErrorFatal';
break;
case 103:
$REDIS = new Redis();
if ($REDIS->CONNECT(REDIS_IP_2, REDIS_PORT_2) !== true) exit('Conect REDIS_2 Failed.');
$REDIS->SELECT(REDIS_DB_2);
$error_type = 'BadRequests';
break;
}
if ($opt > 100) {
if ($REDIS->DEL($error_type) > 0) {
echo 'Delete successfully!';
} else {
echo 'Delete failed!';
}
exit;
}
$start = SDATA_OUT('start', 6, 0);
$row = 20;
$arr_data = array();
$PROCESS_COUNT = $REDIS->LLEN($error_type);
if ($PROCESS_COUNT > 0) {
if ($start === -1 || $start > $PROCESS_COUNT) $start = ($PROCESS_COUNT > $row ? $PROCESS_COUNT - $row : 0);
$arr_data = $REDIS->LRANGE($error_type, $start, ($start + $row - 1));
} else {
$start = 0;
}
$arr_data[] = array($PROCESS_COUNT, $start);
echo json_encode($arr_data);
break;
}
exit;
function SDATA_OUT($key, $opt, $def, $maxL=0, $minL=0) {
if (isset($_GET[$key])) {
$val = $_GET[$key];
} else {
if ($def === 'EXIT') {
exit;
} else {
return $def;
}
}
switch ($opt) {
case 0:
$mval = filter_var($val, FILTER_SANITIZE_STRING);
if (strlen($mval) !== strlen($val)) {
return '';
} else {
if (strlen($val) > $maxL) {
return substr($val, 0, $maxL);
} else {
return $val;
}
}
case 4:
$mval = filter_var($val, FILTER_SANITIZE_STRING);
if (strlen($mval) === $maxL) {
return $val;
} else {
exit;
}
case 6:
$tmp = (int)$val;
if ((string)$tmp !== (string)$val) {
exit;
} else {
return $tmp;
}
}
return NULL;
}
function verify_admin($uid, $t, $v) {
$n = time();
if ($t < $n) exit;
$matchvisa = md5($uid . $t . ENCODE_FACTOR . '4');
if ($v === $matchvisa) return true;
exit;
}
function con_db($host, $user, $pw) {
$con = mysqli_connect($host,$user,$pw);
if (mysqli_connect_errno($con)) return false;
return $con;
}
function use_db(&$con, $db) {
$db_selected = mysqli_select_db($con, $db);
if ($db_selected) return true;
return false;
}
?>
PHP
1
https://gitee.com/guibinwu/Centcount-Analytics.git
git@gitee.com:guibinwu/Centcount-Analytics.git
guibinwu
Centcount-Analytics
百夫长统计
master

搜索帮助