码迷,mamicode.com
首页 > 其他好文 > 详细

关于耗时操作的处理方式猜想/我所用到的队列操作

时间:2016-05-16 08:12:44      阅读:221      评论:0      收藏:0      [点我收藏+]

标签:

  引语:在许多的web应用中,我们都是通过同步操作的方式去处理我们的任务,但是往往也有这样的业务诉求,即一个操作可能比较耗时,或者有许多的不确定性(如支付操作需要等待第三方结果通知)。在这种业务场景下,再使用同步的方式去操作,可能就不太合理了。那我们想到的是,使用同步先返回临时结果,再通过异步通知最终结果的方式,进行处理,这是必须的。

  那么对于这种场景,怎么处理呢?

  对于有自己处理异步操作能力的语言(如java),那么对于这种情况,只需要抛一个线程到代码里,指定一个回调处理即可。

  对于没有自行处理异步操作的语言(如php),相对来说就麻烦一点,一般需要借助于后台一些一直运行的进程,它会一直去检测是否有需要处理的事情,如果有,根据需求,依次去操作。像这种操作,我们可以称之为,消息处理。那么,当遇到耗时操作的时候,我们就需要立即将消息存放到消息队列中,以便后台进程能读取到该消息!

  市面上有很多现成的消息队列的软件如:rabbitmq,kafka等,如果真有需求,可以选择其中一个进行使用,本文只为解释一些基本原理及个人实践。

  因为我用的是php语言,所以,也只能就php的这种特性来表达一下自己的处理方式。对于有自己处理能力的语言,他们可以自行处理各种并发问题,但是对于需要cron脚本辅助的语言,则需要更多的操作!

  1. 怎样将消息存入队列?

  既然操作很耗时,那我们可以想一下不耗时的操作,先处理了,然后将后续工作交给服务器,那么我们怎样存储这些要操作的事项呢?方法应该是很多的,比如存储至文件,存储到数据库,存储到缓存。当然了,最好的方式当然是存储到缓存,借助于redis或者memcache这样的缓存工具,可以轻松的实现push和pop操作。但是消息可能就只是一些字符串,怎样表达清楚需要做的事呢?这个,方式当然也很多了,自己定义好消息的结构,如:{msgType: aa, params: [{p1:2, p2:3}], addTime:2016-05-15 10:30:03, from:[{ip:1.1.1.1, who:lee}]}, 然后将消息序列化或者json化,存储起来即可!

  2. 怎样处理消息?

  消息存入队列后,怎样去处理呢?一般有两种:1. 写一个死循环,一直去检测消息内容,检测到后,根据消息类型,就立即做相应处理。2. 使用cron脚本的方式,定期去检测消息,有就处理,没有就退出!其实还有第三种,使用cron定期执行脚本,但是一次执行就需要处理完所有的消息,再进行返回,提高效率!(每处理完一条消息,就必须将该消息删除或者存放到其他地方)

  3. 怎样避免并发执行?

  消息应该是只能一次执行的,如果被多次执行,则已超出预期结果,所以,一定要注意多进程同时执行一条消息情况,主要有两种方式,1. 程序中自己创建文件锁,执行前先检测是否存在该锁,没有则创建,执行完后删除,但是这种情况一定要注意程序意外终止的情况(如果意外终止,锁将一直存在,后续将永远无法执行)。2. 让cron生成锁,控制该文件只被一个进程同时执行;

  4. 注意事项?

  如果消息只是存储于缓存中,执行完成之后,就将其删除,那么,对于排查及恢复来说,都是致命的,所以,一般需要在删除之前,先将其存储到一个备份的位置或者以日志的方式将消息保存下来!

 

  简单来说,消息队列就是一个消息推入,一个消息执行的过程。其他的,只是为了保障执行过程中的各种意外,各种恢复,各种去重操作罢了!(好像也找不到其他话说了我,哈哈哈...)

关于耗时操作的处理方式猜想/我所用到的队列操作

标签:

原文地址:http://www.cnblogs.com/yougewe/p/5496142.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!