热门标签 | 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


推荐阅读
  • 本文详细介绍了Git分布式版本控制系统中远程仓库的概念和操作方法。通过具体案例,帮助读者更好地理解和掌握如何高效管理代码库。 ... [详细]
  • 网络运维工程师负责确保企业IT基础设施的稳定运行,保障业务连续性和数据安全。他们需要具备多种技能,包括搭建和维护网络环境、监控系统性能、处理突发事件等。本文将探讨网络运维工程师的职业前景及其平均薪酬水平。 ... [详细]
  • 极大似然估计(MLE)及其3D可视化解析
    本文详细介绍了极大似然估计(Maximum Likelihood Estimation, MLE)的推导过程,并通过3D可视化展示其在概率密度函数中的应用。我们将探讨如何利用MLE来估计参数,以及它在实际问题中的重要性。 ... [详细]
  • 2023 ARM嵌入式系统全国技术巡讲旨在分享ARM公司在半导体知识产权(IP)领域的最新进展。作为全球领先的IP提供商,ARM在嵌入式处理器市场占据主导地位,其产品广泛应用于90%以上的嵌入式设备中。此次巡讲将邀请来自ARM、飞思卡尔以及华清远见教育集团的行业专家,共同探讨当前嵌入式系统的前沿技术和应用。 ... [详细]
  • 本文介绍如何解决在 IIS 环境下 PHP 页面无法找到的问题。主要步骤包括配置 Internet 信息服务管理器中的 ISAPI 扩展和 Active Server Pages 设置,确保 PHP 脚本能够正常运行。 ... [详细]
  • Python 异步编程:深入理解 asyncio 库(上)
    本文介绍了 Python 3.4 版本引入的标准库 asyncio,该库为异步 IO 提供了强大的支持。我们将探讨为什么需要 asyncio,以及它如何简化并发编程的复杂性,并详细介绍其核心概念和使用方法。 ... [详细]
  • 探讨一个老旧 PHP MySQL 系统中,时间戳字段不定期出现异常值的问题及其可能原因。 ... [详细]
  • 国内BI工具迎战国际巨头Tableau,稳步崛起
    尽管商业智能(BI)工具在中国的普及程度尚不及国际市场,但近年来,随着本土企业的持续创新和市场推广,国内主流BI工具正逐渐崭露头角。面对国际品牌如Tableau的强大竞争,国内BI工具通过不断优化产品和技术,赢得了越来越多用户的认可。 ... [详细]
  • 优化ListView性能
    本文深入探讨了如何通过多种技术手段优化ListView的性能,包括视图复用、ViewHolder模式、分批加载数据、图片优化及内存管理等。这些方法能够显著提升应用的响应速度和用户体验。 ... [详细]
  • 郑州大学在211高校中的地位与排名解析
    本文将详细解读郑州大学作为一所位于河南省的211和双一流B类高校,在全国211高校中的地位与排名,帮助高三学生更好地了解这所知名学府的实力与发展前景。 ... [详细]
  • 深入理解 Oracle 存储函数:计算员工年收入
    本文介绍如何使用 Oracle 存储函数查询特定员工的年收入。我们将详细解释存储函数的创建过程,并提供完整的代码示例。 ... [详细]
  • 优化ASM字节码操作:简化类转换与移除冗余指令
    本文探讨如何利用ASM框架进行字节码操作,以优化现有类的转换过程,简化复杂的转换逻辑,并移除不必要的加0操作。通过这些技术手段,可以显著提升代码性能和可维护性。 ... [详细]
  • 本文总结了2018年的关键成就,包括职业变动、购车、考取驾照等重要事件,并分享了读书、工作、家庭和朋友方面的感悟。同时,展望2019年,制定了健康、软实力提升和技术学习的具体目标。 ... [详细]
  • 电子元件封装库:三极管、MOS管及部分LDO(含3D模型)
    本资源汇集了常用的插件和贴片三极管、MOS管以及部分LDO的封装,涵盖TO和SOT系列。所有封装均配有高质量的3D模型,共计96种,满足日常设计需求。 ... [详细]
  • 深入解析Spring Cloud Ribbon负载均衡机制
    本文详细介绍了Spring Cloud中的Ribbon组件如何实现服务调用的负载均衡。通过分析其工作原理、源码结构及配置方式,帮助读者理解Ribbon在分布式系统中的重要作用。 ... [详细]
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社区 版权所有