비동기 이메일 또는 SMS 전송 작업을 위해 gearman을 사용하는 PHP에 대한 자세한 설명

이 문서의 예에서는 PHP가 gearman을 사용하여 비동기 이메일 또는 SMS 전송 작업을 수행하는 방법을 설명합니다. 참고하실 수 있도록 자세한 내용은 다음과 같습니다.

1. 준비

1. 업무 처리 중 다운타임을 방지하기 위해 기어맨의 지속 방식을 구성해 주세요.
2. 테스트를 용이하게 하기 위해 gearmanManager를 사용하여 작업자 스크립트를 관리합니다.

관련 학습 권장사항: PHP 프로그래밍 초보부터 능숙까지

2. 테스트 스크립트 작성

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

client.php< /code>코드는 다음과 같습니다.

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

3. gearmanManager에서 구성 정보를 수정합니다

My gearmanManager가 /data/GearmanManager/

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

에 설치되어 있습니다. 다음 정보를 추가하면 5개의 프로세스가 시작됩니다. for sendEmail

> 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 &

4. gearman을 시작합니다

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

5. gearmanManager를 시작합니다

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

6. Ctrl+C를 실행하면 client.php를 실행합니다. pecl_manager.php에서 , 작업자가 강제로 닫힙니다. Client.php는 여전히 정상적으로 요청을 보낼 수 있지만 데이터는 mysql에 저장됩니다.

작업자를 다시 시작하면 기어맨이 처리되지 않은 작업을 다시 로드하여 처리합니다.

My mysql은 호스트 머신에 설치되어 있고 gearman은 가상 머신에 설치되어 있습니다. 친구가 gearman이 mysql에 연결할 수 없다는 것을 알게 되면 일시적으로 win10 방화벽을 끄고 win10의 ping 에코를 활성화할 수 있습니다.

위 내용은 비동기 이메일 또는 SMS 전송 작업을 위해 gearman을 사용하는 PHP에 대한 자세한 설명의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!