热门标签 | HotTags
当前位置:  开发笔记 > 编程语言 > 正文

SAE新浪TaskQueue使用技巧

来,我们测试一下TaskQueueSAE设置服务限制和配额的目的是为了防止个别用户攻击和滥用,从而在公有云计算平台上保证绝大多数开发者的正常使用


         //SAE需要手动建立一个test,然后通过如下代码调用使用


        $t = new SaeTaskQueue("test");
        $t->addTask("http://" . $_SERVER['HTTP_HOST'] . __URL__ . "/tq_test1"); //添加列队任务1
        $t->addTask("http://" . $_SERVER['HTTP_HOST'] . __URL__ . "/tq_test2", "k1=v1&k2=v2", true); //添加列队任务2
        if (!$t->push()) {
            echo '出错:' . $t->errmsg();
        } else {
            echo '执行成功!请查看[' . LOG_PATH . 'sae_debug.log' . ']文件中的日志';
        }


      //列队任务1
      public function tq_test1() {
           sae_debug("列队任务1被执行"); 
      }


      //列队任务2
      public function tq_test2() {
           sae_debug("列队任务2被执行,k1的值:{$_POST['k1']},k2的值:{$_POST['k2']}"); 
      }






 ?>


 

后附SAE的TaskQueue介绍---------------

 

   TaskQueue 是SAE为开发者提供的分布式任务队列服务,用来以异步HTTP方式执行用户任务。用户需要先在在线管理平台创建Queue,然后向Queue Push任务,放入队列的任务随即即会执行。TaskQueue 的任务的执行是以HTTP方式执行的,真正执行的是用户在App中的PHP代码,所以最长执行时间和HTTP页面执行时间相同。TaskQueue 服务是分布式环境部署的,具有高可靠性,每个worker相互隔离,并且主动负责任务执行。

    Queue分为顺序队列和并发队列,顺序队列的任务顺序执行,而并发队列中的任务则以并行的方式执行。用户还可以为每个Queue指定error callback url,当每个任务执行失败时,TaskQueue 自动会调用error callback url通知开发者。

    特别注意:

  • TaskQueue 的任务的最长时间不得超过30秒
  • 并发队列不保证任务的有序性
  • 所有队列类型都有最大长度,请勿使队列长期阻塞
  • 所有APP创建TaskQueue 总数<=10

 

应用场景

    TaskQueue 服务主要提供针对http方式的异步任务执行,如开发者想给1000个用户发送微博,如果写成:

    for($i=0;$i<1000;$i++)

        send_weibo(); 

    很容易造成页面超时,因为发送任务均为同步执行。而如果使用TaskQueue 则不会超时,如写成:

    $array=array();
    for($i=0;$i<1000;$i++)
        $array[]=array('url'=>"http://freedemo.sinaapp.com/sendweibo.php", "postdata"=>user[$i]);

    $queue->addTask($array);

 

 

使用指南

    例子:

    appname: saetest

    appversion: 1

 

 创建queue

    使用TaskQueue 服务执行,开发者需要登录在线管理平台,并进入服务管理=>TaskQueue ,先创建队列。TaskQueue 目前的队列分成两大类,顺序队列和并发队列:


 

 

    一些概念:

  • 顺序队列:并发度为1,以保证任务可以按照进入队列的先后顺序依次执行
  • 并发队列:并发度>1,进入队列的任务将按并发度并行执行,不保证严格有序
  • 并发度:负责处理该队列的worker数量,worker越多处理的越快
  • worker:负责处理任务,并执行Web请求
  • 最大长度:当队列worker处理较慢,队列发生阻塞时,允许队列的最大长度,当队列达到最大长度时,新的任务将不能进入队列,直到有旧任务从队列中消费出去为止
  • 任务:TaskQueue 目前只支持web任务,任务的执行可以用GET或者POST方式,用户负责对格式做拼装和解析
  • 队列属性还有一个“失败回调URL”,指的是:当该任务执行失败时,回调的URL地址,如果用户制定了该地址,SAE会将原请求的 url上增加原请求地址后原封不动再发送给回调URL,如:用户原HTTP请求(GET):http://kobe.sinaapp.com /a.php,用户指定了失败回调URL:http://kobe.sinaapp.com/error_callback.php,则当TaskQueue 失败时得到的回调是:http://kobe.sinaapp.com/error_callback.php?url=http://kobe.sinaapp.com/a.php ,如果原请求为POST方式,则post段内容不变。

    用户可以根据自身的需要创建不同属性的队列,如果对顺序性要求强烈,可以选择顺序队列,如果对处理速度要求强烈,可以选择并发大的并发队列;如果任务执行较慢,可能发生拥堵,则最好选择队列最大长度较大的队列。

 使用队列

    创建完队列后,就可以通过SAE std lib通过函数调用TaskQueue 了,如:

    $queue = new SaeTaskQueue('test');//此处的test队列需要在在线管理平台事先建好

    //添加单个任务

    $queue->addTask("http://freedemo.sinaapp.com/yourtask1.php");

    $queue->addTask("http://freedemo.sinaapp.com/yourtask2.php", "postdata", true);

 

    //批量添加任务

    $array = array();
    $array[] = array('url'=>"http://freedemo.sinaapp.com/yourtask1.php", "postdata"=>"act=test");
    $array[] = array('url'=>"http://freedemo.sinaapp.com/yourtask2.php", "postdata"=>"act=test", "prior"=>true);

    $queue->addTask($array);

 

    //将任务推入队列

    $ret = $queue->push();

    var_dump($ret);

 

 

服务限制与配额

    SAE设置服务限制和配额的目的是为了防止个别用户攻击和滥用,从而在公有云计算平台上保证绝大多数开发者的正常使用。

    1. 服务限制和配额设定是在门户网站新浪自身长期运维的基础上经过严格计算得出的,所以正常使用一般不会出现问题。经过SAE实际统计,99%的应用不会受到任何影响

    2. 当您发现您的某项服务超过限制或者超配时,请先阅读相关文档确认限制和配额的具体数值,再检查自己的程序是否存在使用不当的情况,如果仍然解决不了,可以和SAE官方联系,saeadmin@sina.cn

 服务限制

单任务超时限制 300秒
单用户创建的最大队列数 10

注意:由于TaskQueue 服务是回调HTTP服务,所以会受到Runtime内核的限制 。

 分钟配额

服务 请求数 cpu时间 流入带宽 流出带宽
TaskQueue 20,000=>40,000 60s=>100s 10MB=>20M 10MB=>20M


推荐阅读
  • 本文详细介绍了在不同操作系统中查找和设置网卡的方法,涵盖了Windows系统的具体步骤,并提供了关于网卡位置、无线网络设置及常见问题的解答。 ... [详细]
  • 本文探讨了在构建应用程序时,如何对不同类型的数据进行结构化设计。主要分为三类:全局配置、用户个人设置和用户关系链。每种类型的数据都有其独特的用途和应用场景,合理规划这些数据结构有助于提升用户体验和系统的可维护性。 ... [详细]
  • 历经三十年的开发,Mathematica 已成为技术计算领域的标杆,为全球的技术创新者、教育工作者、学生及其他用户提供了一个领先的计算平台。最新版本 Mathematica 12.3.1 增加了多项核心语言、数学计算、可视化和图形处理的新功能。 ... [详细]
  • Linux中的yum安装软件
    yum俗称大黄狗作用:解决安装软件包的依赖关系当安装依赖关系的软件包时,会将依赖的软件包一起安装。本地yum:需要yum源,光驱挂载。yum源:(刚开始查看yum源中的内容就是上图 ... [详细]
  • 本文探讨了如何解决PHP文件无法写入本地文件的问题,并解释了PHP文件中HTML代码无效的原因,提供了一系列实用的解决方案和最佳实践。 ... [详细]
  • 鼠标悬停出现提示信息怎么做
    概述–提示:指启示,提起注意或给予提醒和解释。在excel中会经常用到给某个格子增加提醒信息,比如金额提示输入数值或最大长度值等等。设置方式也有多种,简单的,仅为单元格插入批注就可 ... [详细]
  • 精致小屏灰色风格苹果CMS v10模板,支持DIY主题管理系统
    探索一款专为影视站设计的苹果CMS v10模板,具备强大的主题管理系统和500多个设置项,无需二次开发即可轻松配置。下载地址:https://www.mytheme.cn/maccms/244.html,演示地址:http://demo.mytheme.cn/index.php?id=244。 ... [详细]
  • 本文详细探讨了如何通过分析单个或多个线程在瓶颈情况下的表现,来了解处理器资源的消耗。无论是单进程还是多进程环境,监控关键指标如线程数量、占用时间及调度优先级等,有助于揭示潜在的性能问题。 ... [详细]
  • 使用Powershell Studio快速构建GUI应用程序
    本文介绍了如何利用Powershell Studio创建功能强大的可视化界面。相较于传统的开发工具,Powershell Studio提供了更为简便和高效的开发体验,尤其适合需要快速构建图形用户界面(GUI)的场景。 ... [详细]
  • 本文详细介绍了PHP中的多条件分支结构,包括if、elseif和else语句的使用方法。通过具体示例,解释了如何根据不同的条件执行相应的代码块,并确保每个条件只能触发一次。 ... [详细]
  • 气象对比分析
    本文探讨了不同地区和时间段的天气模式,通过详细的图表和数据分析,揭示了气候变化的趋势及其对环境和社会的影响。 ... [详细]
  • 使用PHP实现网站访客计数器的完整指南
    本文详细介绍了如何利用PHP构建一个简易的网站访客统计系统。通过具体的代码示例和详细的解释,帮助开发者理解和实现这一功能,适用于初学者和有一定经验的开发人员。 ... [详细]
  • 本文详细介绍了在 Windows 7 系统中配置 Nginx 1.10.3 和 PHP 7.1.1 NTS 的步骤,包括修改 PHP 配置文件、处理依赖项以及创建批处理脚本启动和停止服务。重点解释了如何解决常见的运行时错误。 ... [详细]
  • 在PHP后端开发中遇到一个难题:通过第三方类文件发送短信功能返回的JSON字符串无法解析。本文将探讨可能的原因并提供解决方案。 ... [详细]
  • 本文探讨了现代分布式架构的多样性,包括高并发、多活数据中心、容器化、微服务、高可用性和弹性架构等,并介绍了与这些架构相关的重要管理技术,如DevOps、应用监控和自动化运维。文章还深入分析了分布式系统的核心概念、主要用途及类型,同时对比了单体应用与分布式服务化的优缺点。 ... [详细]
author-avatar
BeckyWang25_966
这个家伙很懒,什么也没留下!
PHP1.CN | 中国最专业的PHP中文社区 | DevBox开发工具箱 | json解析格式化 |PHP资讯 | PHP教程 | 数据库技术 | 服务器技术 | 前端开发技术 | PHP框架 | 开发工具 | 在线工具
Copyright © 1998 - 2020 PHP1.CN. All Rights Reserved | 京公网安备 11010802041100号 | 京ICP备19059560号-4 | PHP1.CN 第一PHP社区 版权所有