redis 订阅与发布
def PUBLISH(channel, message): # 遍历所有订阅频道 channel 的客户端for client in server.pubsub_channels:
# 将信息发送给它们
send_message(client, message)
# 取出所有模式,以及订阅模式的客户端
for pattern, client in server.pubsub_patterns:
# 如果 channel 和模式匹配
if match(channel, pattern):
# 那么也将信息发给订阅这个模式的客户端
send_message(client, message)
页:
[1]