### 1、ThinkPHP3.1控制器的代码
```
class interfaceDriver2017Action extends CommonAction{
	// 构造函数挂载入口
    public function __construct(){
        $this->rpc_data = $this->rpc_route_cpu_report();
    }
	
	// 析构函数提交监控数据到RPC
	public function __destruct() {
        $rpc_data = $this->rpc_route_cpu_report($this->rpc_data);
        
        // 读取框架SQL日志
        $list = trace($value='[think]');
        if (isset($list['SQL'])) {
            $list = $list['SQL'];
            $sql = array(
                'select_num' => 0,
                'select_time' => 0,
                'insert_num' => 0,
                'insert_time' => 0,
                'update_num' => 0,
                'update_time' => 0,
                'delete_num' => 0,
                'delete_time' => 0,
            );
            foreach ($list as $v) {
                // 查询
                if (stripos($v, 'SHOW COLUMNS') !== false || stripos($v, 'SELECT') !== false) {
                    $sql['select_num']++;
                    $arr = explode('RunTime:', $v);
                    $arr = explode('s ]', $arr[1]);
                    $sql['select_time'] = round($sql['select_time']+$arr[0], 4);
                    continue;
                }
                // 新增
                if (stripos($v, 'INSERT') !== false) {
                    $sql['insert_num']++;
                    $arr = explode('RunTime:', $v);
                    $arr = explode('s ]', $arr[1]);
                    $sql['insert_time'] = round($sql['insert_time']+$arr[0], 4);
                    continue;
                }
                // 修改
                if (stripos($v, 'UPDATE') !== false) {
                    $sql['update_num']++;
                    $arr = explode('RunTime:', $v);
                    $arr = explode('s ]', $arr[1]);
                    $sql['update_time'] = round($sql['update_time']+$arr[0], 4);
                    continue;
                }
                // 删除
                if (stripos($v, 'UPDATE') !== false) {
                    $sql['delete_num']++;
                    $arr = explode('RunTime:', $v);
                    $arr = explode('s ]', $arr[1]);
                    $sql['delete_time'] = round($sql['delete_time']+$arr[0], 4);
                    continue;
                }
            }
            $rpc_data = array_merge($rpc_data, $sql);
        }
        // 请求RPC服务
        require_once 'vendor/SwooleXRpc/RpcClient.php';
        $Rpc = new RpcClient();
        $Rpc->route('zabbix/client_report')
			->func('run')
			->param($rpc_data)
			->max(1)
			->task()
            ->send();
	}
	
	// 监控数据函数
    public function rpc_route_cpu_report($data=array()) {
        // 开始
        if (!$data) {
            $data['time'] = time();
            $data['route'] = $_SERVER['REQUEST_URI'];
            $data['task_time'] = explode(' ',microtime());
            $data['cpu'] = memory_get_usage();
        // 结束
        } else {
            // 耗时
            $end = explode(' ',microtime());
            $thistime = $end[0]+$end[1]-($data['task_time'][0]+$data['task_time'][1]);
            $data['task_time'] = round($thistime, 6);
            // 内存
            $end_memory = memory_get_usage();
            $use_memory = $end_memory - $data['cpu'];
            if ($use_memory <= 1024) {
                $data['cpu'] = $use_memory.'B';
            } else {
                $use_memory =  round($use_memory/1024, 2);
                if ($use_memory <= 1024) {
                    $data['cpu'] = $use_memory.'KB';
                } else {
                    $use_memory =  round($use_memory/1024, 2);
                    if ($use_memory <= 1024) {
                        $data['cpu'] = $use_memory.'MB';
                    } else {
                        $data['cpu'] = round($use_memory/1024, 2).'TB';
                    }
                }
            }
        }
        return $data;
    }
}
```

### 2、RPC服务代码
```
<?php
// +----------------------------------------------------------------------
// | 提交API监控数据
// +----------------------------------------------------------------------
// | Copyright (c) 2018 https://blog.junphp.com All rights reserved.
// +----------------------------------------------------------------------
// | Licensed ( http://www.apache.org/licenses/LICENSE-2.0 )
// +----------------------------------------------------------------------
// | Author: 小黄牛 <1731223728@qq.com>
// +----------------------------------------------------------------------

namespace app\rpc\zabbix;

class client_report {

public function run() {
        $data = json_encode($this->param);
        $redis_key = 'zabbix_'.md5($this->param['route']);

$Redis = new \x\Redis();
        $Redis->select(13);
        $status = $Redis->llen($redis_key);
        $Redis->lpush($redis_key, $data);
        // 不存在就更新有效期
        if (!$status) {
			// 这里根据你定时器任务多久执行一次，来配置过期时间
            $Redis->expire($redis_key, 70);
        }
        $Redis->return();

return true;
    }
}
```

### 3、添加一个RPC服务节点
![](https://blog.junphp.com/public/upload/20210422111401_775.png)

### 4、创建一个监控数据表
```
CREATE TABLE `sw_zabbix_report` (
  `id` bigint(13) NOT NULL AUTO_INCREMENT,
  `route` varchar(255) DEFAULT NULL,
  `time` int(11) DEFAULT NULL,
  `task_time` decimal(10,6) DEFAULT NULL,
  `cpu` varchar(32) DEFAULT NULL,
  `select_num` int(11) DEFAULT NULL,
  `select_time` decimal(10,4) DEFAULT NULL,
  `insert_num` int(11) DEFAULT NULL,
  `insert_time` decimal(10,4) DEFAULT NULL,
  `update_num` int(11) DEFAULT NULL,
  `update_time` decimal(10,4) DEFAULT NULL,
  `delete_num` int(11) DEFAULT NULL,
  `delete_time` decimal(10,4) DEFAULT NULL,
  `create_time` int(11) DEFAULT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='API监控表';
```

### 5、添加一个定时器
```
<?php
// +----------------------------------------------------------------------
// | zabbix数据回写到数据库
// +----------------------------------------------------------------------
// | Copyright (c) 2018 https://blog.junphp.com All rights reserved.
// +----------------------------------------------------------------------
// | Licensed ( http://www.apache.org/licenses/LICENSE-2.0 )
// +----------------------------------------------------------------------
// | Author: 小黄牛 <1731223728@qq.com>
// +----------------------------------------------------------------------

namespace app\crontab;

class zabbix_report {

/**
     * 统一入口
     * @todo 无
     * @author 小黄牛
     * @version v1.0.9 + 2020.04.16
     * @deprecated 暂不启用
     * @global 无
     * @param Swoole\Server $server
     * @return void
    */
    public function run($server) {
        // 60秒一次
        \Swoole\Timer::tick(60000, function ($timer_id) use ($server) {
            $Db = new \x\Db();
            $Redis = new \x\Redis();
            $Redis->select(13);
            $Redis->prefix('');
            $list = $Redis->keys('*');
            foreach ($list as $v) {
                $max = $Redis->llen($v);

$report = [
                    'task_time' => 0,
                ];
                for ($i=0; $i < $max; $i++) {
                    $json = $Redis->lpop($v);
                    if (!$json) break;
                    $arr = json_decode($json, true);
                    if ($arr['task_time'] > $report['task_time']) {
                        $report = $arr;
                    }
                }
                // 更新到Db
                if (isset($report['route'])) {
                    $report['create_time'] = time();
                    $Db->name('zabbix_report')->insert($report);
                }
            }
            $Db->return();
            $Redis->return();
        });
    }
}
```

### 6、监控数据显示
这个可以自行实现，如果安装了zabbix监控的，可以直接写脚本读取数据，显示到图形表上。

也可以用HTML+PHP写页面，读取成表格来查看。

### 7、下面是数据展示，用的ThinkPHP3.1
图表插件：`https://www.jq22.com/jquery-info18594`
视图代码
```
<body>
<h1 class="xdcms_search_title"><div id="open_search"></div>API监控记录</h1>
<div class="line"></div>
<div id="XDcms_search">

<div class="more-bg">
<form name="form2" method="get">
	<dl>
		<dd>&nbsp;&nbsp;路由:<input type="text" name="route" value="<{$route}>" id="driver_sn" style="width:280px;height:20px;"/></dd>
		<dd>&nbsp;&nbsp;请求时间:<input type="text" name="start" id="start" value="<{$start}>" style="width:180px;height:20px;"/></dd>
		<dd>-<input type="text" name="end" value="<{$end}>" id="end" style="width:180px;height:20px;"/></dd>
	</dl>
	<dl>
		<dd>&nbsp;&nbsp;排序:
			<select name="order">
				<option value="0">最新</option>
				<option value="1" <if condition="$order == 1">selected</if>>最高耗时</option>
				<option value="2" <if condition="$order == 2">selected</if>>最低耗时</option>
		</select>
		</dd>
		<dd>&nbsp;&nbsp;总耗时超标:
			<select name="max">
				<option value="0">全部</option>
				<option value="1" <if condition="$max == 1">selected</if>>是</option>
		</select>
		</dd>
		<dd>&nbsp;&nbsp;查询-耗时:
			<select name="select_time">
				<option value="0">全部</option>
				<option value="1" <if condition="$select_time == 1">selected</if>>是</option>
		</select>
		</dd>
		<dd>&nbsp;&nbsp;新增-耗时:
			<select name="insert_time">
				<option value="0">全部</option>
				<option value="1" <if condition="$insert_time == 1">selected</if>>是</option>
		</select>
		</dd>
		<dd>&nbsp;&nbsp;修改-耗时:
			<select name="update_time">
				<option value="0">全部</option>
				<option value="1" <if condition="$update_time == 1">selected</if>>是</option>
		</select>
		</dd>
		<dd>&nbsp;&nbsp;删除-耗时:
			<select name="delete_time">
				<option value="0">全部</option>
				<option value="1" <if condition="$delete_time == 1">selected</if>>是</option>
		</select>
		</dd>
		<dd><input name="submit" type="submit" value="搜索" class="submit ml20" style="width:90px;"/></dd>
	</dl>
</form>
<br/>
<font color="red">注意：当耗时大于0.5秒时，会显示为红色</font>
</div>

<table width="100%" border="0" class="xdcms_table">
  <tr>
    <th colspan="25" class="title"></span><div class="title_nav_3"><a href="javascript:location.reload()"><{$Think.lang.refresh_page}></a></div></th>
  </tr>
  <tr>
	<th class="tc">请求时间</th>
	<th class="tc">路由</th>
	<th class="tc">请求耗时</th>
    <th class="tc">内存开销</th>
    <th class="tc">SELECT</th>
    <th class="tc">总耗时</th>
    <th class="tc">INSERT</th>
    <th class="tc">总耗时</th>
    <th class="tc">UPDATE</th>
    <th class="tc">总耗时</th>
    <th class="tc">DELETE</th>
	<th class="tc">总耗时</th>
	<th class="tc">请求参数</th>
	<th class="tc">记录时间</th>
  </tr>

<foreach name="result" item="r">
  <tr height="40" class="bf" ondblclick="opens('<{$r.route}>')" title="双击根据时间条件-查看图表">
  	<td class="tc"><{$r.time|date="Y-m-d H:i",###}></td>
  	<td class="tc"><{$r.route}></td>
  	<td class="tc"><if condition="$r['task_time'] gt 0"><font color="<if condition="$r['task_time'] egt 0.5">red</if>"><{$r.task_time}> 秒</font></if></td>
  	<td class="tc"><{$r.cpu}></td>
  	<td class="tc"><{$r.select_num}></td>
  	<td class="tc"><if condition="$r['select_time'] gt 0"><font color="<if condition="$r['select_time'] egt 0.5">red</if>"><{$r.select_time}> 秒</font></if></td>
  	<td class="tc"><{$r.insert_num}></td>
  	<td class="tc"><if condition="$r['insert_time'] gt 0"><font color="<if condition="$r['insert_time'] egt 0.5">red</if>"><{$r.insert_time}> 秒</font></if></td>
  	<td class="tc"><{$r.update_num}></td>
  	<td class="tc"><if condition="$r['update_time'] gt 0"><font color="<if condition="$r['update_time'] egt 0.5">red</if>"><{$r.update_time}> 秒</font></if></td>
  	<td class="tc"><{$r.delete_num}></td>
	<td class="tc"><if condition="$r['delete_time'] gt 0"><font color="<if condition="$r['delete_time'] egt 0.5">red</if>"><{$r.delete_time}> 秒</font></if></td>
	<td class="tc"><{$r.param}></td>
  	<td class="tc"><{$r.create_time|date="Y-m-d H:i",###}></td>
  </tr>
  
  </foreach>
 <tr class="bf">
    <td colspan="25" class="tc"><{$pages}></td></tr>
</table>

<body>

</body>
</html>

yMarkers: [
		{
			label: "单位：秒",
			value: 9, // 最高单位
		}
	],

datasets: [{
		"name": "Events",
		"values": <{$data}>
	}]
};
let c1 = document.querySelector("#chart-composite-1");
let lineCompositeChart = new Chart (c1, {
	title: "<{$route}> / <{$start}> - <{$end}>",
	data: lineCompositeData,
	type: 'line',
	height: 190,
	colors: ['green'],
	isNavigable: 1,
	valuesOverPoints: 1,

lineOptions: {
		dotSize: 8
	},
});
</script>
```
控制器代码
```
<?php

class LogAction extends Action{

public function zabbix_tu(){
		import("@.ORG.page");
		
		$str = '';
		if(!empty($_GET['route'])){
			$str .= ' and route = "'.$_GET['route'].'" ';
			$this->assign('route',$_GET['route']);
		}
			
		if(!empty($_GET['start'])){
			$str .= ' and time >'.strtotime($_GET['start']);
			$this->assign('start',$_GET['start']);
		}
		if(!empty($_GET['end'])){
			$str .= ' and time <'.strtotime($_GET['end']);
			$this->assign('end',$_GET['end']);
		}

$model = M('zabbix_report');
		$result = $model->where('1=1 '.$str)->order('id ASC')->select(); 
		$data = array();
		$date = array();	
		foreach ($result as $v) {
			$data[] = $v['task_time'];
			$date[] = date('Y-m-d H:i:s', $v['time']);
		}
		
		$this->assign('data', json_encode($data));
		$this->assign('date', json_encode($date));
		$this->display();
	}

public function zabbix(){
		import("@.ORG.page");
		$order = 'id DESC';
		if(!empty($_GET['order'])){
			switch ($_GET['order']) {
				case 1: // 最高耗时
					$order = 'task_time DESC, id DESC';
					$this->assign('order', $_GET['order']);
				break;
				case 2: // 最低耗时
					$order = 'task_time ASC, id DESC';
					$this->assign('order', $_GET['order']);
				break;
			}
		}
		$str = '';
		if(!empty($_GET['route'])){
			$str .= ' and route like "%'.$_GET['route'].'%" ';
			$this->assign('route', $_GET['route']);
		}
			
		if(!empty($_GET['start'])){
			$str .= ' and time >'.strtotime($_GET['start']);
			$this->assign('start',$_GET['start']);
		}else{
			$m_date = date("Y-m-d");
			$str .= ' and time >'.strtotime($m_date);
			$this->assign('start',$m_date);
		}
		if(!empty($_GET['end'])){
			$str .= ' and time <'.strtotime($_GET['end']);
			$this->assign('end',$_GET['end']);
		}
		if(!empty($_GET['max'])){
			$str .= ' and task_time > 0.5';
			$this->assign('max',$_GET['max']);
		}
		if(!empty($_GET['select_time'])){
			$str .= ' and select_time > 0.5';
			$this->assign('select_time',$_GET['select_time']);
		}
		if(!empty($_GET['insert_time'])){
			$str .= ' and insert_time > 0.5';
			$this->assign('insert_time',$_GET['insert_time']);
		}
		if(!empty($_GET['update_time'])){
			$str .= ' and update_time > 0.5';
			$this->assign('update_time',$_GET['update_time']);
		}
		if(!empty($_GET['delete_time'])){
			$str .= ' and delete_time > 0.5';
			$this->assign('delete_time',$_GET['delete_time']);
		}

$model = M('zabbix_report');
		$total = $model->where(' 1=1 '.$str)->count();
		$configs = array('header'=>L('header'),'prev'=>L('prev'),'next'=>L('next'),'first'=>L('first'),'last'=>L('last'),'jump'=>L('jump'),
					 'count'=>L('count'),'unit'=>L('unit'),'each'=>L('each'),'page'=>L('page'),'this_page'=>L('this_page'));
      	$page = new Page($total,C('PAGE_NUM'),$configs);
      	$limit = str_replace('limit','',$page->limit);
		
		$result = $model->where(' 1=1 '.$str)->limit($limit)->order($order)->select(); 	
		
		$this->assign('result',$result);
		$this->assign('pages',$page->fpage(array(0,4,6,5,7,8,2,9)));
		$this->display();
	}
}
```

本案例只用于学习用途，请勿用于商业用途。

已有0条评论

添加新评论☺

如果认为本文对您有所帮助请赞助本站

支付宝扫一扫赞助

已有0条评论

添加新评论☺