Redis进阶——redis消息队列

Redis作为一种基于内存的数据结构存储，可以用作消息队列。以下是一个使用Redis作为消息队列的Python示例：

import redis
 
# 连接到Redis
redis_host = 'localhost'
redis_port = 6379
r = redis.StrictRedis(host=redis_host, port=redis_port, decode_responses=True)
 
# 生产者将消息放入队列
def produce(queue_name, message):
    r.rpush(queue_name, message)
 
# 消费者从队列取出消息
def consume(queue_name):
    while True:
        # 使用brpop进行阻塞等待，直到有消息可消费
        message = r.brpop(queue_name, timeout=5)
        if message:
            # 处理消息
            print(f"Consumed: {message[1]}")
 
# 使用示例
queue_name = 'my_queue'
produce(queue_name, 'Hello, Redis!')
consume(queue_name)

在这个例子中，我们使用了rpush来生产消息到队列（右侧推入列表），并使用brpop来消费消息（左侧阻塞弹出）。这里的队列名为my_queue。消费者会阻塞等待新消息的到来，如果在指定的timeout时间内没有消息，将继续等待。