最近一个外部的项目，使用到了消息队列，本来是用rabbitmq实现的，但是由于是部署到别人家的服务器上，想尽量简化一些，项目中本来也要接入了redis缓存，就尝试使用redis来实现简单的消息队列。使用redis做消息队列有两种方法，一种是使用pub/sub，另一种是使用list结构，配合brpop来消费。这两种方式各有特点，这里简述一下：。首先需要在appsettings.json中添加redis的连接字符串：具体配置请参考github上的文档：然后在startup.cs的ConfigureServices中配置redis:当然也可以采用依赖注入的方式添加CSRedisClient实例，这个不纠结。在项目中有好几处使用到了队列，所以先封装一个消费服务：然后就可以继承RedisMQConsumer，编写实际逻辑：发布消息只是往队列中添加项：最后把消费服务添加到startup.cs中：经测试，还算稳定，小并发项目可以使用。
暂无评论