1. 程式人生 > 程式設計 >PHP使用gearman進行非同步的郵件或簡訊傳送操作詳解

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

PHP使用gearman進行非同步的郵件或簡訊傳送操作詳解

六、執行client.php

> /data/php56/bin/php /data/client.php

PHP使用gearman進行非同步的郵件或簡訊傳送操作詳解

當我們對pecl_manager.php進行ctrl+c時,強行關閉worker,client.php那邊仍可正常的傳送請求,不過資料都被儲存在了mysql中。
當我們重新把worker啟動時,gearman會重新載入沒有處理的進行處理。

PHP使用gearman進行非同步的郵件或簡訊傳送操作詳解
我的mysql是裝在主機的,虛擬機器裡裝了gearman,如果有朋友發現gearman無法連線mysql,可暫時關閉win10防火牆,和開啟win10被ping的回顯。

更多關於PHP相關內容感興趣的讀者可檢視本站專題:《PHP程序與執行緒操作技巧總結》、《PHP網路程式設計技巧總結》、《PHP基本語法入門教程》、《PHP陣列(Array)操作技巧大全》、《php字串(string)用法總結》、《php+mysql資料庫操作入門教程》及《php常見資料庫操作技巧彙總》

希望本文所述對大家PHP程式設計有所幫助。