统一消息系统

小明：最近我在设计一个消息系统，想加入排行榜功能，有什么建议吗？

小李：你可以考虑使用消息队列来处理实时数据，然后用缓存或数据库维护排名。

小明：那具体怎么实现呢？有没有例子？

小李：比如用Redis的Sorted Set来存储用户分数，每次有新消息进来时更新分数，再通过消息系统通知前端刷新排行榜。

小明：听起来不错，能给我看看代码吗？

小李：当然可以。下面是一个简单的Python示例，使用Redis和消息队列（如RabbitMQ）来实现：

import redis
import pika

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

# RabbitMQ连接
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()
channel.queue_declare(queue='score_update')

def update_score(user_id, score):
    r.zadd('leaderboard', {user_id: score})
    channel.basic_publish(exchange='', routing_key='score_update', body=str(user_id))

# 示例：更新用户分数
update_score('user123', 100)

    

小明：这个代码很清晰！那前端怎么获取最新的排行榜呢？

小李：前端可以监听消息队列中的变化，或者定期从Redis中拉取排行榜数据。

小明：明白了，这样就能实现实时更新的排行榜了。

小李：没错，这就是统一消息系统与排行榜结合的优势所在。