简单的Redis消息队列实现模型

1.目录结构

简单的Redis消息队列实现模型

2.消息生产者(生产消息将消息写入队列)

简单的Redis消息队列实现模型

3.构建公共类:封装RedisMQ方法

创建redis客户端对象

消息入队:将消息插入队列使用LPush,消息存储以list类型进行存储

消息出队(阻塞):相当于redis将数据推送至方法使用BlockingPopItemFormList

消息出队非阻塞:相当于方法从redis中拉数据RPop 

获取队列数量:getListCount

IDisposable用于释放非托管资源redisClient.Dispose

简单的Redis消息队列实现模型

简单的Redis消息队列实现模型

4.消费者

将生产者存储的数据进行消费,消费完成后会将redis数据进行删除

简单的Redis消息队列实现模型