1、电商支付系统中,用户下单后N分钟不支付,自动取消订单。
2、用户浏览商品长时间后还没下单,后续推送相关产品和优惠券。
3、用户注册或修改生日后:生日短信推送等。
4、7天后的自动确认收货等。。。
......
rabbitmq-plugins enable rabbitmq_delayed_message_exchange
using (var channel = Rabbit.Instance.DefaultConnection.CreateModel())
{
//定义队列
channel.QueueDeclare("dead");
//定义延时路由
IDictionary<string, object> dic = new Dictionary<string, object>();
dic.Add("x-delayed-type", "direct");
channel.ExchangeDeclare("ex-dead", "x-delayed-message", arguments: dic);
channel.QueueBind("dead", "ex-dead", "dead");
var p1 = channel.CreateBasicProperties();
IDictionary<string, object> header = new Dictionary<string, object>();
header.Add("x-delay", 6000);
p1.Headers = header;
var p2 = channel.CreateBasicProperties();
IDictionary<string, object> header2 = new Dictionary<string, object>();
header2.Add("x-delay", 16000);
p2.Headers = header2;
channel.BasicPublish("ex-dead", "dead", false, p1, Encoding.UTF8.GetBytes("6秒就过期了1。"));
channel.BasicPublish("ex-dead", "dead", false, p2, Encoding.UTF8.GetBytes("16秒就过期了2。"));
}
如果说,列信队列的适合场景,是短时间的固定间隔时间。
那么说,延时队列插件的适合场景,就是更进一步的短时间内的随机时间。