利用 Gearman 实现系统错误报警功能

时间：2023-03-10 06:55:01
利用 Gearman 实现系统错误报警功能

Gearman 是什么？

Gearman是一个用来把工作委派给其他机器、分布式的调用更适合做某项工作的机器、并发的做某项工作在多个调用间做负载均衡、或用来在调用其它语言的函数的系统。

Gearman 工作原理

  • Client(客户端)：创建一个Job。

  • Server(服务)：找到合适的Worker,把 Job 交给 Worker。

  • Worker(工人)：执行Job。

利用 Gearman 实现系统错误报警功能

Web 中常用的场景。

  • 裁剪图片，生成缩略图。

  • 文件分发（针对用户上传的文件，进行多台服务器分发）。

  • 视频转码（对上传的视频，进行转码存储）。

  • 系统报警（当系统出现问题的时候，第一时间通知相关人）。

这篇文章主要讲解 系统报警 场景

在开发系统的过程中，往往程序会出现这样，那样的问题。

我们要第一时间获取错误问题，通知短信，邮件通知给相关人员。

因为，短信、邮件的发送比较耗时，并发量大的情况下，会出现延时现象。

所以，使用 Gearman 实现短信，邮件的异步发送。

Gearman 安装的两种方式

  • 方式一：官网推荐安装方法

官网地址：http://gearman.org/getting-st...

yum install gearmand

  • 方式二：自定义安装

    • 安装libevent：

      wget get https://github.com/libevent/libevent/releases/download/release-2.0.22-stable/libevent-2.0.22-stable.tar.gz

tar zxvf libevent-2.0.22-stable.tar.gz

./configure --prefix=/usr

make && make install

      • 安装Gearman server and library：

        wget get https://launchpad.net/gearmand/1.2/1.1.12/+download/gearmand-1.1.12.tar.gz

tar zxvf gearmand-1.1.12.tar.gz

cd gearmand-1.1.12

./configure

如果报错：configure: error: could not find boost

yum install -y boost boost-devel

如果报错：configure: error: could not find gperf

yum install gperf

如果报错：configure: error: Unable to find libuuid

yum install libuuid-devel

make && make install

安装成功后，执行 gearmand -V 查询版本号。

gearmand -d 开启服务。

温馨提示：
        
仅供参考，遇到不可预测的问题，请进行Google。

      • 安装Gearman PHP extension：

        wget get http://pecl.php.net/get/gearman-1.1.2.tgz

tar zxvf gearman-1.1.2.tgz

cd gearman-1.1.2

/usr/local/php/bin/phpize

./configure --with-php-config=/usr/local/php/bin/php-config --with-gearman

如果报错：configure: error: Please install libgearman

yum install -y libgearman-devel.x86_64

案例（系统报警）

  • 开启服务

gearmand -d

  • 执行Worker

php worker.php

  • client.php

<?php

//设置错误处理器

set_error_handler('errorHandler');

//在脚本结束时运行的函数

register_shutdown_function('fatalErrorHandler');

//这里发生一个警告错误,被errorHandler 捕获

$a = $b;

//发生致命错误，脚本停止运行触发 fatalErrorHandler

$c = new Test();

/**

 * 错误处理

 * @param int    $err_no         错误代码

 * @param string $err_msg        错误信息

 * @param string $err_file       错误文件

 * @param int    $err_line       错误行号

 * @param int    $is_fatal_error 是否为致命错误

 * @return string

 */

function errorHandler($err_no = 0, $err_msg = '', $err_file = '', $err_line = 0, $is_fatal_error = 0)

{

    $strEmailInfo = ($is_fatal_error == 1) ? "【致命错误】\n" : "【警告错误】\n";

    $strEmailInfo .= "时间:".date('Y-m-d H:i:s')."\n";

    $strEmailInfo .= "错误代码:{$err_no}\n";

    $strEmailInfo .= "错误信息:{$err_msg}\n";

    $strEmailInfo .= "错误文件:{$err_file}\n";

    $strEmailInfo .= "错误行号:{$err_line}\n";

    $strSmsInfo = "[致命错误]错误代码:{$err_no},错误信息:{$err_msg},错误文件:{$err_file}";

    $client= new GearmanClient();

    $client->addServer("127.0.0.1", 4730);

    $client->doNormal("send_mail", $strEmailInfo);

    if ($is_fatal_error == 1) {

        $client->doNormal("send_sms", $strSmsInfo);

    }

}

/**

 * 捕捉致命错误

 * @return string

 */

function fatalErrorHandler() {

    $e = error_get_last();

    switch ($e['type']) {

        case 1:

            errorHandler($e['type'], $e['message'], $e['file'], $e['line'], 1);

            break;

    }

}

  • worker.php

<?php

  $worker = new GearmanWorker();

  $worker->addServer("127.0.0.1", 4730);

  $worker->addFunction("send_mail", "doSendMail");

  $worker->addFunction("send_sms", "doSendSms");

  while ($worker->work());

  /**

   * 执行发送邮件的Job

   * @param $job

   * @return string

   */

  function doSendMail($job)

  {

    $strEmailInfo = $job->workload();

    /**

     * 在这个方法里完善发送邮件的操作

     * ......

     * Demo是把信息写入到文件中

     */

    return file_put_contents("gearman.txt", $strEmailInfo."\n", FILE_APPEND);

  }

  /**

   * 执行发送短信的Job

   * @param $job

   * @return string

   */

  function doSendSms($job)

  {

    $strSmsInfo = $job->workload();

    /**

     * 在这个方法里完善发送短信的操作

     * ......

     * Demo是把信息写入到文件中

     */

    return file_put_contents("gearman.txt", $strSmsInfo."\n", FILE_APPEND);

  }

  • gearman.txt



【警告错误】

时间:2016-09-22 23:15:10

错误代码:8

错误信息:Undefined variable: b

错误文件:/home/www/mi/gearman/client.php

错误行号:9

【致命错误】

时间:2016-09-22 23:15:10

错误代码:1

错误信息:Class 'Test' not found

错误文件:/home/www/mi/gearman/client.php

错误行号:12

[致命错误]错误代码:1,错误信息:Class 'Test' not found,错误文件:/home/www/mi/gearman/client.php

温馨提示

  • 也可以用 Redis Queue 来实现上面的需求。

  • 也可以用 Swoole 来实现上面的需求。

  • 也可以了解下 Gearman 与 Swoole 的区别。

相关文章