消息队列 gmq

gmq是基于redis提供的特性,使用go语言开发的一个简单易用的队列;支持延迟任务,异步任务,超时任务,优先级任务

应用场景

• 延迟任务
  • 延迟任务,例如用户下订单一直处于未支付状态，半个小时候自动关闭订单
• 异步任务
  • 异步任务,一般用于耗时操作,例如群发邮件等批量操作
• 超时任务
  • 规定时间内(TTR)没有执行完毕或程序被意外中断,则消息重新回到队列再次被消费,一般用于数据比较敏感,不容丢失的
• 优先级任务
  • 当多个任务同时产生时,按照任务设定等级优先被消费,例如a,b两种类型的job,优秀消费a,然后再消费b

gmq流程

web监控

gmq提供了一个简单web监控平台(后期会提供根据job.Id追踪消息的功能),方便查看当前堆积任务数,默认监听端口为8000,例如:http://127.0.0.1:8000, 界面如下: