(转)开源的任务队列服务HTQ

注：本文为转载，原文请查看star7th的我的博客。

1、什么是 HTQ

先介绍下基本概念。

咱们在编写程序时，偶尔会遇到须要用到异步队列的状况。好比说，我发送一万封邮件，若是单纯使用一个for循环来发送，则执行时间要很长，要等好久才能发完，同时很容易致使阻塞、超时等问题。当邮件更多，好比一百万封的时候，问题会更加明显。这时最好的解决方案就是把这十万封邮件排队，一一发出去。这就是任务队列的概念。

而且，咱们并不须要等到十万封邮件都发送完毕后才在网站前台通知用户。咱们能够把邮件一入队列，就通知用户。这样，用户等待的时间就不是漫长的“发十万封邮件”的时间，而是“把十万封邮件排队”的时间。所以能明显地缩短了用户等待时间。这就是异步的概念。

HTQ ，全称 Http Task Queue ，是一个以Http方式执行异步任务的队列服务。你能够推送若干url进HTQ队列,HTQ会以Http GET 的方式访问这些url。若是url所在的脚本写上各类具体的任务操做，如发送邮件等，即可以实现异步操做了。HTQ使用node.js编写，可跟各类后台语言如PHP、java配合使用以加强异步处理能力。目前支持的队列类型有实时异步队列、定时异步队列、可变异步队列。

若是你依然对HTQ陌生，则可往下看详细的应用场景以加深了解。

2、应用场景

一、实时异步队列

所谓实时，指的是把任务一推动队列就立刻执行。一个典型的应用场景就是咱们上面所说的发送邮件。邮件推送进任务队列，队列立刻把它发出去。若是它推动队列后有其余邮件正在发送中，它则等待当前邮件发送完毕后才发送。

除了发邮件，咱们在发文章、发微博、发评论的时候均可以用得上HTQ的实时任务队列，尤为是数量很是大的时候。好比评论用户太多，若是一瞬间让服务器处理，服务器可能由于支撑不了过高的并发从而形成阻塞。这个时候就可让评论们进入队列再一一处理。

二、定时异步队列

定时，顾名思义，就是在特定的时间执行任务队列。这种队列服务可用于定时邮件、定时短信。须要说明的是，这里的定时，不必定是精准的定时。假如你设置了明天12点执行某个任务，那么，它在明天12点的时候将进入队列。假如队列中已经有任务在执行，那么它会等待到前面的任务完毕才执行。此时多是12点01分钟才执行。

三、可变队列

咱们推送10个任务进队列，这10个队列会反复循环地执行，而且它们的执行快慢可以根据返回状况进行调整，这就是可变队列。好比，咱们作扫描监控，会反复地执行“扫描”这个任务。咱们但愿，在有异常状况的时候，能加快扫描的速度以便更快速地发现问题；而在没有长期异常的状况能减慢一下扫描速度以节省机器资源。

再举一个场景例子，经过API拉取微博新动态。咱们网站上有10万绑定了新浪微博的用户，咱们须要时常获取他们的最新动态以展现在咱们的网站的用户主页上。 若是是采用定时获取动态的方式，那么，假设1分钟能获取1千个用户的动态（由于受API使用频率和网络等缘由限制，咱们获取不了太快。这里先假设一个数字），那么，获取完全部用户状态须要100分钟。对用户来讲，他在微博更新动态后，100分钟后才显示到咱们网站。这明显滞后太多。有没有办法加快点呢？此时可使用HTQ的可变队列。可变队列会对长期没有更新动态的那部分不活跃用户进行减缓速度，减缓对他们微博的获取频率，同时加大对活跃用户的获取频率。这样，一个活跃用户更新微博后，可能10分钟就能同步到咱们网站了。对于不活跃用户，可能获取时间会变长了些，但没关系，咱们愿意分配更多的资源去知足活跃用户的需求。

使用可变队列，能让咱们有所侧重地使用咱们的资源，以减小浪费、增长利用率。

3、安装和使用

安装和使用 请点击该连接

相关文章：
本身实现异步执行任务的队列（一）
本身实现异步执行任务的队列（二）