抖音评论系统的实现思路

抖音大家都刷过。点开抖音的一个视频的评论，他会有一个根评论，根评论下面会有子评论，子评论中还有有对子评论的评论。具体如下图：

通过上面的图片可以直观的看见，这三种类型的评论。然后评论是根据时间的倒叙排列的。肯定还有会分页查询。用户点开评论，首先看到的是根评论。点开根评论，可以看见当前根评论对应的子评论。大概的功能就是这些。

一，需要实现的大致的功能点：

1.根评论，及根评论下子评论的嵌套。

2.评论用户基本信息的获取（用户图像，用户昵称）

3.对子评论的评论的展现。（a用户回复b用户的子评论）

4.用户的点赞，及点踩

5.评论的展示顺序（根据时间顺序，还是评论的热度）

二，数据库库表结构的设计：

两张表，一张根评论表，一张子评论表。

建表语句如下：

CREATE TABLE sys_sub_comments (
    id INT AUTO_INCREMENT PRIMARY KEY COMMENT '评论的唯一标识符',  -- 主键 id，唯一标识每个评论
    userId INT NOT NULL COMMENT '评论者的用户 ID',               -- 评论者的用户 ID
    workId INT NOT NULL COMMENT '作品 ID（如视频或文章等）',      -- 作品 ID，指评论对应的作品
    content TEXT NOT NULL COMMENT '评论内容',                     -- 评论的内容
    targetUserId INT COMMENT '评论的目标用户 ID（如针对特定用户的评论）',  -- 评论的目标用户 ID
    parentCommentId INT DEFAULT NULL COMMENT '父评论 ID，用于层级关系，NULL 代表根评论',  -- 父评论 ID，用于表示评论的层级，NULL 代表没有父评论
    createdAt TIMESTAMP DEFAULT CURRENT_TIMESTAMP COMMENT '评论的创建时间',  -- 评论的创建时间
    updatedAt TIMESTAMP DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '评论的更新时间'  -- 评论的最后更新时间
) COMMENT = '评论表，存储用户对作品的评论信息，支持层级评论';


CREATE TABLE sys_comments (
    id INT AUTO_INCREMENT PRIMARY KEY COMMENT '评论的唯一标识符',  -- 主键 id，唯一标识每个评论
    userId INT NOT NULL COMMENT '评论者的用户 ID',               -- 评论者的用户 ID
    workId INT NOT NULL COMMENT '作品 ID（如视频或文章等）',      -- 作品 ID，指评论对应的作品
    content TEXT NOT NULL COMMENT '评论内容',                     -- 评论的内容
    createdAt TIMESTAMP DEFAULT CURRENT_TIMESTAMP COMMENT '评论的创建时间',  -- 评论的创建时间
    updatedAt TIMESTAMP DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '评论的更新时间'  -- 评论的最后更新时间
) COMMENT = '评论表，存储用户对作品的评论信息，支持层级评论';

三，评论查询主要逻辑

1.根评论查询逻辑

返回的vo对象结构：

	/**
	 * 根评论vo
	 *
	 */ 
 
/**
 * 商品根评论实体
 */
@Data
@NoArgsConstructor
public class CommentVO {
 
	Integer id;
 
	Integer goodsId;
 
	/**
	 * 评论用户信息
	 */
	UserSimpleVO userInfo;
  
	String content;
  
	String type;
 
	Timestamp createdAt;

}

主要代码逻辑：

首先根据作品id，分页查出当前页的评论:

SELECT * FROM sys_comments WHERE workId = 'root' ORDER BY create_time DESC LIMIT 20 OFFSET 1;

根据userId获取当前页，所有评论用户的信息:

SELECT * FROM sys_user WHERE userId in (idList);

主要代码如下：

//根据作品id,分页查询作品评论       
List<Comment> comments = commentService.selectByGoodsId(googsId,pageNumber,pageCount);
       if (ObjectUtils.isEmpty(comments)){
           return new ArrayList<>();
       }
        // 统计用户id，并进行去重
        List<Long> userIds = comments.stream().map(Commetn::getUserId)
                .distinct()
                .collect(Collectors.toList());
       //key是用户id,值是用户信息
       Map<Long, UserInfo> userInfos = userService.selectByIds(userIds);
        List<CommentVo> commentVos = new ArrayList<CommentVo>();
        //进行对应评论用户信息的填充
        for (Comment comment : comments) {
            CommentVo commentVo = new CommentVo();
            //进行原有属性的拷贝
            BeanUtils.copyProperties(comment,commentVo);
            //设置用户相关信息
            UserInfo userInfo = userInfos.get(comment.getUserId);
            commentVo.setUserInfo(userInfo);
            commentVos.add(commentVo);
        }
        return commentVos;

2.子评论查询的主要逻辑

返回的vo对象结构：相较于根评论，多了一个被评论者用户信息

/**
	 * 子评论vo
	 *
	 */ 
 
/**
 * 商品子评论实体
 */
@Data
@NoArgsConstructor
public class SubCommentVO extents CommentVO  {

    //被评论者用户信息
    private UserInfo targetUserInfo;
}

主要代码逻辑：

根据父评论id筛选出，对应的子评论。

SELECT * FROM sys_sub_comments WHERE parentCommentId= 'commentId' ORDER BY create_time DESC LIMIT 20 OFFSET 1;

根据用户id，获取对应的用户信息

SELECT * FROM sys_user WHERE userId in (idList);

代码逻辑：

//根据作品id,分页查询作品评论       
List<SubComment> subComments= SubCommentService.selectByParentCommetnId(parentCommetnId,pageNumber,pageCount);
       if (ObjectUtils.isEmpty(comments)){
           return new ArrayList<>();
       }
        // 统计用户id（包括评论用户id和被评论用户id）
        List<Long> userIds = SubComments.stream()
                ..flatMap(subComment -> Arrays.stream(new long[]{subComment.getUserId1(), subComment.getTargetUserId()}))
                .distinct()
                .collect(Collectors.toList());
       //key是用户id,值是用户信息
       Map<Long, UserInfo> userInfos = userService.selectByIds(userIds);
        List<CommentVo> subCommentVos = new ArrayList<CommentVo>();
        //进行对应评论用户信息的填充
        for (SubComment subComment : subComments) {
            SubCommentVo  = new SubCommentVo();
            //进行原有属性的拷贝
            BeanUtils.copyProperties(subComment ,subCommentVo);
            //设置用户相关信息
            UserInfo userInfo = userInfos.get(subComment.getUserId());
            subCommentVo.setUserInfo(userInfo);
            //设置目标评论者的用户信息
            UserInfo targetUserInfo = userInfos.get(subComment.getTargetUserInfo());
            subCommentVo.setTargetUserInfo(targetUserInfo);
            subCommentVos.add(subComment );
        }
        return subCommentVos;

对于插入操作来说，都是常规操作，这里不做过多的说明。