- .net core版本:2.1
- redis版本:3.0以上
1.很方便的使用redis消息队列,开箱即用
2.可以设置消费消息的频次
分布式环境,redis消息队列
- 1.获取initQ包 install-package InitQ
- 2.添加中间件
services.AddInitQ(m=> { m.SuspendTime = 1000; m.ConnectionString = "47.104.247.70,password=admin"; m.ListSubscribe =new List<IRedisSubscribe>() { new RedisSubscribe(),new RedisSubscribe2() }; m.ShowLog = false; }); - 3.定义消费者类
public class RedisSubscribe : IRedisSubscribe { [Subscribe("bbb")] private async Task SubRedisOrderMessage(string order) { Console.WriteLine($"队列bbb消费消息:{order}"); } }
- V1.0 更新时间:2019-12-30