利用 Gearman 實現系統錯誤報警功能
阿新 • • 發佈：2017-08-05
-m bre load() 區別 inf .cn cnblogs 短信 date
Gearman 是什麽？
Gearman是一個用來把工作委派給其他機器、分布式的調用更適合做某項工作的機器、並發的做某項工作在多個調用間做負載均衡、或用來在調用其它語言的函數的系統。
Gearman 工作原理
-
Client(客戶端)：創建一個Job。
-
Server(服務)：找到合適的Worker,把 Job 交給 Worker。
-
Worker(工人)：執行Job。
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 的區別。
利用 Gearman 實現系統錯誤報警功能