Redis应用3 异步操作基于Redis消息队列实现

Redis实现消息队列的模式

当前广泛采用的消息队列系统包括RabbitMQ、ActiveMQ以及Kafka等，这些均为开源且具备强大功能的消息处理工具，特别适用于企业级项目的实际部署与运行。

Redis实现的消息队列代码原理

Redis支持两种消息队列的实现方式。
一种是采用生产者-消费者模式，
另一种则是发布-订阅模式。
在前者中，一个或多个客户端会对消息队列进行监听，当有消息到达时，消费者会立即进行处理，遵循先到先得的原则；若队列中无消息，则消费者将继续保持监听状态。
而在后者中，一个或多个客户端会订阅特定的消息频道，每当发布者向频道发送消息时，所有订阅该频道的客户端都会接收到相应信息，订阅者之间处于平等地位。

本文所采用的是生产者-消费者模式。

基于Redis的消息队列实现的异步操作原理图如下：

事件生成器负责将各类事件信息传输至消息队列系统，事件消费端则持续对队列进行监控。一旦检测到新事件的抵达，即刻从队列中提取该事件，并将其传递至相应的处理模块完成后续操作。

代码实现

**1.