利用 Gearman 實現系統錯誤報警功能

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 的區別。