简单的Redis消息队列实现模型
1.目录结构
2.消息生产者(生产消息将消息写入队列)
3.构建公共类:封装RedisMQ方法
创建redis客户端对象
消息入队:将消息插入队列使用LPush,消息存储以list类型进行存储
消息出队(阻塞):相当于redis将数据推送至方法使用BlockingPopItemFormList
消息出队非阻塞:相当于方法从redis中拉数据RPop
获取队列数量:getListCount
IDisposable用于释放非托管资源redisClient.Dispose
4.消费者
将生产者存储的数据进行消费,消费完成后会将redis数据进行删除