Redis的基本使用(二) 消息队列
发布网友
发布时间：2022-12-24 18:10
共1个回答
热心网友
时间：2023-10-09 18:25
Redis 的消息队列不是特别专业，他没有很多高级特性，适用简单的场景，如果对于消息可靠性有着极高的追求，那么不适合使用 Redis 做消息队列。
Redis 做消息队列，使用它里边的 List 数据结构就可以实现，使用 lpush/rpush 操作来实现入队，然后使用 lpop/rpop 来实现出队。
在客户端（例如 Java 端），我们会维护一个死循环来不停的从队列中读取消息，并处理，如果队列中有消息，则直
接获取到，如果没有消息，就会陷入死循环，直到下一次有消息进入，这种死循环会造成大量的资源浪费，这个时候，
可以使用之前讲的 blpop/brpop 。
blpop 阻塞式的弹出，相当于 lpop 的阻塞版。
延迟队列可以通过 zset 来实现，因为 zset 中有一个 score，我们可以把时间作为 score，将 value 存到redis 中，然后通过轮询的方式，去不断的读取消息出来。
首先，如果消息是一个字符串，直接发送即可，如果是一个对象，则需要对对象进行序列化，这里我们
使用 JSON 来实现序列化和反序列化。
首先在项目中，添加 JSON 依赖：
接下来，构造一个消息对象：
接下来封装一个消息队列：
测试：
