您现在的位置是：网站首页> 编程资料编程资料
手把手教你用Redis 实现点赞功能并且与数据库同步_Redis_
2023-05-27
440人已围观
简介 手把手教你用Redis 实现点赞功能并且与数据库同步_Redis_
一、Redis 缓存设计及实现
Linux下安装Redis或者Docker下安装Redis并且启动(redis-server)
SpringBoot整合Redis
1.在 pom.xml 中引入依赖
org.springframework.boot spring-boot-starter-data-redis
2.在启动类上添加注释 @EnableCaching
3.编写 Redis 配置类 RedisConfig
@Configuration public class RedisConfig { @Bean @ConditionalOnMissingBean(name = "redisTemplate") public RedisTemplate redisTemplate(RedisConnectionFactory redisConnectionFactory)throws UnknownHostException { Jackson2JsonRedisSerializer 二、点赞数据在 Redis 中的存储格式
用 Redis 存储两种数据：
- 一种是记录点赞人、被点赞人、点赞状态的数据
- 一种是每个用户被点赞了多少次，做个简单的计数
由于需要记录点赞人和被点赞人，还有点赞状态（点赞、取消点赞），还要固定时间间隔取出 Redis 中所有点赞数据，所以 Redis 数据格式中 Hash 最合适。
因为 Hash 里的数据都是存在一个键里，可以通过这个键很方便的把所有的点赞数据都取出。这个键里面的数据还可以存成键值对的形式，方便存入点赞人、被点赞人和点赞状态。
设点赞人的 id 为 giveLikeId，被点赞人的 id 为 likeUserId ，点赞时状态为 1，取消点赞状态为 0。将点赞人 id 和被点赞人 id 作为键，两个 id 中间用 :: 隔开，点赞状态作为值。
类似于这样：
在service层操作Redis
public interface RedisService { /** * 点赞。状态为1 * @param likedUserId * @param giveLikeId */ void saveLiked2Redis(String likedUserId, String giveLikeId); /** * 取消点赞。将状态改变为0 * @param likedUserId * @param giveLikeId */ void unlikeFromRedis(String likedUserId, String giveLikeId); /** * 从Redis中删除一条点赞数据 * @param likedUserId * @param giveLikeId */ void deleteLikedFromRedis(String likedUserId, String giveLikeId); /** * 该用户的点赞数加1 * @param likedUserId */ void incrementLikedCount(String likedUserId); /** * 该用户的点赞数减1 * @param likedUserId */ void decrementLikedCount(String likedUserId); /** * 获取Redis中存储的所有点赞数据 * @return */ List getLikedDataFromRedis(); /** * 获取Redis中存储的所有点赞数量 * @return */ List getLikedCountFromRedis();} 实现类 RedisServiceImpl ：
@Service @Slf4j public class RedisServiceImpl implements RedisService { @Autowired RedisTemplate redisTemplate; @Autowired LikedService likedService; @Override public void saveLiked2Redis(String likedUserId, String giveLikeId) { String key = RedisKeyUtils.getLikedKey(likedUserId, giveLikeId); redisTemplate.opsForHash().put(RedisKeyUtils.MAP_USER_LIKED, key, LikedStatusEnum.LIKE.getCode()); } @Override public void unlikeFromRedis(String likedUserId, String giveLikeId) { String key = RedisKeyUtils.getLikedKey(likedUserId, giveLikeId); redisTemplate.opsForHash().put(RedisKeyUtils.MAP_USER_LIKED, key, LikedStatusEnum.UNLIKE.getCode()); } @Override public void deleteLikedFromRedis(String likedUserId, String giveLikeId) { String key = RedisKeyUtils.getLikedKey(likedUserId, giveLikeId); redisTemplate.opsForHash().delete(RedisKeyUtils.MAP_USER_LIKED, key); } @Override public void incrementLikedCount(String likedUserId) { redisTemplate.opsForHash().increment(RedisKeyUtils.MAP_USER_LIKED_COUNT,likedUserId,1); } @Override public void decrementLikedCount(String likedUserId) { redisTemplate.opsForHash().increment(RedisKeyUtils.MAP_USER_LIKED_COUNT,likedUserId,-1); } @Override public List getLikedDataFromRedis() { Cursor> cursor =redisTemplate.opsForHash().scan(RedisKeyUtils.MAP_USER_LIKED, ScanOptions.NONE); List list = new ArrayList<>(); while (cursor.hasNext()){ Map.Entry entry = cursor.next(); String key = (String) entry.getKey(); //分离出 likedUserId，giveLikeId String[] split = key.split("::"); String likedUserId = split[0]; String giveLikeId = split[1]; Integer value = (Integer) entry.getValue(); //组装成 UserLike 对象 UserLike userLike = new UserLike(likedUserId, giveLikeId, value); list.add(userLike); //存到 list 后从 Redis 中删除 redisTemplate.opsForHash().delete(RedisKeyUtils.MAP_USER_LIKED, key); } return list; } @Override public List getLikedCountFromRedis() { Cursor> cursor = redisTemplate.opsForHash().scan(RedisKeyUtils.MAP_USER_LIKED_COUNT, ScanOptions.NONE); List list = new ArrayList<>(); while (cursor.hasNext()){ Map.Entry map = cursor.next(); //将点赞数量存储在 LikedCountDT String key = (String)map.getKey(); LikedCountDTO dto = new LikedCountDTO(key, (Integer) map.getValue()); list.add(dto); //从Redis中删除这条记录 redisTemplate.opsForHash().delete(RedisKeyUtils.MAP_USER_LIKED_COUNT, key); } return list; } } RedisKeyUtils, 用于根据一定规则生成 key
public class RedisKeyUtils { //保存用户点赞数据的key public static final String MAP_USER_LIKED = "MAP_USER_LIKED"; //保存用户被点赞数量的key public static final String MAP_USER_LIKED_COUNT = "MAP_USER_LIKED_COUNT"; /** * 拼接被点赞的用户id和点赞的人的id作为key。格式 001::1006 * @param likedUserId 被点赞的人id * @param giveLikeId 点赞的人的id * @return */ public static String getLikedKey(String likedUserId, String giveLikeId){ StringBuilder builder = new StringBuilder(); builder.append(likedUserId); builder.append("::"); builder.append(giveLikeId); return builder.toString(); } } LikedStatusEnum 用户点赞状态的枚举类
/** * 用户点赞的状态 */ @Getter public enum LikedStatusEnum { LIKE(1, "点赞"), UNLIKE(0, "取消点赞/未点赞"), ; private Integer code; private String msg; LikedStatusEnum(Integer code, String msg) { this.code = code; this.msg = msg; } } 三、数据库设计
数据库表中至少要包含三个字段：被点赞用户 id，点赞用户 id，点赞状态。再加上主键 id，创建时间，修改时间就行了。
create table `user_like`( `id` int not null auto_increment, `liked_user_id` varchar(32) not null comment '被点赞的用户id', `give_liked_id` varchar(32) not null comment '点赞的用户id', `status` tinyint(1) default '1' comment '点赞状态，0取消，1点赞', `create_time` timestamp not null default current_timestamp comment '创建 时间', `update_time` timestamp not null default current_timestamp on update current_timestamp comment '修改时间', primary key(`id`), INDEX `liked_user_id`(`liked_user_id`), INDEX `give_liked_id`(`give_liked_id`) ) comment '用户点赞表';
对应的对象 UserLike
/** * 用户点赞表 */ @Entity @Data public class UserLike { //主键id @Id @GeneratedValue(strategy = GenerationType.IDENTITY) private Integer id; //被点赞的用户的id private String likedUserId; //点赞的用户的id private String giveLikedId; //点赞的状态.默认未点赞 private Integer status = LikedStatusEnum.UNLIKE.getCode(); public UserLike() { } public UserLike(String likedUserId, String giveLikedId, Integer status) { this.likedUserId = likedUserId; this.giveLikedId = giveLikedId; this.status = status; } } 在service层操作数据库
public interface LikedService { /** * 保存点赞记录 * @param userLike * @return */ UserLike save(UserLike userLike); /** * 批量保存或修改 * @param list */ List saveAll(List list); /** * 根据被点赞人的id查询点赞列表（即查询都谁给这个人点赞过） * @param likedUserId 被点赞人的id * @param pageable * @return */ Page getLikedListByLikedUserId(String likedUserId, Pageable pageable); /** * 根据点赞人的id查询点赞列表（即查询这个人都给谁点赞过） * @param giveLikedId * @param pageable * @return */ Page getLikedListByGiveLikedId(String giveLikedId, Pageable pageable); /** * 通过被点赞人和点赞人id查询是否存在点赞记录 * @param likedUserId * @param giveLikedId * @return */ UserLike getByLikedUserIdAndGiveLikedId(String likedUserId, String giveLikedId); /** * 将Redis里的点赞数据存入数据库中 */ void transLikedFromRedis2DB(); /** * 将Redis中的点赞数量数据存入数据库 */ void transLikedCountFromRedis2DB(); } LikedServiceImpl 实现类
@Service @Slf4j public class LikedServiceImpl implements LikedService { @Autowired UserLikeRepository likeRepos
相关内容
- Redis中Bitmap的使用示例_Redis_
- Redis中Redisson布隆过滤器的学习_Redis_
- 浅谈Redis的异步机制_Redis_
- redis连接报错error:NOAUTH Authentication required_Redis_
- redis远程连接不上的解决办法_Redis_
- Redis实现限流器的三种方法(小结)_Redis_
- 浅谈Redis高并发缓存架构性能优化实战_Redis_
- Redis三种常用的缓存读写策略步骤详解_Redis_
- RedisTemplate常用操作方法总结(set、hash、list、string等)_Redis_
- Redis 的内存淘汰策略和过期删除策略的区别_Redis_
点击排行
本栏推荐
