Explication détaillée de PHP utilisant Gearman pour les opérations d'envoi asynchrone d'e-mails ou de SMS

L'exemple de cet article décrit l'utilisation de PHP gearman pour des opérations d'envoi asynchrone d'e-mails ou de SMS. Partagez-le avec tout le monde pour votre référence, les détails sont les suivants :

1. Travaux de préparation

1 Afin d'éviter les temps d'arrêt pendant le traitement commercial, veuillez configurer Gearman. Méthode de persistance.
2. Utilisez gearmanManager pour gérer nos scripts de travail afin de faciliter les tests.

Recommandations d'apprentissage associées : Programmation PHP de l'entrée à la maîtrise

Rédaction de scripts de test

sendEmail.phpLe code est le suivant :

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

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

client.phpLe code est le suivant :

<?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}",
  )));
}

3. Modifiez les informations de configuration dans gearmanManager

Mon gearmanManager est installé sous /data/GearmanManager/

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

Ajoutez les informations suivantes, nous démarrons cinq processus pour sendEmail

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

4. Démarrez 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 &

5. Démarrez gearmanManager

> cd /data/GearmanManager
> ./bin/pecl_manager.php -c /data/GearmanManager/etc/GearmanManager.ini -vvv

6. Exécutez client.php

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

Lorsque nous effectuons ctrl+c sur pecl_manager.php et fermons de force le travailleur, client.php peut toujours envoyer des requêtes normalement, mais les données sont enregistrées dans MySQL.
Lorsque nous redémarrons le travailleur, Gearman rechargera ceux non traités pour le traitement.

Mon MySQL est installé sur la machine hôte et Gearman est installé sur la machine virtuelle. Si des amis constatent que Gearman ne peut pas se connecter à MySQL, ils peuvent désactiver temporairement le pare-feu Win10 et. activez la réponse ping de win10 show.

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!