如何使用Redis做异步队列?

1.使用List作为队列,RPUSH生产消息,LPOP消费消息

缺点:没有等待队列里有值就直接消费

弥补:可以通过在应用层引入Sleep机制去调用LPOP重试

如果没有消息的时候,可以使用BLPOP去等待,直到队列里有消息

JAVA面试准备之Redis 如何使用Redis做异步队列

以上的生产者消费者模式的缺点在于只能供一个消费者消费,消费完了就没了。想要实现生产一次,让多个消费者消费。

 

2.使用redis的pub/sub主题订阅者模式,实现一对多的消费队列。

发送者(pub)发送消息,订阅者(sub)接收消息。

订阅者可以订阅任意数量的频道。

缺点:消息的发布是无状态的,无法保证可达。对发布者来说,消息即发即失,如果某个消费者在生产者发布消息的时候下线,重新上线后接收不到该消息。

 

主题订阅者模式:

JAVA面试准备之Redis 如何使用Redis做异步队列

Publisher发布消息,通过Topic发送给订阅该消息的三个客户端。

 

实践:

List

JAVA面试准备之Redis 如何使用Redis做异步队列

BLPOP:

两个客户端模拟生产者和消费者

等待30s

JAVA面试准备之Redis 如何使用Redis做异步队列

 

pub/sub:

订阅频道

JAVA面试准备之Redis 如何使用Redis做异步队列

发布消息:往不同频道发送消息,监听不同频道的 sub接收到不同的消息

JAVA面试准备之Redis 如何使用Redis做异步队列

相关文章:

  • 2021-07-04
  • 2021-07-12
  • 2021-11-12
  • 2022-12-23
  • 2021-05-30
  • 2021-12-03
  • 2022-12-23
  • 2022-12-23
猜你喜欢
  • 2021-06-24
  • 2022-12-23
  • 2021-11-10
  • 2021-09-22
  • 2021-11-15
  • 2021-06-19
  • 2021-05-16
相关资源
相似解决方案