Redis在社交网络系统中的作用及应用

import redis

# 连接Redis数据库
r = redis.Redis(host='localhost', port=6379)

# 查询用户数据
def get_user_data(user_id):
    # 先尝试从缓存中获取数据
    data = r.get('user_data:' + user_id)
    if data:
        return data.decode()
    else:
        # 从数据库中查询数据
        data = db.get_user_data_from_db(user_id)
        # 将数据存入缓存并设置过期时间
        r.setex('user_data:' + user_id, 600, data)
        return data

import redis

# 连接Redis数据库
r = redis.Redis(host='localhost', port=6379)

def publish_new_dynamic(user_id, dynamic):
    # 将动态发布到指定频道
    r.publish('new_dynamic', user_id + '|' + dynamic)

import redis

# 连接Redis数据库
r = redis.Redis(host='localhost', port=6379)

def increase_follower_count(user_id):
    # 将用户的粉丝数加1
    r.incr('follower_count:' + user_id)

def get_follower_count(user_id):
    # 获取用户的粉丝数
    return r.get('follower_count:' + user_id)

import redis

# 连接Redis数据库
r = redis.Redis(host='localhost', port=6379)

def add_to_ranking(user_id, score):
    # 将用户添加到排行榜并设置分值
    r.zadd('ranking', {user_id: score})

def get_top_users(num):
    # 获取排名前num的用户
    return r.zrange('ranking', 0, num-1, desc=True)