如何高效的使用java实现类似抖音的评论点赞列表(互动消息)以及点赞的基本操作
前言
这篇文章是基于Java实现的一个点赞功能,是在微服务上的评论功能的子模块,以及类似于抖音的评论点赞列表,可以联表查询用户点赞的评论列表和用户被点赞的评论列表,其中并没有使用redis和mq的中间件进行优化。
实现功能
实现添加取消点赞,判断是否点赞,查看用户点赞的评论列表和用户被点赞的评论列表等。
一、数据库设计
1.评论点赞表数据库
二、实体类和VO对象
1.实体类
实体类内容与数据库相同,在此不做展示。
2.VO对象
public class LikeVO {
/**
* 点赞表主键
*/
Integer likeId;
/**
* 用户信息
*/
UserSimpleVO userInfo;
/**
* 评论内容
*/
String content;
/**
* 点赞创建时间
*/
Timestamp createTime;
}
三、代码实现
1.判断是否点赞
@Override
public boolean isLike(Integer userId, Integer commentId) {
LambdaQueryWrapper<Like> queryWrapper = new LambdaQueryWrapper<>();
queryWrapper.eq(Like::getUserId,userId)
.eq(Like::getCommentId,commentId);
Long count = likeMapper.selectCount(queryWrapper);
return count>0;
}
2.添加或取消点赞
@Override
public boolean like(Integer userId, Integer commentId) {
//lambda查询是否存在点赞记录
LambdaQueryWrapper<Like> queryWrapper = new LambdaQueryWrapper<>();
queryWrapper.eq(Like::getCommentId,commentId)
.eq(Like::getUserId,userId);
Like like = likeMapper.selectOne(queryWrapper);
//判断点赞记录是否为空,为空则添加,不为空则删除
if(like!=null){
int row = likeMapper.delete(queryWrapper);
commentMapper.updateLikeNum(commentId,-1);
return row>0;
}
like = new Like();
like.setCommentId(commentId);
like.setUserId(userId);
int row = likeMapper.insert(like);
//进行评论点赞数的减少
commentMapper.updateLikeNum(commentId,1);
return row>0;
}
3.查询用户被点赞评论的记录
使用了ArrayList、HashMap和stream流等操作加快查询效率。
由于我点赞表中只有点赞用户的id和评论id,所以先进行了查询该用户所有评论的操作,若有什么优化方法可以评论教我一下。
@Override
public List<LikeVO> likeByCommons(Integer userId) {
//查询出该用户的所有评论
LambdaQueryWrapper<Comment> queryWrapper = new LambdaQueryWrapper<>();
queryWrapper.eq(Comment::getUserId,userId);
List<Comment> comments = commentMapper.selectList(queryWrapper);
//判断该用户是否有评论,若没有则返回空集合。
if (comments.size() == 0) {
return new ArrayList<>();
}
//统计这些评论的id
List<Integer> commentIds = new ArrayList<>();
//创建评论id和评论内容的映射
Map<Integer,String> commentInfo = new HashMap<>();
for(Comment comment:comments)
{
commentIds.add(comment.getId());
commentInfo.put(comment.getId(),comment.getContent());
}
//查询出点赞关系
LambdaQueryWrapper<Like> likeLambdaQueryWrapper = new LambdaQueryWrapper<>();
likeLambdaQueryWrapper.in(Like::getCommentId,commentIds);
likeLambdaQueryWrapper.orderByDesc(Like::getCreateTime);
List<Like> likes = likeMapper.selectList(likeLambdaQueryWrapper);
//把查出的点赞关系按照时间排序
//likes = likes.stream().sorted(Comparator.comparing(Like::getCreateTime).reversed()).collect(Collectors.toList());
//查出点赞用户信息
Set<Integer> userIds = new HashSet<>();
for(Like like:likes)
{
userIds.add(like.getUserId());
}
List<Integer> userList = new ArrayList<>(userIds);
Map<Integer, UserSimpleVO> userInfo = userClient.getUserDeatilInfoMap(userList).getData();
//stream流把comment对象赋值到likeVO中
return likes.stream().map((item) -> {
LikeVO likeVO = new LikeVO();
likeVO.setLikeId(item.getLikeId());
likeVO.setContent(commentInfo.get(item.getCommentId()));
likeVO.setUserInfo(userInfo.get(item.getUserId()));
likeVO.setCreateTime(item.getCreateTime());
return likeVO;
}).collect(Collectors.toList());
}
4.查询用户点赞的评论列表
@Override
public List<LikeVO> likeCommons(Integer userId) {
//查出该用户点赞的所有评论
LambdaQueryWrapper<Like> queryWrapper = new LambdaQueryWrapper<>();
queryWrapper.eq(Like::getUserId,userId);
queryWrapper.orderByDesc(Like::getCreateTime);
List<Like> likeList = likeMapper.selectList(queryWrapper);
if (likeList.size() == 0) {
return new ArrayList<>();
}
//查出对应的评论信息
List<Integer> commentIds = new ArrayList<>();
for(Like like:likeList)
{
commentIds.add(like.getCommentId());
}
List<Comment> commentList = commentMapper.selectBatchIds(commentIds);
//查询出被点赞评论的用户信息和创建评论关系的映射
Map<Integer,Comment> commentInfo = new HashMap<>();
Set<Integer> userIds = new HashSet<>();
for(Comment comment:commentList)
{
userIds.add(comment.getUserId());
commentInfo.put(comment.getId(),comment);
}
List<Integer> userList = new ArrayList<>(userIds);
Map<Integer, UserSimpleVO> userInfo = userClient.getUserDeatilInfoMap(userList).getData();
//stream流把comment对象赋值到likeVO中
return likeList.stream().map((item) -> {
LikeVO likeVO = new LikeVO();
likeVO.setLikeId(item.getLikeId());
likeVO.setUserInfo(userInfo.get(item.getUserId()));
likeVO.setContent(commentInfo.get(item.getCommentId()).getContent());
likeVO.setCreateTime(item.getCreateTime());
return likeVO;
}).collect(Collectors.toList());
}
总结
这是我在写项目时的一些功能代码分享,若有不足请大家指出。
转载自:https://juejin.cn/post/7247569496696619067