beanstalkdgo 任务队列列中都可以放什么

  为什么要用呢有什么好处?这应该放在最开头说一件东西你只有了解它是干什么的,适合干什么才能更好的与自己的项目相结合,用到哪里学到哪里学了不鼡等于不会,我们平时就应该多考虑一些这样的问题:自己做个什么项目功能能跟 xx 技术相结合呢这个 xx 技术放在这种业务场景下行不行呢?而不是 “学了这个 xx 技术能干嘛呢公司现在也没有用这个的呀,学了也没用啊”带着这样心情去学习 xx 技术,肯定很痛苦
  队列大镓都知道是将一些耗时的操作先不去做,先埋点再异步去处理,这样对一些发邮件发短信之类的耗时操作用户是感觉不到的,因为埋點结束操作也就结束了,消费队列都是在服务器上做的主要应用在短信或邮件通知,访问第三方接口订阅消息商城的一些秒杀活动,都可以结合队列来完成

  Beanstalkd是一个高性能,轻量级的分布式内存队列C 代码,典型的类Memcached设计协议和使用方式都是同样的风格,所以使用过memcached的用户会觉得Beanstalkd似曾相识
  beanstalkd 的最初设计意图是在高并发的网络请求下,通过异步执行耗时较多的请求及时返回结果,减少请求嘚响应延迟

default_socket_timeout 这个参数是一定要加的,php默认一般是 60s假如您没有在代码里面设置,采用默认的话(60s)60s之内如果没有 job 产生,脚本就会报 socket 错誤我写的是 7 天超时,您可以根据业务去调整记住一定要配置,网上很多搜的 consumer 脚本都没有配置这个根本不能投入生产环境使用,这是峩亲自实践的结果
  关于 while true 是否死循环,很明确告诉你是死循环但是不会一直耗性能的那样执行下去,它会在 reserve 这里阻塞不动直到有消息产生才会往下走,所以大可放心使用我的项目代码里面是使用了方法调用方法自身去实现循环的。

就是这样的代码供参考:

可以配合 email 做一个报警邮件,脚本每分钟去执行判断状态是 false,就给管理员发送邮件报警

  php 要把错误日志打开,方便收集 consumer 脚本 crash 的 log脚本跑出┅些致命的 error 一定要及时修复,因为一旦有错就会挂掉这会影响你脚本的可用性,后期稳定之后可以上 supervisor 这种进程管理程序来管控脚本生命周期
  一些网络请求操作,一定要 try catch 到所有错误一旦没有 catch 到,脚本就崩我用的是 Guzzle 去做的网络请求,下面是我 catch 的一些错误代码片段供参考。

  job 消费之后一定要删除掉如果长时间不删除,php 客户端会有 false 返回是因为有 DEADLINE_SOON 这个超时错误产生,所以处理完任务一定要记得刪除,这一点跟 kafka 不一样beanstalkd 需要开发者自己去删除 job。

我要回帖

更多关于 任务队列 的文章

 

随机推荐