PHP使用gearman進行異步的郵件或短信發送操作詳解
本文實例講述了PHP使用gearman進行異步的郵件或短信發送操作。分享給大家供大家參考,具體如下:
一、準備工作
1、為了防止,處理業務途中出現的宕機,請配置好gearman的持久化方式。2、使用gearmanManager來管理我們的worker腳本,方便測試。
上述兩條請看我之前寫的兩篇文章
二、編寫測試腳本
sendEmail.php代碼如下:
<?php//注意函數名與文件名相同function sendEmail($job) { $workId = uniqid(); //workload()獲取客戶端發送來的序列化數據 $data = json_decode($job->workload(), true); //這里模擬處理過程 //具體的業務,這里應該是請求發送郵件的接口,這里只做演示 sleep(1); echo 'workId: {$workId} 發送 {$data[’email’]} 成功n';}
client.php代碼如下:
<?php//創建一個客戶端$client = new GearmanClient();//添加一個job服務$client->addServer(’127.0.0.1’, 4730);$cnt = 5000;$ret = array();//循環發送5000條郵件for($i = 0; $i < $cnt; ++$i) { //doBackground異步,返回提交任務的句柄 $ret[$i] = $client->doBackground(’sendEmail’, json_encode(array( ’email’ => '{$i}@qq.com', ’title’ => '郵件標題{$i}', ’body’ => '我是內容{$i}', )));}
三、修改gearmanManager中配置信息
我的gearmanManager是安裝在/data/GearmanManager/下
> vi /data/GearmanManager/etc/GearmanManager.ini
添加如下信息,我們為sendEmail啟動五個進程
[sendEmail];指定5個進程dedicated_count=5;5個進程都只做sendEmail工作dedicated_only=1
四、啟動gearman
> gearmand -d -q mysql --mysql-host=192.168.1.100 --mysql-port=3306 --mysql-user=gearman --mysql-password=123456 --mysql-db=gearman --mysql-table=gearman_queue &
五、啟動gearmanManager
> cd /data/GearmanManager> ./bin/pecl_manager.php -c /data/GearmanManager/etc/GearmanManager.ini -vvv
六、運行client.php
> /data/php56/bin/php /data/client.php
當我們對pecl_manager.php進行ctrl+c時,強行關閉worker,client.php那邊仍可正常的發送請求,不過數據都被保存在了mysql中。當我們重新把worker啟動時,gearman會重新載入沒有處理的進行處理。
我的mysql是裝在主機的,虛擬機里裝了gearman,如果有朋友發現gearman無法連接mysql,可暫時關閉win10防火墻,和開啟win10被ping的回顯。
更多關于PHP相關內容感興趣的讀者可查看本站專題:《PHP進程與線程操作技巧總結》、《PHP網絡編程技巧總結》、《PHP基本語法入門教程》、《PHP數組(Array)操作技巧大全》、《php字符串(string)用法總結》、《php+mysql數據庫操作入門教程》及《php常見數據庫操作技巧匯總》
希望本文所述對大家PHP程序設計有所幫助。
相關文章: