操作Redis监听支持多次操作（redis监听执行多次）

Redis是一种高性能key-value存储系统，它支持多种数据结构，例如字符串、哈希表、列表、集合和有序集合。Redis也支持监听（pub / sub）模式，这使得我们可以订阅某个特定的消息，以便在消息到达时执行相应的操作。但是，在实际应用中，有时我们需要在监听某个消息的同时，支持多次操作。本篇文章将介绍如何实现这样的功能。

我们需要使用Redis中的listen方法来订阅消息。该方法可以接收一个回调函数，当消息到达时，该回调函数将被调用。例如，以下代码监听了“test”消息：

“`python

import redis

r = redis.StrictRedis(host=’localhost’, port=6379, db=0)

def callback(message):

print(message[‘data’])

p = r.pubsub()

p.subscribe(**{‘test’: callback})

在上述代码中，callback回调函数将在每次接收到“test”消息时被调用。

接下来，我们需要考虑如何在监听某个消息的同时支持多次操作。对于这个问题，我们可以使用Python的协程库asyncio来处理。asyncio是一种用于编写异步代码的库，它遵循事件循环模型，支持基于协程的非阻塞代码，使得在I / O密集型任务中能够实现高效的并发。

以下是如何使用asyncio库实现多次操作的代码：

```python
import asyncio
import redis

r = redis.StrictRedis(host='localhost', port=6379, db=0)

async def operation_1():
    awt asyncio.sleep(1)
    print('Performing operation 1')

async def operation_2():
    awt asyncio.sleep(2)
    print('Performing operation 2')

async def callback(message):
    print(message['data'])
    awt asyncio.gather(operation_1(), operation_2())

async def mn():
    p = r.pubsub()
    awt p.subscribe(**{'test': callback})
    awt p.run_in_thread(sleep_time=0.001)
asyncio.run(mn())

在上述代码中，我们定义了两个异步方法operation_1和operation_2，它们分别需要1和2秒钟的时间来完成一些操作。在callback函数中，我们使用asyncio.gather方法来同时执行这两种操作，而不会阻塞主线程。我们使用asyncio库的run方法来运行整个事件循环。

通过这种方式，我们可以在监听Redis消息的同时，支持多个操作，并使它们异步执行，从而获得更好的性能和可扩展性。