实战:Redis实现排行榜、点赞和关注功能的基本操作

Redis是一款高性能的内存数据库,以其极快的读写速度和丰富的数据结构广泛应用于各种互联网服务中。本文将介绍如何基于Redis实现排行榜、点赞和关注功能,并提供相应的代码示例。

实战:Redis性能测试、调优和使用规范-CSDN博客

规范:Redis规范-CSDN博客

实战:搞懂Redisson、分布式锁、限流器_redisson分布式限流-CSDN博客

实践:Redis6.0配置文件解读_redis 6.0-CSDN博客

科普文:深入理解Redis-CSDN博客

1. Redis简介

Redis(Remote Dictionary Server)是一种开源的内存数据结构存储系统,通常用作数据库、缓存和消息中间件。它支持多种数据结构,如字符串、散列、列表、集合、有序集合等,并提供持久化选项。

主要特点:

  • 高速读写性能

  • 丰富的数据结构

  • 主从复制和高可用性

  • 持久化支持

这些特性使得Redis非常适合用于实现实时性要求较高的功能,比如排行榜、点赞和关注。

2. 环境配置

在开始之前,我们需要配置开发环境。本文使用Jedis库来与Redis进行交互。首先,在你的项目中引入Jedis库。对于Maven项目,可以在pom.xml中添加以下依赖:

<dependency>    <groupId>redis.clients</groupId>    <artifactId>jedis</artifactId>    <version>3.7.0</version></dependency>

接下来,确保你的系统已经安装并运行Redis服务器。

3. 排行榜功能的实现

概述

排行榜功能是许多应用中的常见需求,比如游戏中的积分排名、网站上的热门文章排行等。Redis提供的有序集合(Sorted Set)数据结构非常适合实现排行榜功能,因为它可以自动根据分数排序,并支持范围查询。

实现步骤

  1. 数据结构选择:使用有序集合(Sorted Set),其中成员是用户ID或项目ID,分数是对应的积分或权重。

  2. 添加和更新分数:使用ZADD命令添加或更新成员的分数。

  3. 获取排行榜:使用ZRANGE命令获取排行榜中的成员及其分数。

  4. 获取成员排名:使用ZRANK命令获取成员在排行榜中的排名。

代码示例

import redis.clients.jedis.Jedis;import redis.clients.jedis.Tuple;
import java.util.Set;
public class Leaderboard {
    private static final String LEADERBOARD_KEY = "leaderboard";    private Jedis jedis;
    public Leaderboard(Jedis jedis) {        this.jedis = jedis;    }
    // 添加或更新用户积分    public void addScore(String userId, double score) {        jedis.zadd(LEADERBOARD_KEY, score, userId);    }
    // 获取排行榜前N名    public Set<Tuple> getTopN(int n) {        return jedis.zrevrangeWithScores(LEADERBOARD_KEY, 0, n - 1);    }
    // 获取用户排名    public long getRank(String userId) {        Long rank = jedis.zrevrank(LEADERBOARD_KEY, userId);        return rank != null ? rank + 1 : -1;    }
    public static void main(String[] args) {        try (Jedis jedis = new Jedis("localhost")) {            Leaderboard leaderboard = new Leaderboard(jedis);
            leaderboard.addScore("user1", 100);            leaderboard.addScore("user2", 150);            leaderboard.addScore("user3", 120);
            Set<Tuple> top3 = leaderboard.getTopN(3);            for (Tuple tuple : top3) {                System.out.println(tuple.getElement() + ": " + tuple.getScore());            }
            System.out.println("user1's rank: " + leaderboard.getRank("user1"));        }    }}

4. 点赞功能的实现

概述

点赞功能常用于社交平台或内容网站,用于表示用户对某个内容的喜爱。Redis的集合(Set)数据结构可以有效地实现点赞功能,每个被点赞的内容对应一个集合,集合中存储点赞用户的ID。

实现步骤

  1. 数据结构选择:使用集合(Set),集合名为内容ID,集合中存储点赞用户的ID。

  2. 添加点赞:使用SADD命令将用户ID添加到集合中。

  3. 取消点赞:使用SREM命令将用户ID从集合中移除。

  4. 获取点赞数:使用SCARD命令获取集合中的元素数量。

  5. 检查用户是否点赞:使用SISMEMBER命令检查集合中是否包含用户ID。

代码示例

import redis.clients.jedis.Jedis;
public class LikeService {
    private Jedis jedis;
    public LikeService(Jedis jedis) {        this.jedis = jedis;    }
    // 点赞    public void like(String contentId, String userId) {        jedis.sadd("likes:" + contentId, userId);    }
    // 取消点赞    public void unlike(String contentId, String userId) {        jedis.srem("likes:" + contentId, userId);    }
    // 获取点赞数    public long getLikes(String contentId) {        return jedis.scard("likes:" + contentId);    }
    // 检查用户是否点赞    public boolean hasLiked(String contentId, String userId) {        return jedis.sismember("likes:" + contentId, userId);    }
    public static void main(String[] args) {        try (Jedis jedis = new Jedis("localhost")) {            LikeService likeService = new LikeService(jedis);
            likeService.like("post1", "user1");            likeService.like("post1", "user2");            likeService.unlike("post1", "user1");
            System.out.println("post1 likes: " + likeService.getLikes("post1"));            System.out.println("user1 has liked post1: " + likeService.hasLiked("post1", "user1"));        }    }}

5. 关注功能的实现

概述

关注功能是社交网络中的核心功能,用户可以关注其他用户以获取其动态。Redis的集合(Set)数据结构也适合实现关注功能,分别用两个集合存储每个用户的关注列表和粉丝列表。

实现步骤

  1. 数据结构选择:使用集合(Set),一个集合存储关注列表,一个集合存储粉丝列表。

  2. 关注用户:使用SADD命令将被关注用户ID添加到关注列表,将关注者ID添加到粉丝列表。

  3. 取消关注:使用SREM命令将被关注用户ID从关注列表移除,将关注者ID从粉丝列表移除。

  4. 获取关注列表和粉丝列表:使用SMEMBERS命令获取集合中的所有元素。

  5. 检查是否关注:使用SISMEMBER命令检查集合中是否包含用户ID。

代码示例

import redis.clients.jedis.Jedis;
import java.util.Set;
public class FollowService {
    private Jedis jedis;
    public FollowService(Jedis jedis) {        this.jedis = jedis;    }
    // 关注用户    public void follow(String userId, String targetId) {        jedis.sadd("following:" + userId, targetId);        jedis.sadd("followers:" + targetId, userId);    }
    // 取消关注    public void unfollow(String userId, String targetId) {        jedis.srem("following:" + userId, targetId);        jedis.srem("followers:" + targetId, userId);    }
    // 获取关注列表    public Set<String> getFollowing(String userId) {        return jedis.smembers("following:" + userId);    }
    // 获取粉丝列表    public Set<String> getFollowers(String userId) {        return jedis.smembers("followers:" + userId);    }
    // 检查是否关注    public boolean isFollowing(String userId, String targetId) {        return jedis.sismember("following:" + userId, targetId);    }
    public static void main(String[] args) {        try (Jedis jedis = new Jedis("localhost")) {            FollowService followService = new FollowService(jedis);
            followService.follow("user1", "user2");            followService.follow("user1", "user3");            followService.unfollow("user1", "user2");
            System.out.println("user1 is following: " + followService.getFollowing("user1"));            System.out.println("user2's followers: " + followService.getFollowers("user2"));            System.out.println("user1 is following user2: " + followService.isFollowing("user1", "user2"));        }    }}

结论

本文介绍了如何使用Java语言和Redis实现排行榜、点赞和关注功能。通过Jedis库,我们可以轻松地与Redis进行交互,利用其高性能和丰富的数据结构来实现这些常见的功能。希望这些代码示例能帮助你更好地理解和实现相关功能。

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

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

QT vs2019编译报错LNK2019无法解析的外部符号

严重性 代码 说明 项目 文件 行 禁止显示状态 错误 LNK2019 无法解析的外部符号 "public: __cdecl Dialog_Setting::Dialog_Setting(class QWidget *)" (??0Dialog_SettingQEAAPEAVQWidgetZ)&#xff0c;函数 "public: __cdecl QtWid…

网络安全-华为华三交换机防火墙日志解析示例

DEF_SYSLOG_SWITCH_HUAWEI.py 华为交换机日志解析示例 # -*- coding: utf8 -*- import time from DEF_COLOR import * ## 终端显示颜色def 时间戳_2_时间文本(时间戳, 时间文本格式%Y-%m-%d %H:%M:%S):#时间文本格式 %Y-%m-%d %H:%M:%S时间类 time.localtime(时间戳)时间…

KingbaseES8(人大金仓数据库)备份还原

KingbaseES8(人大金仓数据库)备份还原 1.用户角色备份 sys_dumpall -U system -r -f backup_AAAAAA/user.sql2.数据库备份 sys_dump -h ip -p 端口 -U 用户 –F c -f 备份路径/xxx.dmp 库名 sys_dump -h 127.0.0.1 -p 54321 -U system -F c -f backup_AAAAAA/AAAAAA.dmp A…

C# 连接SQLServer操作数据库问题

C#联合SQLServer开发时连接数据库报错connection 连接问题 报错信息&#xff1a; This operation requires a connection to the ‘master’ database. Unable to create a connection to the ‘master’ database because the original database connection has been opened a…

工业现场实测,焦化厂导烟车与装煤车风机实现无人作业

一、项目背景 作为我国重要的能源行业之一&#xff0c;焦化行业在国民经济中扮演着重要角色&#xff0c;焦化工艺是高温、高压、有毒物质等因素共同作用下进行的&#xff0c;因此存在着安全隐患&#xff0c;并伴有环境污染&#xff0c;改善焦化工艺的安全和环保问题是当前亟待…

Docker 安装指南

&#x1f341; 作者&#xff1a;知识浅谈&#xff0c;CSDN签约讲师&#xff0c;CSDN博客专家&#xff0c;华为云云享专家&#xff0c;阿里云专家博主 &#x1f4cc; 擅长领域&#xff1a;全栈工程师、爬虫、ACM算法 &#x1f525; 微信&#xff1a;zsqtcyw 联系我领取学习资料 …

Golang | Leetcode Golang题解之第287题寻找重复数

题目&#xff1a; 题解&#xff1a; func findDuplicate(nums []int) int {slow, fast : 0, 0for slow, fast nums[slow], nums[nums[fast]]; slow ! fast; slow, fast nums[slow], nums[nums[fast]] { }slow 0for slow ! fast {slow nums[slow]fast nums[fast]}return s…

React--Action Creators

在 Redux 中&#xff0c;Action Creators 是专门用于创建 actions 的函数。它们简化了生成 actions 的过程&#xff0c;使得代码更易读和可维护。 什么是 Action Creators Action 是一个普通的 JavaScript 对象&#xff0c;描述了对 Redux store 状态的某种变化。通常它具有一…

分布式搜索引擎ES-DSL搜索详解

1.DSL搜索-入门语法 建立索引&#xff1a; xxx(自定义名称) 自定义mapping: POST /shop/_mapping {"properties": {"id": {"type": "long"},"age": {"type": "integer"},"username": {&quo…

Springboot 多数据源事务

起因 在一个service方法上使用的事务,其中有方法是调用的多数据源orderDB 但是多数据源没有生效,而是使用的primaryDB 原因 spring 事务实现的方式 以 Transactional 注解为例 (也可以看 TransactionTemplate&#xff0c; 这个流程更简单一点)。 入口&#xff1a;ProxyTransa…

前端缓存策略

Service Worker &#xff08;https) 使用 Service Worker 可以实现离线功能和缓存策略&#xff0c;使你的 Web 应用在没有网络连接时也能正常运行。下面是一个详细的步骤和示例代码&#xff0c;展示如何使用 Service Worker 实现这一功能。 步骤 注册 Service Worker安装 Se…

PHP框架中的数据加密实践:确保数据安全的艺术

引言 数据加密是保护敏感信息不被未授权访问的关键技术。在PHP框架中实现数据加密不仅可以增强应用的安全性&#xff0c;也是遵守数据保护法规的必要措施。本文将深入探讨在PHP框架中实现数据加密的方法&#xff0c;包括加密算法的选择、密钥管理、以及如何在应用程序中集成加…

Java语言程序设计——篇九(1)

&#x1f33f;&#x1f33f;&#x1f33f;跟随博主脚步&#xff0c;从这里开始→博主主页&#x1f33f;&#x1f33f;&#x1f33f; 内部类 概述内部类—内部类的分类成员内部类实战演练 局部内部类实战演练 匿名内部类实战演练 静态内部类实战演练 概述 内部类或嵌套类&#…

java pdf转base64图片工具类

java pdf转base64图片工具类 依赖工具类 依赖 <dependency><groupId>org.apache.pdfbox</groupId><artifactId>pdfbox</artifactId><version>2.0.13</version></dependency>工具类 import org.apache.pdfbox.pdmodel.PDDocume…

组串式逆变器发展趋势

组串式逆变器单机功率不断增加 组串式逆变器的单体容量一般在100KW以下&#xff0c;在行业发展初期&#xff0c;一般以较小功率的组串式逆变器为主&#xff0c;随着功率模块等技术的不断发展&#xff0c;市场领先企业不断研发和推出单机功率较大的组串式逆变器。 随着单机功率的…

【攻防演练】【含poc和修复建议】海康威视综合安防管理平台 远程命令执行漏洞

使用防护类设备进行防护&#xff0c;限制访问/center/api/installation/detection 路径&#xff0c;拦截请求中出现的恶意命令注入 POST /center/api/installation/detection HTTP/1.1 Host: User-Agent: Mozilla/5.0 (Macintosh; Intel Mac Os X 10 12_6) AppleWebKit/537.36…

sheng的学习笔记-AI-公式-指数加权移动平均(EWMA)

AI目录&#xff1a;sheng的学习笔记-AI目录-CSDN博客 基础知识 指数加权移动平均&#xff08;Exponential Weighted Moving Average&#xff09;&#xff0c;是一种常用的序列处理方式 看例子&#xff0c;首先这是一年365天的温度散点图&#xff0c;以天数为横坐标&#xff0…

牛客AB5 | 点击消除

描述 牛牛拿到了一个字符串。 他每次“点击”&#xff0c;可以把字符串中相邻两个相同字母消除&#xff0c;例如&#xff0c;字符串"abbc"点击后可以生成"ac"。 但相同而不相邻、不相同的相邻字母都是不可以被消除的。 牛牛想把字符串变得尽可能短。他想知…

操作系统概念(黑皮书)阅读笔记

操作系统概念&#xff08;黑皮书&#xff09;阅读笔记 进程和内存管理部分章节 导论&#xff1a; 操作系统类似于政府&#xff0c;其本身不能实现任何有用功能&#xff0c;而是提供一个方便其他程序执行有用工作的环境 ​ 个人理解&#xff1a;os是government的作用&#xff0…

【学一点儿前端】本地或jenkins打包报错:getaddrinfo ENOTFOUND registry.nlark.com.

问题 今天jenkins打包一个项目&#xff0c;发现报错了 error An unexpected error occurred: "https://registry.nlark.com/xxxxxxxxxx.tgz: getaddrinfo ENOTFOUND registry.nlark.com". 先写解决方案 把yarn.lock文件里面的registry.nlark.com替换为registry.npmmi…