使用Redis构建简易社交网站(2)-处理用户关系

news2025/1/11 6:01:50
目的

本文目的：实现用户关注和取消关注功能。（完整代码附在文章末尾）

相关知识

在我之前的文章 《使用Redis构建简易社交网站(1)-创建用户与动态界面》中提到了如何实现简易社交网站中创建新用户和创建新动态功能。

那这篇文章将教会你掌握：1.redis基本命令，2.python基本命令。

redis基本命令

zscore：返回有序集合中指定成员的分值。

conn = redis.Redis()
conn.zscore("testzset", "member1")
conn.zscore("testzset", "not_exists_member")

testzset内容如下：

执行结果：

100.0
None

zadd：将成员加入到有序集合中，并确保其在正确的位置上。

conn = redis.Redis()
conn.zadd("testzset", "member2", 3)
conn.zadd("testzset", "member1", 2)
conn.zadd("testzset", "member3", 1)

执行后：

member3
member1
member2

执行结果：1，1，1

hincrby：为哈希中指定域的值增加增量 increment，用于统计。

conn = redis.Redis()
conn.hincrby("testhash", "field1", 1)

执行前：

{'field1': '1'}

执行后：

{'field1': '2'}

zrem：从有序集合中移除指定成员。

conn = redis.Redis()
conn.zrem("testzset", "member1")

执行前：

member3
member1
member2

执行后：

member3
member2

执行结果：1

pipeline：将多条命令按照先后顺序放进一个队列中，一般配合execute一同使用，原子性(atomic)地执行队列里的命令。

conn = redis.Redis()
pipe = conn.pipeline(True) # 事务开始
pipe.incr("counter")
pipe.incr("counter")
pipe.incr("counter")
pipe.execute() # 事务执行

执行结果：[1, 2, 3]，通过下标即可获取对应命令的执行结果。

python基本命令

使用格式化拼接字符串：

"My name is %s, I'm %i years old"%('educoder', 2)

执行结果："My name is educoder, I'm 2 years old"

返回当前时间的时间戳。

  1. time.time()

将字符串转换为整型数据：

  1. int("1")

执行结果：1

取一个数的相反数：

  1. a = 1
  2. b = -a
  3. print b

执行结果：-1

实战例题

编写 follow(uid, other_uid) 函数，实现关注用户的功能，具体参数与要求如下：

  • 方法参数uid为当前用户编号，other_uid为被关注的用户编号；
  • 避免重复关注的实现：如果被关注的用户编号已经在当前用户的关注列表following:{uid}中，则不重复关注，直接返回None；
  • 建立关注关系的实现：使用事务一次性提交：
    • 将被关注的用户编号加入到当前用户的关注列表following:{uid}中，分值为当前时间戳。
    • 将当前用户编号加入到被关注用户的粉丝列表中followers:{other_uid}，分值为当前时间戳。
  • 修改统计数据的实现：若关系建立成功，则使用事务一次性提交：
    • 将当前用户详情user:{uid}中的关注数following加1
    • 将被关注用户详情user:{other_uid}中的粉丝数followers加1
  • 返回执行结果的实现：返回True

编写 unfollow(uid, other_uid) 函数，实现取消关注的功能，具体参数与要求如下：

  • 方法参数uid为当前用户编号，other_uid为被取消关注的用户编号；
  • 避免重复取消关注的实现：如果被关注的用户编号已经不在当前用户的关注列表following:{uid}中，则不重复取消关注，直接返回None；
  • 删除关注关系的实现：使用事务一次性提交：
    • 从当前用户的关注列表following:{uid}中移除被取消关注用户编号。
    • 从被取消关注用户的粉丝列表中followers:{other_uid}移除当前用户编号。
  • 修改统计数据的实现：若关系删除成功，则使用事务一次性提交：
    • 将当前用户详情user:{uid}中的关注数following减1
    • 将被取消关注用户详情user:{other_uid}中的粉丝数followers减1
  • 返回执行结果的实现：返回True

注意： 关注列表和粉丝列表均为有序集合，存储成员时，分值均为当前时间戳； 用户详情为上一关中创建的哈希结构。

测试输入：

  1. 9
  2. 4

预期输出：

测试 follow 方法...
用户 9 关注 用户 4
关注结果: True
用户 9 的关注列表内容为: ['4']
用户 4 的粉丝列表内容为: ['9']
用户 9 的用户详情为: {'login_name': 'test_user9', 'posts': '0', 'real_name': 'Test user9', 'followers': '0', 'following': '1', 'id': '9'}
用户 4 的用户详情为: {'login_name': 'test_user4', 'posts': '0', 'real_name': 'Test user4', 'followers': '1', 'following': '0', 'id': '4'}

用户 9 再次关注 用户 4
关注结果: None

测试 unfollow 方法...
用户 9 取消关注 用户 4
取消关注结果: True
用户 9 的关注列表内容为: []
用户 4 的粉丝列表内容为: []
用户 9 的用户详情为: {'login_name': 'test_user9', 'posts': '0', 'real_name': 'Test user9', 'followers': '0', 'following': '0', 'id': '9'}
用户 4 的用户详情为: {'login_name': 'test_user4', 'posts': '0', 'real_name': 'Test user4', 'followers': '0', 'following': '0', 'id': '4'}

用户 9 再次取消关注 用户 4
取消关注结果: None
 

 code.py

#code.py
#-*- coding:utf-8 -*-

import re
import time
import redis

conn = redis.Redis()

# 关注用户
def follow(uid, other_uid):
    # 请在下面完成要求的功能
    #********* Begin *********#
    fkey1 = "following:%s"%(uid)
    fkey2 = "followers:%s"%(other_uid)

    if conn.zscore(fkey1, other_uid):
        return None

    now = time.time()
    pipe = conn.pipeline(True)
    pipe.zadd(fkey1, other_uid, now)
    pipe.zadd(fkey2, uid, now)
    following, followers = pipe.execute()

    pipe.hincrby("user:%s"%(uid), 'following', int(following))
    pipe.hincrby("user:%s"%(other_uid), 'followers', int(followers))
    pipe.execute()

    return True
    #********* End *********#

# 取消关注
def unfollow(uid, other_uid):
    # 请在下面完成要求的功能
    #********* Begin *********#
    fkey1 = "following:%s"%(uid)
    fkey2 = "followers:%s"%(other_uid)

    if not conn.zscore(fkey1, other_uid):
        return None

    pipe = conn.pipeline(True)
    pipe.zrem(fkey1, other_uid)
    pipe.zrem(fkey2, uid)
    following, followers = pipe.execute()

    pipe.hincrby("user:%s"%(uid), 'following', -int(following))
    pipe.hincrby("user:%s"%(other_uid), 'followers', -int(followers))
    pipe.execute()

    return True
    #********* End *********#

# 创建新用户
def create_user(login_name, real_name):
    login_name = login_name.lower()
    if conn.hget("users", login_name):
        return None

    uid = conn.incr("user:id")
    pipe = conn.pipeline(True)
    pipe.hset("users", login_name, uid)
    pipe.hmset("user:%i"%(uid), {
        'login_name': login_name,
        'id': uid,
        'real_name': real_name,
        'followers': 0,
        'following': 0,
        'posts': 0,
        'last_signup': time.time(),
    })
    pipe.execute()

    return uid

# 为用户创建新动态
def create_post(uid, content):
    pipe = conn.pipeline(True)
    pipe.hget("user:%i"%(uid), 'login_name')
    pipe.incr("post:id")
    login_name, pid = pipe.execute()

    if not login_name:
        return None

    pipe.hmset("post:%i"%(pid), {
        'id': pid,
        'uid': uid,
        'content': content,
        'posted': time.time(),
        'user_name': login_name,
    })
    pipe.hincrby("user:%i"%(uid), 'posts')
    pipe.execute()

    return pid

read.py

#read.py
#-*- coding:utf-8 -*-

import os
import sys
import time
import redis
import pprint
from code import *

conn = redis.Redis()
retry_time = 0
while True:
    try:
        conn.ping()
        break
    except redis.exceptions.ConnectionError:
        os.system("redis-server > /dev/null 2>&1 &")
        retry_time += 1
        if retry_time > 3:
            break

pipe = conn.pipeline(True)
pipe.delete("users", "user:id")
keys = conn.keys("user:*") + conn.keys("followers:*") + conn.keys("following:*")
for key in keys:
    pipe.delete(key)
pipe.execute()

# 创建测试数据
join_str = " "
for i in xrange(10):
    login_name = "test_user%i"%(i+1)
    real_name = join_str.join(login_name.split("_")).capitalize()
    create_user(login_name, real_name)

uid = int(sys.stdin.readline().strip())
other_uid = int(sys.stdin.readline().strip())

print "测试 follow 方法..."
print "用户 %i 关注 用户 %i"%(uid, other_uid)
f_result = follow(uid, other_uid)
print "关注结果: " + str(f_result)
print "用户 %i 的关注列表内容为: %s"%(uid, str(conn.zrange("following:%i"%(uid), 0, -1)))
print "用户 %i 的粉丝列表内容为: %s"%(other_uid, str(conn.zrange("followers:%i"%(other_uid), 0, -1)))
uid_info = conn.hgetall("user:%i"%(uid))
uid_info.pop("last_signup", "404")
other_uid_info = conn.hgetall("user:%i"%(other_uid))
other_uid_info.pop("last_signup", "404")
print "用户 %i 的用户详情为: %s"%(uid, str(uid_info))
print "用户 %i 的用户详情为: %s"%(other_uid, str(other_uid_info))
print

print "用户 %i 再次关注 用户 %i"%(uid, other_uid)
oth_f_result = follow(uid, other_uid)
print "关注结果: " + str(oth_f_result)
print

print "测试 unfollow 方法..."
print "用户 %i 取消关注 用户 %i"%(uid, other_uid)
unf_result = unfollow(uid, other_uid)
print "取消关注结果: " + str(unf_result)
print "用户 %i 的关注列表内容为: %s"%(uid, str(conn.zrange("following:%i"%(uid), 0, -1)))
print "用户 %i 的粉丝列表内容为: %s"%(other_uid, str(conn.zrange("followers:%i"%(other_uid), 0, -1)))
uid_info = conn.hgetall("user:%i"%(uid))
uid_info.pop("last_signup", "404")
other_uid_info = conn.hgetall("user:%i"%(other_uid))
other_uid_info.pop("last_signup", "404")
print "用户 %i 的用户详情为: %s"%(uid, str(uid_info))
print "用户 %i 的用户详情为: %s"%(other_uid, str(other_uid_info))
print

print "用户 %i 再次取消关注 用户 %i"%(uid, other_uid)
oth_unf_result = unfollow(uid, other_uid)
print "取消关注结果: " + str(oth_unf_result)

pipe = conn.pipeline(True)
pipe.delete("users", "user:id")
keys = conn.keys("user:*") + conn.keys("followers:*") + conn.keys("following:*")
for key in keys:
    pipe.delete(key)
pipe.execute()

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/1282239.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

Java 使用Graphics生成海报图片（附效果图）

Java 使用Graphics生成海报图片（附效果图）

生成流程 1、创建画布 2、开启画图 3、画布上加载背景图片 4、画布上指定坐标绘制二维码（关于二维码实现的参考文后的链接） 5、将最终的图存放在本地 6、将图片url返回给前端 主要代码： PostMapping(value "/getPoster")public R…
阅读更多...
I/O口接口扩展----82C55

I/O口接口扩展----82C55

目录 一.扩展的I/O接口功能 二.端口的编址 1.独立编址 2.统一编制 三.I/O数据的传送方式 四.I/O接口电路----82C55 1.82C55的引脚及其内部结构 2.工作方式选择控制字及端口PC置位/复位控制字 3.82C55的三种工作方式 (1)方式0 (2)方式1 (3)方式2 4.AT89S52单片机与…
阅读更多...
麒麟V10安装kerberos客户端

麒麟V10安装kerberos客户端

麒麟V10系统安装kerberos客户端 当系统具备yum镜像源的时候需要执行安装命令 yum install krb5-devel krb5-client krb5-libs -y 会提示报错 “未找到匹配的参数:krb5-client” 此时我们需要手动安装krb5-client 安装包链接放到了这里 链接: https://pan.baidu.com/s/1x1YVr6…
阅读更多...
k8s中批量处理Pod应用的Job和CronJob控制器、处理守护型pod的DaemonSet控制器介绍

k8s中批量处理Pod应用的Job和CronJob控制器、处理守护型pod的DaemonSet控制器介绍

目录 一.Job控制器 1.简介 2.Jobs较完整解释 3.示例演示 4.注意：如上例的话，执行“kubectl delete -f myJob.yaml”就可以将job删掉 二.CronJob（简写为cj） 1.简介 2.CronJob较完整解释 3.案例演示 4.如上例的话&#xf…
阅读更多...
数据“表”的增删改查

数据“表”的增删改查

创建数据表 删除数据表 修改数据表 查看数据表 喜欢点赞收藏，如有疑问，点击链接加入群聊【信创技术交流群】：http://qm.qq.com/cgi-bin/qm/qr?_wv1027&kEjDhISXNgJlMMemn85viUFgIqzkDY3OC&authKey2SKLwlmvTpbqlaQtJ%2FtFXJgHVgl…
阅读更多...
适用于 Windows 的 10 个顶级分区管理器软件

适用于 Windows 的 10 个顶级分区管理器软件

您想要对硬盘驱动器或 USB 驱动器进行分区的原因可能有多种。许多用户希望对其外部和内部硬盘驱动器进行分区以有效地管理数据。为了处理分区，Windows为用户提供了一个内置的分区管理工具。 Windows 用户可以通过磁盘管理面板对任何驱动器进行分区。然而&#xff0…
阅读更多...
『VUE3后台—大事件管理系统（已完结）』

『VUE3后台—大事件管理系统（已完结）』

项目地址：https://gitee.com/csheng-gitee/vue3-big-event-admin 技术栈：VUE3 Pinia Pnpm（本项目暂不用 typescript） 一、前期准备工作 1、创建项目 npm install -g pnpm pnpm create vue2、ESLint 配置 (1) 禁用 prettier 插…
阅读更多...
做销售的时候为什么你的内心会恐惧？

做销售的时候为什么你的内心会恐惧？

做销售的时候为什么你的内心会恐惧？ 做销售的时候，很多人的内心会感到恐惧。这种恐惧可能来自于对自己业绩的担忧，或者是对被拒绝的恐惧。但是，恐惧并不是我们该有的心态。在销售中，我们需要保持自信和冷静&#xff0…
阅读更多...
线上超市小程序可以做什么活动_提升用户参与度与购物体验

线上超市小程序可以做什么活动_提升用户参与度与购物体验

标题：线上超市小程序：精心策划活动，提升用户参与度与购物体验 一、引言 随着移动互联网的普及，线上购物已经成为人们日常生活的一部分。线上超市作为线上购物的重要组成部分，以其便捷、快速、丰富的商品种类和个性化…
阅读更多...
直击2023云栖大会-大模型时代到来：“计算，为了无法计算的价值”

直击2023云栖大会-大模型时代到来：“计算，为了无法计算的价值”

2023年的云栖大会以“计算，为了无法计算的价值”为主题，强调了计算技术在现代社会中的重要性，特别是在大模型时代到来的背景下。 大模型时代指的是以深度学习为代表的人工智能技术的快速发展，这些技术需要大量的计算资源来训练和优…
阅读更多...
机器学习决策树ID3算法

机器学习决策树ID3算法

1、先去计算总的信息量 2、根据不同指标分别计算对应的信息增益 3、根据算出的信息增益来选择信息增益最大的作为根结点 4、天气中选择一个继续上述过程 5、决策树划分结束
阅读更多...
基于Springboot的秒杀系统（有报告）。Javaee项目，springboot项目。

基于Springboot的秒杀系统（有报告）。Javaee项目，springboot项目。

演示视频： 基于Springboot的秒杀系统（有报告）。Javaee项目，springboot项目。 项目介绍： 采用M（model）V（view）C（controller）三层体系结构&#xf…
阅读更多...
服务器数据恢复—ocfs2文件系统被格式化为其他文件系统如何恢复数据？

服务器数据恢复—ocfs2文件系统被格式化为其他文件系统如何恢复数据？

服务器故障： 由于工作人员的误操作，将Ext4文件系统误装入到存储中Ocfs2文件系统数据卷上，导致原Ocfs2文件系统被格式化为Ext4文件系统。 由于Ext4文件系统每隔几百兆就会写入文件系统的原始信息，原Ocfs2文件系统数据会遭受一定程度…
阅读更多...
电脑监控软件是隐藏安装吗？

电脑监控软件是隐藏安装吗？

电脑监控软件通常可以隐藏安装。 这种类型的软件可能是通过企业管理者下载或拷贝到员工的电脑上的。因为程序包比较小，安装过程也比较简单，所以操作起来也很方便。 企业管理者的这种操作基本上是为了更好管控公司的电脑运行、防止员工恶意泄露公司的机密…
阅读更多...
行业分析：2023年智能自动化药房市场现状及发展前景

行业分析：2023年智能自动化药房市场现状及发展前景

医药电商是近些年的行业风口，尤其是随着大型互联网平台的介入和互联网医院的兴起，医药电商步入高速增长期。第三方交易服务平台在医药电商的销售额占比为58%，而到了2020年下降至40%。在终端销售额中，大型医院占据了59.7%的份额&am…
阅读更多...
【字符串匹配】【KMP算法】Leetcode 28 找出字符串中第一个匹配项的下标☆

【字符串匹配】【KMP算法】Leetcode 28 找出字符串中第一个匹配项的下标☆

【字符串匹配】【KMP算法】Leetcode 28 找出字符串中第一个匹配项的下标 （1）前缀和后缀（2）前缀表（最长相同的前缀和后缀的长度）（3）匹配过程示意（4）next数组的…
阅读更多...
2024年天津中德应用技术大学专升本专业课报名及考试时间通知

2024年天津中德应用技术大学专升本专业课报名及考试时间通知

天津中德应用技术大学2024年高职升本科专业课报名确认及考试通知 按照市高招办《2024年天津市高职升本科招生实施办法》（津招办高发〔2023〕14号）文件要求，天津中德应用技术大学制定了2024年高职升本科专业课考试报名、确认及考试实施方案&a…
阅读更多...
【开源】基于Vue.js的人事管理系统

【开源】基于Vue.js的人事管理系统

文末获取源码，项目编号： S 079 。 \color{red}{文末获取源码，项目编号：S079。} 文末获取源码，项目编号：S079。 目录 一、摘要1.1 项目介绍1.2 项目录屏 二、功能模块2.1 管理员功能模块2.2 普通员工功能模块…
阅读更多...
【JVM系列】Class文件分析

【JVM系列】Class文件分析

💝💝💝欢迎来到我的博客，很高兴能够在这里和您见面！希望您在这里可以感受到一份轻松愉快的氛围，不仅可以获得有趣的内容和知识，也可以畅所欲言、分享您的想法和见解。 推荐:kwan 的首页,持续学…
阅读更多...
IDEA2023找不到 Allow parallel run

IDEA2023找不到 Allow parallel run

我的idea版本：2023.1.4 第一步：点击Edit Configrations 第二步：点击Modify options 第三步：勾选Allow multiple instances 最后点击Apply应用一下 ok,问题解决！
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023