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程序设计有所帮助。

赞 (0)

相关推荐

  • php使用gearman进行任务分发操作实例详解

    php使用gearman进行任务分发操作实例详解

    本文实例讲述了php使用gearman进行任务分发操作.分享给大家供大家参考,具体如下: 一.安装gearman 下载gearman源码包 https://launchpad.net/gearmand/+download 如: gearmand-1.1.12.tar.gz 下载php的gearman扩展包 http://pecl.php.net/package/gearman 如: gearman-1.1.2.tgz 安装gearman > yum install boost-devel gpe

  • python基于json文件实现的gearman任务自动重启代码实例

    一:在gearman任务失败后,调用task_failed def task_failed(task, *args): info = '\n'.join(args) datetime = local_datetime() text = '{} FAILED:\n{}\n当前响应worker已关闭\n{}\n-->[{}]'.format(task, info, datetime, task) print(text) check_frequency(task) 二:打印失败信息后,调用check_

  • 实现PHP多线程异步请求的3种方法

    在网上看过很多版本的PHP异步请求方法,这里简单总结几个常用方法分享给大家 1.用CURL实现一步请求 CURL扩展是我们在开发过程中最常用的一种方法,他是一个强大的HTTP命令行工具,可以模拟POST/GET等HTTP请求,然后得到和提取数据,显示在"标准输出"(stdout)上面. 示例: 复制代码 代码如下: <?php $cl = curl_init(); $curl_opt = array(CURLOPT_URL, 'http://www.uncletoo.com/de

  • 深入PHP异步执行的详解

    Web服务器执行一个PHP脚本,有时耗时很长才能返回执行结果,后面的脚本需要等待很长一段时间才能继续执行.如果想实现只简单触发耗时脚本的执行而不等待执行结果就直接执行下一步操作,可以通过fscokopen函数来实现.PHP支持socket编程,fscokopen函数返回一个到远程主机连接的句柄,可以像使用fopen返回的句柄一样,对它进行fwrite.fgets.fread等操作.使用fsockopen连接到本地服务器,触发脚本执行,然后立即返回,不等待脚本执行完成,即可实现异步执行PHP的效果

  • PHP并发多进程处理利器Gearman使用介绍

    PHP并发多进程处理利器Gearman使用介绍

    工作中我们有时候会遇到比如需要同时发布数据到多个个服务器上,或者同时处理多个任务.可以使用PHP的curl_multi的方式并发处理请求,但是由于网络和数据以及各个服务器等等的一些情况导致这种并发处理的响应时间很慢,因为在并发请求的过程中还包括记录日志,处理数据等逻辑,等待处理结果并返回,所以也不能友好的满足后台操作的体验. 现在有另外一种方案,利Gearman来实现并发的需求.通过Client将请求发送到Gearman的Jobs,在每个Work中来再来进行curl_multi和数据处理和日志等

  • gearman + mysql方式实现持久化操作示例

    本文实例讲述了gearman+mysql方式实现持久化操作.分享给大家供大家参考,具体如下: 1.为什么要持久化? gearman的job server中的工作队列存储在内存中,一旦服务器有未处理的任务时重启或者宕机,那么这些任务就会丢失. 持久化存储队列可以允许添加后台任务,并将其存储在外部的持久型队列里(比如MySQL数据库). 2.关于gearman的持久化的文章,建议可以看官方文档 http://gearman.org/manual/job_server/#persistent_queu

  • gearman的安装启动及python API使用实例

    本文讲述了gearman的安装启动及python API使用实例,对于网站建设及服务器维护来说非常有用! 一.概述: Gearman是一款非常优秀的任务分发框架,可以用于分布式计算.具体的gearmand服务的安装启动及gearman的python 模块的安装以及简单示例如下:   操作系统:rnel 5.7 1. 首先,我们需要安装gearmand,在centos和rhel环境下,我们只需运行以下命令: yum install gearmand -y   注意:如果不希望通过yum的方式来安装

  • gearman队列持久化引发的问题及解决方法

    本文简述了gearman用mysql持久化的方法,以及由此引发的一些问题,具体分析如下: 一.gearman 创建Mysql持久化队列的方式如下: 1. 登入mysql命令行,运行: create database gearman; 2. 启动gearman,命令如下: /usr/local/gearman/sbin/gearmand -p 4730 -L 0.0.0.0 --log-file=/tmp/gearmand-4730.log --pid-file=/tmp/gearmand-473

  • Gearman::XS在Centos下的编译安装方法

    本文简述了Gearman::XS在Centos下编译安装方法,供大家参考学习一下! 目前Gearman能够支持各种语言,其官网的描述如下: Language Bindings/Drivers/Frameworks Select your language – cross links to download section which details all your options. C, C#/.NET, Go, Java, Lisp, Nodejs, PHP, Perl, Python, R

  • gearman管理工具GearmanManager的安装与php使用方法示例

    本文实例讲述了gearman管理工具GearmanManager的安装与php使用方法.分享给大家供大家参考,具体如下: 一.gearman自带了一个gearadmin工具 查看帮助信息 > gearadmin --help 查看状态 > gearadmin --status 查看worker信息 > gearadmin --workers 二.为什么要用GearmanManager 为什么要用GearmanManager来管理我们的worker,因为我们用php编写的worker是要常

  • rhel5.7下安装gearmand及启动的方法

    本文简述了在rhel5.7下安装gearmand及启动的方法,供大家学习参考! 首先,到官网https://launchpad.net/gearmand/下载gearmand的源码包,传到rhel5.7的系统上,并解压.   运行configure: [@localhost gearmand-1.1.11]# ./configure --prefix=/usr/local/gearman --with-mysql --with-sqlite3=no 这时候会出现报如下错误: checking f

随机推荐