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

本文實例講述了PHP使用gearman進行非同步的郵件或簡訊發送操作。分享給大家供大家參考，具體如下：

一、準備工作

1、為了防止，處理業務途中出現的宕機，請配置好gearman的持久化方式。
2、使用gearmanManager來管理我們的worker腳本，方便測試。

相關學習推薦：PHP程式設計從入門到精通

#二、寫測試腳本

#sendEmail.php程式碼如下：

<?php
//注意函数名与文件名相同
function sendEmail($job) {
  $workId = uniqid();

  //workload()获取客户端发送来的序列化数据
  $data = json_decode($job->workload(), true);
  
  //这里模拟处理过程
  //具体的业务，这里应该是请求发送邮件的接口，这里只做演示
  sleep(1);
  
  echo "workId: {$workId} 发送 {$data[&#39;email&#39;]} 成功\n";
}

client.php程式碼如下：

<?php
//创建一个客户端
$client = new GearmanClient();
//添加一个job服务
$client->addServer(&#39;127.0.0.1&#39;, 4730);

$cnt = 5000;
$ret = array();

//循环发送5000条邮件
for($i = 0; $i < $cnt; ++$i) {
  //doBackground异步，返回提交任务的句柄
  $ret[$i] = $client->doBackground(&#39;sendEmail&#39;, json_encode(array(
    &#39;email&#39; => "{$i}@qq.com",
    &#39;title&#39; => "邮件标题{$i}",
    &#39;body&#39; => "我是内容{$i}",
  )));
}

三、修改gearmanManager中設定資訊

我的gearmanManager是安裝在/data/GearmanManager/下

> vi /data/GearmanManager/etc/GearmanManager.ini

添加如下信息，我們為sendEmail啟動五個進程

[sendEmail]
;指定5个进程
dedicated_count=5
;5个进程都只做sendEmail工作
dedicated_only=1

4、啟動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使用gearman進行非同步的郵件或簡訊發送操作的詳細內容。更多資訊請關注PHP中文網其他相關文章！