当请求某api时,后台发送邮件至网站所有用户。
当用户请求该api,后台接收到之后,使用sendgrid 的api 发送给数组中的每个email.
接收到此参数,首先向数据库users表请求所有user数据,然后将这些users的email push到一个数组中,然后遍历此数组,通过发送邮件api进行发送。
当用户数据很小的时候,这个方法看似还可以满足需求,但是设想,如果用户量很大很大,有没有更好的方法?
比如批处理这些数据,或者。。?
现在我想的解决方案是,将任务以队列形式交给后台执行,然后通过事件监听来记录每个条目执行成功与否,成功后消除。打算这么做,成功后贴上解决方案
最终解决方案是使用node-resque,让worker去执行,每批发送比如100个,sendgrid有相应的API用来记录发送的详细信息,比如invalid emails或者是blocked emails. 所以我通过sendgrid的api用来跟踪错误信息,非常方便!
sendgrid API
sendgrid这里我又有了一个unicode问题,希望热心的网友看看这里
定长集合(capped collection)加tailable,await_data可以在mongoDB方便实现队列.
放到队列里面
你肯定得使用ActiveMQ或者Beanstalk这些队列服务,定量的把请求放到队列中去,比如一次发20个,200个看你的服务器情况来定。
把API的请求记录为一次任务, 任务需要签名,可以撤销,可以合并;
后台再有一个进程定时执行这些任务。