使用场景，服务器报异常错误，想要及时收到报警信息并处理

环境介绍，本博使用yaf框架+php，仅仅提供思路，参考，具体根据自己实际情况进行编写

1，每十分钟执行一次任务脚本

# 每10分钟执行一次的任务

if [ "0" -eq "$(($minute % 10))" ]; then

php -f ${pathRoot}public/index.php 'request_uri=/error/dingdingLog'

fi

/**

* error action

*

* @return bool

* @throws Exception

*/

public function errorAction()

{

$req = $this->getRequest();

$exception = $req->getException();

//来自接口的错误

if ($exception instanceof ApiException) {

return $this->json($exception->getCode(), $exception->getMessage());

}

//其它异常

if ($this->yafAutoRender) {

$exceptions = [];

if (! $exception instanceof Exception) {

$exception = new Yaf\Exception\LoadFailed('no exception');

}

//add exception

$exceptions[] = $exception;

//show trace

$this->getView()->exceptions = $exceptions;

Yaf\Dispatcher::getInstance()->autoRender(true);

} else {

if ($exception instanceof Yaf\Exception\LoadFailed) { //接口不存在

$this->log($exception, ApiException::NOT_EXISTS);

return $this->json(ApiException::NOT_EXISTS, $exception->getMessage());

}

$this->log($exception);

return $this->json(ApiException::FATAL, $exception->getMessage());

}

}

5，修改框架错误日志log写入方法

/**

* error log

*

* @param Exception $exception

* @param int $error_code 0-正常报错

*/

private function log($exception, $error_code = 0)

{

//log exception

$msg = sprintf("%s:%s. in %s on line %s, trace:%s",

get_class($exception),

$exception->getMessage(),

$exception->getFile(),

$exception->getLine(),

$exception->getTraceAsString()

);

// 排除 404 的报错才推送

// there is not method / not such file or diractory

if ($error_code != ApiException::NOT_EXISTS) {

$this->saveLog($exception->getMessage());

}

LK::log()->error($msg);

}

如上所示，我将一部分日志写入redis

6，保存日志

public function saveLog($msg)

{

$redis = LK::redis('log');

$key = md5($msg);

$saved = $redis->sadd('error_log', $key);

if ($saved) {

$redis->setex($key, 1100, $msg);

}

return $saved;

}

7，读取redis消息，给钉钉推送错误消息

public function dingdingLogAction()

{

$redis = LK::redis('log');

$keys = $redis->sMembers('error_log');

if (count($keys)) {

foreach ($keys as $key) {

if (false != ($msg = $redis->get($key))) {

Func::dingdingLog($msg);

}

}

$redis->del('error_log');

}

}

8，curl上面那个地址，具体信息自行修改

/**

* 钉钉消息推送

* 推到钉钉 php+web 群

* @return bool

*/

public static function dingdingLog($msg)

{

$url = 'https://oapi.dingtalk.com/robot/send?access_token=XXXXXX';

$env = \Yaf\Application::app()->environ();

$fix = 'somi';

$time = date('Y-m-d H:i:s');

$data = [

'msgtype' => 'text',

'text' => [

'content' => "[{$fix}:{$env}:{$time}]:{$msg}",

]

];

$data_string = json_encode($data);

$resp = \Frame\Core\Tools::curl($url, 'POST', $data_string, ['Content-Type: application/json;charset=utf-8']);

$resp = json_decode($resp, true);

if ($resp['errorcode']) {

return false;

}

return true;

}

9，如图是我的报警信息示例