Gearman 是什么？
Gearman是一个用来把工作委派给其他机器、分布式的调用更适合做某项工作的机器、并发的做某项工作在多个调用间做负载均衡、或用来在调用其它语言的函数的系统。
Gearman 工作原理
- Client(客户端)：创建一个Job。
- Server(服务)：找到合适的Worker,把 Job 交给 Worker。
- Worker(工人)：执行Job。
Gearman 工作原理
Web 中常用的场景。
- 裁剪图片，生成缩略图。
- 文件分发（针对用户上传的文件，进行多台服务器分发）。
- 视频转码（对上传的视频，进行转码存储）。
- 系统报警（当系统出现问题的时候，第一时间通知相关人）。
这篇文章主要讲解 系统报警 场景
在开发系统的过程中，往往程序会出现这样，那样的问题。
我们要第一时间获取错误问题，通知短信，邮件通知给相关人员。
因为，短信、邮件的发送比较耗时，并发量大的情况下，会出现延时现象。
所以，使用 Gearman 实现短信，邮件的异步发送。
Gearman 安装的两种方式
-
方式一：官网推荐安装方法
官网地址：http://gearman.org/getting-started/
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 的区别。
Thanks ~
