消息管理中心在师范大学中的应用与实现

import redis

# 连接Redis

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

# 发布消息

def publish_message(channel, message):

r.publish(channel, message)

print(f"消息已发送到 {channel}: {message}")

# 示例调用

publish_message('notifications', '新课程已上线！')

import redis

# 连接Redis

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

# 订阅消息

def subscribe_messages(channel):

pubsub = r.pubsub()

pubsub.subscribe(channel)

for message in pubsub.listen():

if message['type'] == 'message':

print(f"收到消息: {message['data'].decode('utf-8')}")

# 示例调用

subscribe_messages('notifications')