课程说明

  • 圈子实现点赞、喜欢功能
  • 圈子实现评论
  • 圈子实现评论的点赞
  • 小视频功能说明
  • FastDFS环境搭建
  • 小视频的功能实现

1、评论

点赞、喜欢、评论等均可理解为用户对动态的评论。

1.1、点赞

1.1.1、定义dubbo接口

  1. package com.tanhua.dubbo.server.api;
  3. import com.tanhua.dubbo.server.pojo.Pu blish;
  4. import com.tanhua.dubbo.server.vo.PageInfo;
  6. public interface QuanZiApi {
  8.     /**
  9.      * 发布动态
  10.      *
  11.      * @param publish
  12.      * @return
  13.      */
  14.     boolean savePublish(Publish publish);
  16.     /**
  17.      * 查询动态
  18.      *
  19.      * @return
  20.      */
  21.     PageInfo<Publish> queryPublishList(Long userId, Integer page, Integer pageSize);
  23.     /**
  24.      * 点赞
  25.      *
  26.      * @param userId
  27.      * @param publishId
  28.      * @return
  29.      */
  30.     boolean saveLikeComment(Long userId, String publishId);
  32.     /**
  33.      * 取消点赞、喜欢等
  34.      *
  35.      * @param userId
  36.      * @param publishId
  37.      * @return
  38.      */
  39.     boolean removeComment(Long userId, String publishId, Integer commentType);
  41.     /**
  42.      * 喜欢
  43.      *
  44.      * @param userId
  45.      * @param publishId
  46.      * @return
  47.      */
  48.     boolean saveLoveComment(Long userId, String publishId);
  50.     /**
  51.      * 保存评论
  52.      *
  53.      * @param userId
  54.      * @param publishId
  55.      * @param type
  56.      * @param content
  57.      * @return
  58.      */
  59.     boolean saveComment(Long userId, String publishId, Integer type, String content);
  61.     /**
  62.      * 查询评论数
  63.      *
  64.      * @param publishId
  65.      * @param type
  66.      * @return
  67.      */
  68.     Long queryCommentCount(String publishId, Integer type);
  70. }

1.1.2、编写实现

  1. package com.tanhua.dubbo.server.api;
  3. import com.alibaba.dubbo.config.annotation.Service;
  4. import com.mongodb.client.result.DeleteResult;
  5. import com.tanhua.dubbo.server.pojo.*;
  6. import com.tanhua.dubbo.server.vo.PageInfo;
  7. import org.apache.commons.lang3.StringUtils;
  8. import org.bson.types.ObjectId;
  9. import org.springframework.beans.factory.annotation.Autowired;
  10. import org.springframework.data.domain.PageRequest;
  11. import org.springframework.data.domain.Sort;
  12. import org.springframework.data.mongodb.core.MongoTemplate;
  13. import org.springframework.data.mongodb.core.query.Criteria;
  14. import org.springframework.data.mongodb.core.query.Query;
  16. import java.util.ArrayList;
  17. import java.util.Date;
  18. import java.util.List;
  20. @Service(version = "1.0.0")
  21. public class QuanZiApiImpl implements QuanZiApi {
  23.     @Autowired
  24.     private MongoTemplate mongoTemplate;
  26.     /**
  27.      * 点赞
  28.      *
  29.      * @param userId
  30.      * @param publishId
  31.      */
  32.     public boolean saveLikeComment(Long userId, String publishId) {
  33.         Query query = Query.query(Criteria
  34.                 .where("publishId").is(new ObjectId(publishId))
  35.                 .and("userId").is(userId)
  36.                 .and("commentType").is(1));
  37.         long count = this.mongoTemplate.count(query, Comment.class);
  38.         if (count > 0) {
  39.             return false;
  40.         }
  41.         return this.saveComment(userId, publishId, 1, null);
  42.     }
  44.     /**
  45.      * 取消点赞、喜欢等
  46.      *
  47.      * @return
  48.      */
  49.     public boolean removeComment(Long userId, String publishId, Integer commentType) {
  50.         Query query = Query.query(Criteria
  51.                 .where("publishId").is(new ObjectId(publishId))
  52.                 .and("userId").is(userId)
  53.                 .and("commentType").is(commentType));
  54.         DeleteResult remove = this.mongoTemplate.remove(query, Comment.class);
  55.         return remove.getDeletedCount() > 0;
  56.     }
  58.     /**
  59.      * 喜欢
  60.      *
  61.      * @param userId
  62.      * @param publishId
  63.      */
  64.     public boolean saveLoveComment(Long userId, String publishId) {
  65.         Query query = Query.query(Criteria
  66.                 .where("publishId").is(new ObjectId(publishId))
  67.                 .and("userId").is(userId)
  68.                 .and("commentType").is(3));
  69.         long count = this.mongoTemplate.count(query, Comment.class);
  70.         if (count > 0) {
  71.             return false;
  72.         }
  73.         return this.saveComment(userId, publishId, 3, null);
  74.     }
  76.     /**
  77.      * 保存评论
  78.      *
  79.      * @param userId
  80.      * @param publishId
  81.      * @param type
  82.      * @return
  83.      */
  84.     public boolean saveComment(Long userId, String publishId, Integer type, String content) {
  85.         try {
  86.             Comment comment = new Comment();
  87.             comment.setId(ObjectId.get());
  88.             comment.setUserId(userId);
  89.             comment.setContent(content);
  90.             comment.setPublishId(new ObjectId(publishId));
  91.             comment.setCommentType(type);
  92.             comment.setCreated(System.currentTimeMillis());
  93.             this.mongoTemplate.save(comment);
  94.             return true;
  95.         } catch (Exception e) {
  96.             e.printStackTrace();
  97.         }
  98.         return false;
  99.     }
  101.     @Override
  102.     public Long queryCommentCount(String publishId, Integer type) {
  103.         Query query = Query.query(Criteria.where("publishId").is(new ObjectId(publishId)).and("commentType").is(type));
  104.         return this.mongoTemplate.count(query, Comment.class);
  105.     }
  106. }

1.1.3、编写接口服务

MovementsController：

  1. /**
  2.      * 点赞
  3.      *
  4.      * @param publishId
  5.      * @return
  6.      */
  7.     @GetMapping("/{id}/like")
  8.     public ResponseEntity<Long> likeComment(@PathVariable("id") String publishId) {
  9.         try {
  10.             Long likeCount = this.movementsService.likeComment(publishId);
  11.             if (likeCount != null) {
  12.                 return ResponseEntity.ok(likeCount);
  13.             }
  14.         } catch (Exception e) {
  15.             e.printStackTrace();
  16.         }
  17.         return ResponseEntity.status(HttpStatus.INTERNAL_SERVER_ERROR).build();
  18.     }
  20.     /**
  21.      * 取消点赞
  22.      *
  23.      * @param publishId
  24.      * @return
  25.      */
  26.     @GetMapping("/{id}/dislike")
  27.     public ResponseEntity<Long> disLikeComment(@PathVariable("id") String publishId) {
  28.         try {
  29.             Long likeCount = this.movementsService.cancelLikeComment(publishId);
  30.             if (null != likeCount) {
  31.                 return ResponseEntity.ok(likeCount);
  32.             }
  33.         } catch (Exception e) {
  34.             e.printStackTrace();
  35.         }
  36.         return ResponseEntity.status(HttpStatus.INTERNAL_SERVER_ERROR).build();
  37.     }

1.1.4、编写服务实现

  1. package com.tanhua.server.service;
  3. import com.alibaba.dubbo.common.utils.CollectionUtils;
  4. import com.alibaba.dubbo.config.annotation.Reference;
  5. import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
  6. import com.tanhua.dubbo.server.api.QuanZiApi;
  7. import com.tanhua.dubbo.server.pojo.Publish;
  8. import com.tanhua.dubbo.server.vo.PageInfo;
  9. import com.tanhua.server.pojo.User;
  10. import com.tanhua.server.pojo.UserInfo;
  11. import com.tanhua.server.utils.RelativeDateFormat;
  12. import com.tanhua.server.utils.UserThreadLocal;
  13. import com.tanhua.server.vo.Movements;
  14. import com.tanhua.server.vo.PageResult;
  15. import com.tanhua.server.vo.PicUploadResult;
  16. import org.apache.commons.lang3.StringUtils;
  17. import org.springframework.beans.factory.annotation.Autowired;
  18. import org.springframework.data.redis.core.RedisTemplate;
  19. import org.springframework.stereotype.Service;
  20. import org.springframework.web.multipart.MultipartFile;
  22. import java.util.ArrayList;
  23. import java.util.Date;
  24. import java.util.List;
  26. @Service
  27. public class MovementsService {
  29.     @Reference(version = "1.0.0")
  30.     private QuanZiApi quanZiApi;
  32.     @Autowired
  33.     private PicUploadService picUploadService;
  35.     @Autowired
  36.     private UserInfoService userInfoService;
  38.     @Autowired
  39.     private RedisTemplate<String, String> redisTemplate;
  41.   /**
  42.      * 点赞
  43.      *
  44.      * @param publishId
  45.      * @return
  46.      */
  47.     public Long likeComment(String publishId) {
  48.         User user = UserThreadLocal.get();
  49.         boolean bool = this.quanZiApi.saveLikeComment(user.getId(), publishId);
  50.         if (!bool) {
  51.             return null;
  52.         }
  54.         Long likeCount = 0L;
  56.         //保存点赞数到redis
  57.         String key = "QUANZI_COMMENT_LIKE_" + publishId;
  58.         if (!this.redisTemplate.hasKey(key)) {
  59.             Long count = this.quanZiApi.queryCommentCount(publishId, 1);
  60.             likeCount = count;
  61.             this.redisTemplate.opsForValue().set(key, String.valueOf(likeCount));
  62.         } else {
  63.             likeCount = this.redisTemplate.opsForValue().increment(key);
  64.         }
  66.         //记录已点赞
  67.         String userKey = "QUANZI_COMMENT_LIKE_USER_" + user.getId() + "_" + publishId;
  68.         this.redisTemplate.opsForValue().set(userKey, "1");
  70.         return likeCount;
  71.     }
  73.     /**
  74.      * 取消点赞
  75.      *
  76.      * @return
  77.      */
  78.     public Long cancelLikeComment(String publishId) {
  79.         User user = UserThreadLocal.get();
  80.         boolean bool = this.quanZiApi.removeComment(user.getId(), publishId, 1);
  81.         if (bool) {
  82.             String key = "QUANZI_COMMENT_LIKE_" + publishId;
  83.             //数量递减
  84.             Long likeCount = this.redisTemplate.opsForValue().decrement(key);
  86.             //删除已点赞
  87.             String userKey = "QUANZI_COMMENT_LIKE_USER_" + user.getId() + "_" + publishId;
  88.             this.redisTemplate.delete(userKey);
  90.             return likeCount;
  91.         }
  92.         return null;
  93.     }
  94. }

1.1.5、修改查询动态点赞数

1567998799803.png

1.1.6、测试

1567998836428.png

1.2、喜欢

1.2.1、MovementsController

  1. /**
  2.      * 喜欢
  3.      *
  4.      * @param publishId
  5.      * @return
  6.      */
  7.     @GetMapping("/{id}/love")
  8.     public ResponseEntity<Long> loveComment(@PathVariable("id") String publishId) {
  9.         try {
  10.             Long loveCount = this.movementsService.loveComment(publishId);
  11.             if (null != loveCount) {
  12.                 return ResponseEntity.ok(loveCount);
  13.             }
  14.         } catch (Exception e) {
  15.             e.printStackTrace();
  16.         }
  17.         return ResponseEntity.status(HttpStatus.INTERNAL_SERVER_ERROR).build();
  18.     }
  20.     /**
  21.      * 取消喜欢
  22.      *
  23.      * @param publishId
  24.      * @return
  25.      */
  26.     @GetMapping("/{id}/unlove")
  27.     public ResponseEntity<Long> disLoveComment(@PathVariable("id") String publishId) {
  28.         try {
  29.             Long loveCount = this.movementsService.cancelLoveComment(publishId);
  30.             if (null != loveCount) {
  31.                 return ResponseEntity.ok(loveCount);
  32.             }
  33.         } catch (Exception e) {
  34.             e.printStackTrace();
  35.         }
  36.         return ResponseEntity.status(HttpStatus.INTERNAL_SERVER_ERROR).build();
  37.     }

1.2.2、MovementsService

  1. /**
  2.      * 喜欢
  3.      *
  4.      * @param publishId
  5.      * @return
  6.      */
  7.     public Long loveComment(String publishId) {
  8.         User user = UserThreadLocal.get();
  9.         boolean bool = this.quanZiApi.saveLoveComment(user.getId(), publishId);
  10.         if (!bool) {
  11.             return null;
  12.         }
  14.         Long loveCount = 0L;
  16.         //保存喜欢数到redis
  17.         String key = "QUANZI_COMMENT_LOVE_" + publishId;
  18.         if (!this.redisTemplate.hasKey(key)) {
  19.             Long count = this.quanZiApi.queryCommentCount(publishId, 3);
  20.             loveCount = count ;
  21.             this.redisTemplate.opsForValue().set(key, String.valueOf(loveCount));
  22.         } else {
  23.             loveCount = this.redisTemplate.opsForValue().increment(key);
  24.         }
  26.         //记录已喜欢
  27.         String userKey = "QUANZI_COMMENT_LOVE_USER_" + user.getId() + "_" + publishId;
  28.         this.redisTemplate.opsForValue().set(userKey, "1");
  30.         return loveCount;
  31.     }
  33.     /**
  34.      * 取消喜欢
  35.      *
  36.      * @return
  37.      */
  38.     public Long cancelLoveComment(String publishId) {
  39.         User user = UserThreadLocal.get();
  40.         boolean bool = this.quanZiApi.removeComment(user.getId(), publishId, 3);
  41.         if (bool) {
  42.             String key = "QUANZI_COMMENT_LOVE_" + publishId;
  43.             //数量递减
  44.             Long loveCount = this.redisTemplate.opsForValue().decrement(key);
  46.             //删除已点赞
  47.             String userKey = "QUANZI_COMMENT_LOVE_USER_" + user.getId() + "_" + publishId;
  48.             this.redisTemplate.delete(userKey);
  50.             return loveCount;
  51.         }
  52.         return null;
  53.     }

1.2.3、测试

1568017597762.png
1568017579434.png

1.3、查询单条动态

1.3.1、定义dubbo接口

QuanZiApi：

  1.     /**
  2.      * 根据id查询动态
  3.      *
  4.      * @param id
  5.      * @return
  6.      */
  7.     Publish queryPublishById(String id);

1.3.2、dubbo接口实现

QuanZiApiImpl：

  1.     @Override
  2.     public Publish queryPublishById(String id) {
  3.         return this.mongoTemplate.findById(new ObjectId(id), Publish.class);
  4.     }

1.3.3、定义服务接口

  1.     /**
  2.      * 查询单条动态信息
  3.      *
  4.      * @param publishId
  5.      * @return
  6.      */
  7.     @GetMapping("/{id}")
  8.     public ResponseEntity<Movements> queryById(@PathVariable("id") String publishId) {
  9.         try {
  10.             Movements movements = this.movementsService.queryById(publishId);
  11.             if(null != movements){
  12.                 return ResponseEntity.ok(movements);
  13.             }
  14.         } catch (Exception e) {
  15.             e.printStackTrace();
  16.         }
  17.         return ResponseEntity.status(HttpStatus.INTERNAL_SERVER_ERROR).build();
  18.     }

1.3.4、服务实现

  1.     public Movements queryById(String publishId) {
  2.         Publish publish = this.quanZiApi.queryPublishById(publishId);
  3.         if (null == publish) {
  4.             return null;
  5.         }
  7.         Movements movements = new Movements();
  9.         movements.setId(publish.getId().toHexString());
  10.         movements.setImageContent(publish.getMedias().toArray(new String[]{}));
  11.         movements.setTextContent(publish.getText());
  12.         movements.setUserId(publish.getUserId());
  13.         movements.setCreateDate(RelativeDateFormat.format(new Date(publish.getCreated())));
  15.         UserInfo userInfo = this.userInfoService.queryById(publish.getUserId());
  16.         if (null == userInfo) {
  17.             return null;
  18.         }
  19.         this.fillValueToMovements(movements, userInfo);
  21.         return movements;
  23.     }
  25.     private void fillValueToMovements(Movements movements, UserInfo userInfo) {
  26.         User user = UserThreadLocal.get();
  27.         movements.setAge(userInfo.getAge());
  28.         movements.setAvatar(userInfo.getLogo());
  29.         movements.setGender(userInfo.getSex().name().toLowerCase());
  30.         movements.setNickname(userInfo.getNickName());
  31.         movements.setTags(StringUtils.split(userInfo.getTags(), ','));
  33.         Long commentCount = this.quanZiApi.queryCommentCount(movements.getId(), 2);
  34.         if(null == commentCount){
  35.             movements.setCommentCount(0); //评论数
  36.         }else{
  37.             movements.setCommentCount(commentCount.intValue()); //评论数
  38.         }
  40.         movements.setDistance("1.2公里"); //TODO 距离
  42.         String userKey = "QUANZI_COMMENT_LIKE_USER_" + user.getId() + "_" + movements.getId();
  43.         movements.setHasLiked(this.redisTemplate.hasKey(userKey) ? 1 : 0); //是否点赞（1是，0否）
  45.         String key = "QUANZI_COMMENT_LIKE_" + movements.getId();
  46.         String value = this.redisTemplate.opsForValue().get(key);
  47.         if (StringUtils.isNotEmpty(value)) {
  48.             movements.setLikeCount(Integer.valueOf(value)); //点赞数
  49.         } else {
  50.             movements.setLikeCount(0);
  51.         }
  53.         String userLoveKey = "QUANZI_COMMENT_LOVE_USER_" + user.getId() + "_" + movements.getId();
  54.         movements.setHasLoved(this.redisTemplate.hasKey(userLoveKey) ? 1 : 0); //是否喜欢（1是，0否）
  56.         key = "QUANZI_COMMENT_LOVE_" + movements.getId();
  57.         value = this.redisTemplate.opsForValue().get(key);
  58.         if (StringUtils.isNotEmpty(value)) {
  59.             movements.setLoveCount(Integer.valueOf(value)); //喜欢数
  60.         } else {
  61.             movements.setLoveCount(0);
  62.         }
  63.     }

1.3.5、测试

1568119813872.png
1568119828421.png

1.4、单条动态评论

功能包括：查询评论列表，评论点赞、取消点赞。

1.4.1、定义dubbo接口

  1.     /**
  2.      *  查询单条动态的所有评论
  3.      * @param publishId 动态id
  4.      * @param page 当前页数
  5.      * @param pageSize 每夜显示的条数
  6.      * @return 评论数据
  7.      */
  8.     PageInfo<Comment> queryCommentList(String publishId, Integer page, Integer pageSize);

1.4.2、编写实现

  1.     @Override
  2.     public PageInfo<Comment> queryCommentList(String publishId, Integer page, Integer pageSize) {
  3.         PageRequest pageRequest = PageRequest.of(page - 1, pageSize, Sort.by(Sort.Order.asc("created")));
  4.         Query query = new Query(Criteria
  5.                 .where("publishId").is(new ObjectId(publishId))
  6.                 .and("commentType").is(2)).with(pageRequest);
  8.         //查询时间线表
  9.         List<Comment> timeLineList = this.mongoTemplate.find(query, Comment.class);
  11.         PageInfo<Comment> pageInfo = new PageInfo<>();
  12.         pageInfo.setPageNum(page);
  13.         pageInfo.setPageSize(pageSize);
  14.         pageInfo.setRecords(timeLineList);
  15.         pageInfo.setTotal(0); //不提供总数
  16.         return pageInfo;
  17.     }

1.4.3、服务接口实现

  1. package com.tanhua.server.vo;
  3. import lombok.AllArgsConstructor;
  4. import lombok.Data;
  5. import lombok.NoArgsConstructor;
  7. /**
  8.  * 封装评论的类
  9.  */
  10. @Data
  11. @NoArgsConstructor
  12. @AllArgsConstructor
  13. public class Comments {
  15.     private String id; //评论id
  16.     private String avatar; //头像
  17.     private String nickname; //昵称
  18.     private String content; //评论
  19.     private String createDate; //评论时间: 08:27
  20.     private Integer likeCount; //评论的点赞数
  21.     private Integer hasLiked; //是否点赞（1是，0否）
  23. }
  1. package com.tanhua.server.controller;
  3. import com.tanhua.server.service.CommentsService;
  4. import com.tanhua.server.service.MovementsService;
  5. import com.tanhua.server.vo.Comments;
  6. import com.tanhua.server.vo.PageResult;
  7. import org.springframework.beans.factory.annotation.Autowired;
  8. import org.springframework.http.HttpStatus;
  9. import org.springframework.http.ResponseEntity;
  10. import org.springframework.web.bind.annotation.*;
  12. import java.util.Map;
  14. @RestController
  15. @RequestMapping("comments")
  16. public class CommentsController {
  18.     @Autowired
  19.     private CommentsService commentsService;
  21.     @Autowired
  22.     private MovementsService movementsService;
  24.     /**
  25.      * 查询评论列表
  26.      *
  27.      * @param publishId
  28.      * @param page
  29.      * @param pagesize
  30.      * @return
  31.      */
  32.     @GetMapping
  33.     public ResponseEntity<PageResult> queryCommentsList(@RequestParam("movementId") String publishId,
  34.                                                         @RequestParam(value = "page", defaultValue = "1") Integer page,
  35.                                                         @RequestParam(value = "pagesize", defaultValue = "10") Integer pagesize) {
  36.         try {
  37.             PageResult pageResult = this.commentsService.queryCommentsList(publishId, page, pagesize);
  38.             return ResponseEntity.ok(pageResult);
  39.         } catch (Exception e) {
  40.             e.printStackTrace();
  41.         }
  42.         return ResponseEntity.status(HttpStatus.INTERNAL_SERVER_ERROR).build();
  44.     }
  46.     /**
  47.      * 保存评论
  48.      */
  49.     @PostMapping
  50.     public ResponseEntity<Void> saveComments(@RequestBody Map<String,String> param) {
  51.         try {
  52.             String publishId = param.get("movementId");
  53.             String content = param.get("comment");
  54.             Boolean result = this.commentsService.saveComments(publishId, content);
  55.             if (result) {
  56.                 return ResponseEntity.ok(null);
  57.             }
  58.         } catch (Exception e) {
  59.             e.printStackTrace();
  60.         }
  61.         return ResponseEntity.status(HttpStatus.INTERNAL_SERVER_ERROR).build();
  62.     }
  64.     /**
  65.      * 点赞
  66.      *
  67.      * @param publishId
  68.      * @return
  69.      */
  70.     @GetMapping("/{id}/like")
  71.     public ResponseEntity<Long> likeComment(@PathVariable("id") String publishId) {
  72.         try {
  73.             Long likeCount = this.movementsService.likeComment(publishId);
  74.             if (likeCount != null) {
  75.                 return ResponseEntity.ok(likeCount);
  76.             }
  77.         } catch (Exception e) {
  78.             e.printStackTrace();
  79.         }
  80.         return ResponseEntity.status(HttpStatus.INTERNAL_SERVER_ERROR).build();
  81.     }
  83.     /**
  84.      * 取消点赞
  85.      *
  86.      * @param publishId
  87.      * @return
  88.      */
  89.     @GetMapping("/{id}/dislike")
  90.     public ResponseEntity<Long> disLikeComment(@PathVariable("id") String publishId) {
  91.         try {
  92.             Long likeCount = this.movementsService.cancelLikeComment(publishId);
  93.             if (null != likeCount) {
  94.                 return ResponseEntity.ok(likeCount);
  95.             }
  96.         } catch (Exception e) {
  97.             e.printStackTrace();
  98.         }
  99.         return ResponseEntity.status(HttpStatus.INTERNAL_SERVER_ERROR).build();
  100.     }
  102. }
  1. package com.tanhua.server.service;
  3. import com.alibaba.dubbo.config.annotation.Reference;
  4. import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
  5. import com.tanhua.dubbo.server.api.QuanZiApi;
  6. import com.tanhua.dubbo.server.pojo.Comment;
  7. import com.tanhua.dubbo.server.vo.PageInfo;
  8. import com.tanhua.server.pojo.User;
  9. import com.tanhua.server.pojo.UserInfo;
  10. import com.tanhua.server.utils.UserThreadLocal;
  11. import com.tanhua.server.vo.Comments;
  12. import com.tanhua.server.vo.PageResult;
  13. import org.apache.commons.lang3.StringUtils;
  14. import org.joda.time.DateTime;
  15. import org.springframework.beans.factory.annotation.Autowired;
  16. import org.springframework.data.redis.core.RedisTemplate;
  17. import org.springframework.stereotype.Service;
  19. import java.util.ArrayList;
  20. import java.util.List;
  22. @Service
  23. public class CommentsService {
  25.     @Reference(version = "1.0.0")
  26.     private QuanZiApi quanZiApi;
  28.     @Autowired
  29.     private UserInfoService userInfoService;
  31.     @Autowired
  32.     private RedisTemplate<String, String> redisTemplate;
  34.     public PageResult queryCommentsList(String publishId, Integer page, Integer pagesize) {
  36.         User user = UserThreadLocal.get();
  38.         PageInfo<Comment> pageInfo = this.quanZiApi.queryCommentList(publishId, page, pagesize);
  40.         List<Comment> records = pageInfo.getRecords();
  42.         if (records.isEmpty()) {
  43.             PageResult pageResult = new PageResult();
  44.             pageResult.setPage(page);
  45.             pageResult.setPagesize(pagesize);
  46.             pageResult.setPages(0);
  47.             pageResult.setCounts(0);
  48.             return pageResult;
  49.         }
  51.         List<Long> userIds = new ArrayList<>();
  52.         for (Comment comment : records) {
  53.             if (!userIds.contains(comment.getUserId())) {
  54.                 userIds.add(comment.getUserId());
  55.             }
  57.         }
  59.         QueryWrapper<UserInfo> queryWrapper = new QueryWrapper<>();
  60.         queryWrapper.in("user_id", userIds);
  61.         List<UserInfo> userInfos = this.userInfoService.queryList(queryWrapper);
  63.         List<Comments> result = new ArrayList<>();
  64.         for (Comment record : records) {
  65.             Comments comments = new Comments();
  66.             comments.setContent(record.getContent());
  67.             comments.setCreateDate(new DateTime(record.getCreated()).toString("yyyy年MM月dd日 HH:mm"));
  68.             comments.setId(record.getId().toHexString());
  70.             for (UserInfo userInfo : userInfos) {
  71.                 if (record.getUserId().longValue() == userInfo.getUserId().longValue()) {
  72.                     comments.setAvatar(userInfo.getLogo());
  73.                     comments.setNickname(userInfo.getNickName());
  74.                     break;
  75.                 }
  76.             }
  78.             String key = "QUANZI_COMMENT_LIKE_" + comments.getId();
  79.             String value = this.redisTemplate.opsForValue().get(key);
  80.             if (StringUtils.isNotEmpty(value)) {
  81.                 comments.setLikeCount(Integer.valueOf(value)); //点赞数
  82.             } else {
  83.                 comments.setLikeCount(0);
  84.             }
  86.             String userKey = "QUANZI_COMMENT_LIKE_USER_" + user.getId() + "_" + comments.getId();
  87.             comments.setHasLiked(this.redisTemplate.hasKey(userKey) ? 1 : 0); //是否点赞（1是，0否）
  89.             result.add(comments);
  90.         }
  92.         PageResult pageResult = new PageResult();
  93.         pageResult.setItems(result);
  94.         pageResult.setPage(page);
  95.         pageResult.setPagesize(pagesize);
  96.         pageResult.setPages(0);
  97.         pageResult.setCounts(0);
  99.         return pageResult;
  102.     }
  104.     /**
  105.      * 保存评论
  106.      *
  107.      * @param publishId
  108.      * @param content
  109.      * @return
  110.      */
  111.     public Boolean saveComments(String publishId, String content) {
  112.         User user = UserThreadLocal.get();
  113.         return this.quanZiApi.saveComment(user.getId(), publishId, 2, content);
  114.     }
  115. }

1.4.4、测试

1568209335129.png
1568209381544.png

2、小视频功能说明

小视频功能类似于抖音、快手小视频的应用，用户可以上传小视频进行分享，也可以浏览查看别人分享的视频，并且可以对视频评论和点赞操作。

效果：
1568878011614.png

查看详情：
1568878327076.png

评论：
1568878353854.png

点赞：
1568878397710.png

3、技术方案

对于小视频的功能的开发，核心点就是：存储 + 推荐 + 加载速度 。

  • 对于存储而言，小视频的存储量以及容量都是非常巨大的
    • 所以我们选择自己搭建分布式存储系统 FastDFS进行存储
  • 对于推荐算法，我们将采用多种权重的计算方式进行计算
  • 对于加载速度，除了提升服务器带宽外可以通过CDN的方式进行加速，当然了这需要额外购买CDN服务

3.1、FastDFS

3.1.1、FastDFS是什么？

FastDFS是分布式文件系统。使用 FastDFS很容易搭建一套高性能的文件服务器集群提供文件上传、下载等服务。

3.1.2、工作原理

FastDFS 架构包括 Tracker server 和 Storage server。客户端请求 Tracker server 进行文件上传、下载，通过 Tracker server 调度最终由 Storage server 完成文件上传和下载。

Tracker server 作用是负载均衡和调度，通过 Tracker server 在文件上传时可以根据一些策略找到 Storage server 提供文件上传服务。可以将 tracker 称为追踪服务器或调度服务器。

Storage server 作用是文件存储，客户端上传的文件最终存储在 Storage 服务器上，Storage server 没有实现自己的文件系统而是利用操作系统的文件系统来管理文件。可以将storage称为存储服务器。
6bd41a6af1fef5cc89dda7c94208c6a64f3.png

每个 tracker 节点地位平等。收集 Storage 集群的状态。

Storage 分为多个组，每个组之间保存的文件是不同的。每个组内部可以有多个成员，组成员内部保存的内容是一样的，组成员的地位是一致的，没有主从的概念。

3.1.3、文件的上传

1746338-20190925190927228-1815093216.png

客户端上传文件后存储服务器将文件 ID 返回给客户端，此文件 ID 用于以后访问该文件的索引信息。文件索引信息包括：组名，虚拟磁盘路径，数据两级目录，文件名。

3.1.4、文件的下载

b3d48e8fd6255834f2445e0b956390455a4.png

客户端下载请求到Tracker服务，Tracker返回给客户端storage的信息，客户端根据这些信息进行请求storage获取到文件。

4、FastDFS环境搭建

4.1、搭建服务

我们使用docker进行搭建。

  1. #拉取镜像
  2. docker pull delron/fastdfs
  4. #创建tracker容器
  5. docker create --network=host --name tracker --restart=always -v fdfs-tracker:/var/fdfs delron/fastdfs tracker
  6. #启动容器
  7. docker start tracker
  9. #创建storage容器
  10. docker create --network=host --name storage --restart=always -e TRACKER_SERVER=192.168.31.81:22122 -v fdfs-storage:/var/fdfs -e GROUP_NAME=group1 delron/fastdfs storage
  12. #启动容器
  13. docker start storage
  15. #进入storage容器，到storage的配置文件中配置http访问的端口，配置文件在/etc/fdfs目录下的storage.conf。
  16. docker exec -it storage /bin/bash
  18. #默认的http端口为8888，可以修改也可以配置
  19. # the port of the web server on this storage server
  20. http.server_port=8888
  22. #配置nginx，在/usr/local/nginx目录下，修改nginx.conf文件
  23. #默认配置如下：
  25.     server {
  26.         listen       8888;
  27.         server_name  localhost;
  28.         location ~/group[0-9]/ {
  29.             ngx_fastdfs_module;
  30.         }
  31.         error_page   500 502 503 504  /50x.html;
  32.         location = /50x.html {
  33.             root html;
  34.         }
  35.     }
  37. #默认的存储路径为/var/fdfs/data

1568942782857.png

4.2、java client

导入依赖：导在my-tanhua-server项目中

  1. <dependency>
  2.     <groupId>com.github.tobato</groupId>
  3.     <artifactId>fastdfs-client</artifactId>
  4.     <version>1.26.7</version>
  5.     <exclusions>
  6.         <exclusion>
  7.             <groupId>ch.qos.logback</groupId>
  8.             <artifactId>logback-classic</artifactId>
  9.         </exclusion>
  10.     </exclusions>
  11. </dependency>

4.2.1、application.properties

  1. # ===================================================================
  2. # 分布式文件系统FDFS配置
  3. # ===================================================================
  4. fdfs.so-timeout = 1501
  5. fdfs.connect-timeout = 601
  6. #缩略图生成参数
  7. fdfs.thumb-image.width= 150
  8. fdfs.thumb-image.height= 150
  9. #TrackerList参数,支持多个
  10. fdfs.tracker-list=192.168.31.81:22122
  11. #访问路径
  12. fdfs.web-server-url=http://192.168.31.81:8888/

4.2.2、测试

  1. package com.tanhua.server;
  3. import com.github.tobato.fastdfs.domain.fdfs.StorePath;
  4. import com.github.tobato.fastdfs.service.FastFileStorageClient;
  5. import org.apache.commons.io.FileUtils;
  6. import org.junit.Test;
  7. import org.junit.runner.RunWith;
  8. import org.springframework.beans.factory.annotation.Autowired;
  9. import org.springframework.boot.test.context.SpringBootTest;
  10. import org.springframework.test.context.junit4.SpringRunner;
  12. import java.io.File;
  13. import java.io.IOException;
  15. @RunWith(SpringRunner.class)
  16. @SpringBootTest
  17. public class TestFastDFS {
  19.     @Autowired
  20.     protected FastFileStorageClient storageClient;
  22.     @Test
  23.     public void testUpload(){
  24.         String path = "C:\\Users\\zhijun\\Desktop\\pics\\1.jpg";
  25.         File file = new File(path);
  27.         try {
  28.             StorePath storePath = this.storageClient.uploadFile(FileUtils.openInputStream(file), file.length(), "jpg", null);
  30.             System.out.println(storePath); //StorePath [group=group1, path=M00/00/00/wKgfUV2GJSuAOUd_AAHnjh7KpOc1.1.jpg]
  31.             System.out.println(storePath.getFullPath());//group1/M00/00/00/wKgfUV2GJSuAOUd_AAHnjh7KpOc1.1.jpg
  32.         } catch (IOException e) {
  33.             e.printStackTrace();
  34.         }
  35.     }
  36. }

5、发布小视频

5.1、编写pojo

在dubbo接口工程中编写pojo：

  1. package com.tanhua.dubbo.server.pojo;
  3. import lombok.AllArgsConstructor;
  4. import lombok.Data;
  5. import lombok.NoArgsConstructor;
  6. import org.bson.types.ObjectId;
  7. import org.springframework.data.mongodb.core.mapping.Document;
  9. import java.util.List;
  11. @Data
  12. @NoArgsConstructor
  13. @AllArgsConstructor
  14. @Document(collection = "video")
  15. public class Video implements java.io.Serializable {
  17.     private static final long serialVersionUID = -3136732836884933873L;
  19.     private ObjectId id; //主键id
  20.     private Long userId;
  21.     private String text; //文字
  22.     private String picUrl; //视频封面文件
  23.     private String videoUrl; //视频文件
  24.     private Long created; //创建时间
  25.     private Integer seeType; // 谁可以看，1-公开，2-私密，3-部分可见，4-不给谁看
  26.     private List<Long> seeList; //部分可见的列表
  27.     private List<Long> notSeeList; //不给谁看的列表
  28.     private String longitude; //经度
  29.     private String latitude; //纬度
  30.     private String locationName; //位置名称
  31. }

5.2、定义接口

  1. package com.tanhua.dubbo.server.api;
  3. import com.tanhua.dubbo.server.pojo.Video;
  5. public interface VideoApi {
  7.     /**
  8.      * 保存小视频
  9.      *
  10.      * @param video
  11.      * @return
  12.      */
  13.     Boolean saveVideo(Video video);
  15. }

5.3、实现

  1. package com.tanhua.dubbo.server.api;
  3. import com.alibaba.dubbo.config.annotation.Service;
  4. import com.tanhua.dubbo.server.pojo.Video;
  5. import org.bson.types.ObjectId;
  6. import org.springframework.beans.factory.annotation.Autowired;
  7. import org.springframework.data.mongodb.core.MongoTemplate;
  9. @Service(version = "1.0.0")
  10. public class VideoApiImpl implements VideoApi {
  12.     @Autowired
  13.     private MongoTemplate mongoTemplate;
  15.     @Override
  16.     public Boolean saveVideo(Video video) {
  17.         if(video.getUserId() == null){
  18.             return false;
  19.         }
  21.         video.setId(ObjectId.get());
  22.         video.setCreated(System.currentTimeMillis());
  24.         this.mongoTemplate.save(video);
  25.         return true;
  26.     }
  27. }

5.4、接口服务

1569074668308.png

5.4.1、VideoController

  1. package com.tanhua.server.controller;
  3. import com.tanhua.server.service.VideoService;
  4. import org.springframework.beans.factory.annotation.Autowired;
  5. import org.springframework.http.HttpStatus;
  6. import org.springframework.http.ResponseEntity;
  7. import org.springframework.web.bind.annotation.PostMapping;
  8. import org.springframework.web.bind.annotation.RequestMapping;
  9. import org.springframework.web.bind.annotation.RequestParam;
  10. import org.springframework.web.bind.annotation.RestController;
  11. import org.springframework.web.multipart.MultipartFile;
  13. @RestController
  14. @RequestMapping("smallVideos")
  15. public class VideoController {
  17.     @Autowired
  18.     private VideoService videoService;
  20.     @PostMapping
  21.     public ResponseEntity<Void> saveVideo(@RequestParam(value = "videoThumbnail", required = false) MultipartFile picFile,
  22.                                           @RequestParam(value = "videoFile", required = false) MultipartFile videoFile) {
  23.         try {
  24.             Boolean bool = this.videoService.saveVideo(picFile, videoFile);
  25.             if(bool){
  26.                 return ResponseEntity.ok(null);
  27.             }
  28.         } catch (Exception e) {
  29.             e.printStackTrace();
  30.         }
  31.         return ResponseEntity.status(HttpStatus.INTERNAL_SERVER_ERROR).build();
  32.     }
  33. }

5.4.2、VideoService

  1. package com.tanhua.server.service;
  3. import com.alibaba.dubbo.config.annotation.Reference;
  4. import com.github.tobato.fastdfs.domain.conn.FdfsWebServer;
  5. import com.github.tobato.fastdfs.domain.fdfs.StorePath;
  6. import com.github.tobato.fastdfs.service.FastFileStorageClient;
  7. import com.tanhua.dubbo.server.api.VideoApi;
  8. import com.tanhua.dubbo.server.pojo.Video;
  9. import com.tanhua.server.pojo.User;
  10. import com.tanhua.server.utils.UserThreadLocal;
  11. import com.tanhua.server.vo.PicUploadResult;
  12. import org.apache.commons.lang3.StringUtils;
  13. import org.springframework.beans.factory.annotation.Autowired;
  14. import org.springframework.stereotype.Service;
  15. import org.springframework.web.multipart.MultipartFile;
  17. @Service
  18. public class VideoService {
  20.     @Autowired
  21.     private PicUploadService picUploadService;
  23.     @Autowired
  24.     protected FastFileStorageClient storageClient;
  26.     @Autowired
  27.     private FdfsWebServer fdfsWebServer;
  29.     @Reference(version = "1.0.0")
  30.     private VideoApi videoApi;
  32.     public Boolean saveVideo(MultipartFile picFile, MultipartFile videoFile) {
  33.         User user = UserThreadLocal.get();
  34.         Video video = new Video();
  35.         video.setUserId(user.getId());
  36.         video.setSeeType(1);
  37.         try {
  38.             //上传封面图片
  39.             PicUploadResult picUploadResult = this.picUploadService.upload(picFile);
  40.             video.setPicUrl(picUploadResult.getName()); //图片路径
  42.             //上传视频
  43.             StorePath storePath = storageClient.uploadFile(videoFile.getInputStream(),
  44.                     videoFile.getSize(),
  45.                     StringUtils.substringAfter(videoFile.getOriginalFilename(), "."),
  46.                     null);
  47.             video.setVideoUrl(fdfsWebServer.getWebServerUrl() + "/" + storePath.getFullPath());
  49.             this.videoApi.saveVideo(video);
  51.             return true;
  52.         } catch (Exception e) {
  53.             e.printStackTrace();
  54.         }
  56.         return false;
  57.     }
  58. }

5.4.3、测试

如果上传视频，会导致异常，是因为请求太大的缘故：
1569075180126.png

解决：application.properties

  1. spring.servlet.multipart.max-file-size=30MB
  2. spring.servlet.multipart.max-request-size=30MB

问题解决：
1569075257357.png

6、小视频列表

6.1、定义dubbo服务

  1. package com.tanhua.dubbo.server.api;
  3. import com.tanhua.dubbo.server.pojo.Video;
  4. import com.tanhua.dubbo.server.vo.PageInfo;
  6. public interface VideoApi {
  8.     /**
  9.      * 保存小视频
  10.      *
  11.      * @param video
  12.      * @return
  13.      */
  14.     Boolean saveVideo(Video video);
  16.     /**
  17.      * 分页查询小视频列表，按照时间倒序排序
  18.      *
  19.      * @param page
  20.      * @param pageSize
  21.      * @return
  22.      */
  23.     PageInfo<Video> queryVideoList(Integer page, Integer pageSize);
  25. }

6.2、实现dubbo服务

  1. package com.tanhua.dubbo.server.api;
  3. import com.alibaba.dubbo.config.annotation.Service;
  4. import com.tanhua.dubbo.server.pojo.Video;
  5. import com.tanhua.dubbo.server.vo.PageInfo;
  6. import org.bson.types.ObjectId;
  7. import org.springframework.beans.factory.annotation.Autowired;
  8. import org.springframework.data.domain.PageRequest;
  9. import org.springframework.data.domain.Pageable;
  10. import org.springframework.data.domain.Sort;
  11. import org.springframework.data.mongodb.core.MongoTemplate;
  12. import org.springframework.data.mongodb.core.query.Query;
  14. import java.util.List;
  16. @Service(version = "1.0.0")
  17. public class VideoApiImpl implements VideoApi {
  19.     @Autowired
  20.     private MongoTemplate mongoTemplate;
  22.     @Override
  23.     public Boolean saveVideo(Video video) {
  24.         if (video.getUserId() == null) {
  25.             return false;
  26.         }
  28.         video.setId(ObjectId.get());
  29.         video.setCreated(System.currentTimeMillis());
  31.         this.mongoTemplate.save(video);
  32.         return null;
  33.     }
  35.     @Override
  36.     public PageInfo<Video> queryVideoList(Integer page, Integer pageSize) {
  37.         Pageable pageable = PageRequest.of(page - 1, pageSize, Sort.by(Sort.Order.desc("created")));
  38.         Query query = new Query().with(pageable);
  39.         List<Video> videos = this.mongoTemplate.find(query, Video.class);
  40.         PageInfo<Video> pageInfo = new PageInfo<>();
  41.         pageInfo.setRecords(videos);
  42.         pageInfo.setPageNum(page);
  43.         pageInfo.setPageSize(pageSize);
  44.         pageInfo.setTotal(0); //不提供总数
  45.         return pageInfo;
  46.     }
  47. }

6.3、定义VideoVo

  1. package com.tanhua.server.vo;
  3. import lombok.AllArgsConstructor;
  4. import lombok.Data;
  5. import lombok.NoArgsConstructor;
  7. @Data
  8. @NoArgsConstructor
  9. @AllArgsConstructor
  10. public class VideoVo {
  12.     private String id;
  13.     private Long userId;
  14.     private String avatar; //头像
  15.     private String nickname; //昵称
  16.     private String cover; //封面
  17.     private String videoUrl; //视频URL
  18.     private String signature; //签名
  19.     private Integer likeCount; //点赞数量
  20.     private Integer hasLiked; //是否已赞（1是，0否）
  21.     private Integer hasFocus; //是是否关注 （1是，0否）
  22.     private Integer commentCount; //评论数量
  23. }

6.4、VideoController

  1. @RestController
  2. @RequestMapping("smallVideos")
  3. public class VideoController {    
  4. /**
  5.      * 查询小视频列表
  6.      *
  7.      * @param page
  8.      * @param pageSize
  9.      * @return
  10.      */
  11.     @GetMapping
  12.     public ResponseEntity<PageResult> queryVideoList(@RequestParam(value = "page", defaultValue = "1") Integer page,
  13.                                                      @RequestParam(value = "pagesize", defaultValue = "10") Integer pageSize) {
  14.         try {
  15.             if (page <= 0) {
  16.                 page = 1;
  17.             }
  18.             PageResult pageResult = this.videoService.queryVideoList(page, pageSize);
  19.             if (null != pageResult) {
  20.                 return ResponseEntity.ok(pageResult);
  21.             }
  22.         } catch (Exception e) {
  23.             e.printStackTrace();
  24.         }
  25.         return ResponseEntity.status(HttpStatus.INTERNAL_SERVER_ERROR).build();
  26.     }
  27. }

6.5、VideoService

  1. public PageResult queryVideoList(Integer page, Integer pageSize) {
  3.         User user = UserThreadLocal.get();
  5.         PageResult pageResult = new PageResult();
  6.         pageResult.setPage(page);
  7.         pageResult.setPagesize(pageSize);
  8.         pageResult.setPages(0);
  9.         pageResult.setCounts(0);
  11.         PageInfo<Video> pageInfo = this.videoApi.queryVideoList(page, pageSize);
  12.         List<Video> records = pageInfo.getRecords();
  13.         List<VideoVo> videoVoList = new ArrayList<>();
  14.         List<Long> userIds = new ArrayList<>();
  15.         for (Video record : records) {
  16.             VideoVo videoVo = new VideoVo();
  18.             videoVo.setUserId(record.getUserId());
  19.             videoVo.setCover(record.getPicUrl());
  20.             videoVo.setVideoUrl(record.getVideoUrl());
  21.             videoVo.setId(record.getId().toHexString());
  22.             videoVo.setSignature("我就是我~");
  24.             Long commentCount = this.quanZiApi.queryCommentCount(videoVo.getId(), 2);
  25.             videoVo.setCommentCount(commentCount == null ? 0 : commentCount.intValue()); // 评论数
  27.             String followUserKey = "VIDEO_FOLLOW_USER_" + user.getId() + "_" + videoVo.getUserId();
  28.             videoVo.setHasFocus(this.redisTemplate.hasKey(followUserKey) ? 1 : 0); //是否关注
  30.             String userKey = "QUANZI_COMMENT_LIKE_USER_" + user.getId() + "_" + videoVo.getId();
  31.             videoVo.setHasLiked(this.redisTemplate.hasKey(userKey) ? 1 : 0); //是否点赞（1是，0否）
  33.             String key = "QUANZI_COMMENT_LIKE_" + videoVo.getId();
  34.             String value = this.redisTemplate.opsForValue().get(key);
  35.             if (StringUtils.isNotEmpty(value)) {
  36.                 videoVo.setLikeCount(Integer.valueOf(value)); //点赞数
  37.             } else {
  38.                 videoVo.setLikeCount(0);
  39.             }
  41.             if (!userIds.contains(record.getUserId())) {
  42.                 userIds.add(record.getUserId());
  43.             }
  45.             videoVoList.add(videoVo);
  46.         }
  48.         QueryWrapper<UserInfo> queryWrapper = new QueryWrapper();
  49.         queryWrapper.in("user_id", userIds);
  50.         List<UserInfo> userInfos = this.userInfoService.queryList(queryWrapper);
  51.         for (VideoVo videoVo : videoVoList) {
  52.             for (UserInfo userInfo : userInfos) {
  53.                 if (videoVo.getUserId().longValue() == userInfo.getUserId().longValue()) {
  55.                     videoVo.setNickname(userInfo.getNickName());
  56.                     videoVo.setAvatar(userInfo.getLogo());
  58.                     break;
  59.                 }
  60.             }
  62.         }
  64.         pageResult.setItems(videoVoList);
  65.         return pageResult;
  66.     }

6.6、测试

day05-圈子、小视频功能实现 - 图20

day05-圈子、小视频功能实现 - 图21

7、视频点赞

点赞逻辑与之前的圈子点赞一样，所以实现也是一样的。

mock地址：https://mock.boxuegu.com/project/164/interface/api/77987

day05-圈子、小视频功能实现 - 图22

VideoController：

  1.     /**
  2.      * 视频点赞
  3.      *
  4.      * @param videoId 视频id
  5.      * @return
  6.      */
  7.     @PostMapping("/{id}/like")
  8.     public ResponseEntity<Long> likeComment(@PathVariable("id") String videoId) {
  9.         return this.movementsController.likeComment(videoId);
  10.     }
  12.     /**
  13.      * 取消点赞
  14.      *
  15.      * @param videoId
  16.      * @return
  17.      */
  18.     @PostMapping("/{id}/dislike")
  19.     public ResponseEntity<Long> disLikeComment(@PathVariable("id") String videoId) {
  20.         return this.movementsController.disLikeComment(videoId);
  21.     }

8、小视频评论

小视频的评论与圈子的评论逻辑类似，所以也可以使用同一套逻辑进行实现。

8.1、评论列表

mock地址：https://mock.boxuegu.com/project/164/interface/api/72177

  1.     /**
  2.      * 评论列表
  3.      */
  4.     @GetMapping("/{id}/comments")
  5.     public ResponseEntity<PageResult> queryCommentsList(@PathVariable("id") String videoId,
  6.                                                         @RequestParam(value = "page", defaultValue = "1") Integer page,
  7.                                                         @RequestParam(value = "pagesize", defaultValue = "10") Integer pagesize) {
  8.         return this.commentsController.queryCommentsList(videoId, page, pagesize);
  9.     }

8.2、发布评论

mock地址：https://mock.boxuegu.com/project/164/interface/api/72919

  1.     /**
  2.      * 提交评论
  3.      *
  4.      * @param param
  5.      * @param videoId
  6.      * @return
  7.      */
  8.     @PostMapping("/{id}/comments")
  9.     public ResponseEntity<Void> saveComments(@RequestBody Map<String, String> param,
  10.                                              @PathVariable("id") String videoId) {
  11.         param.put("movementId", videoId);
  12.         return this.commentsController.saveComments(param);
  13.     }

8.3、评论点赞

mock地址：https://mock.boxuegu.com/project/164/interface/api/75306

  1.     /**
  2.      * 评论点赞
  3.      *
  4.      * @param publishId
  5.      * @return
  6.      */
  7.     @PostMapping("/comments/{id}/like")
  8.     public ResponseEntity<Long> commentsLikeComment(@PathVariable("id") String publishId) {
  9.         return this.movementsController.likeComment(publishId);
  10.     }
  12.     /**
  13.      * 评论取消点赞
  14.      *
  15.      * @param publishId
  16.      * @return
  17.      */
  18.     @PostMapping("/comments/{id}/dislike")
  19.     public ResponseEntity<Long> disCommentsLikeComment(@PathVariable("id") String publishId) {
  20.         return this.movementsController.disLikeComment(publishId);
  21.     }

8.4、关注用户

关注用户是关注小视频发布的作者，这样我们后面计算推荐时，关注的用户将权重更重一些。

8.4.1、定义dubbo服务

  1. package com.tanhua.dubbo.server.pojo;
  3. import lombok.AllArgsConstructor;
  4. import lombok.Data;
  5. import lombok.NoArgsConstructor;
  6. import org.bson.types.ObjectId;
  7. import org.springframework.data.mongodb.core.mapping.Document;
  9. @Data
  10. @NoArgsConstructor
  11. @AllArgsConstructor
  12. @Document(collection = "follow_user")
  13. public class FollowUser implements java.io.Serializable{
  15.     private static final long serialVersionUID = 3148619072405056052L;
  17.     private ObjectId id; //主键id
  18.     private Long userId; //用户id
  19.     private Long followUserId; //关注的用户id
  20.     private Long created; //关注时间
  21. }
  1. package com.tanhua.dubbo.server.api;
  3. import com.tanhua.dubbo.server.pojo.Video;
  4. import com.tanhua.dubbo.server.vo.PageInfo;
  6. public interface VideoApi {
  8.     /**
  9.      * 保存小视频
  10.      *
  11.      * @param video
  12.      * @return
  13.      */
  14.     Boolean saveVideo(Video video);
  16.     /**
  17.      * 分页查询小视频列表，按照时间倒序排序
  18.      *
  19.      * @param page
  20.      * @param pageSize
  21.      * @return
  22.      */
  23.     PageInfo<Video> queryVideoList(Integer page, Integer pageSize);
  25.     /**
  26.      * 关注用户
  27.      *
  28.      * @param userId
  29.      * @param followUserId
  30.      * @return
  31.      */
  32.     Boolean followUser(Long userId, Long followUserId);
  34.     /**
  35.      * 取消关注用户
  36.      *
  37.      * @param userId
  38.      * @param followUserId
  39.      * @return
  40.      */
  41.     Boolean disFollowUser(Long userId, Long followUserId);
  43. }

接口实现：

  1.  //VideoApiImpl：   
  2.  @Override
  3.     public Boolean followUser(Long userId, Long followUserId) {
  4.         try {
  5.             FollowUser followUser = new FollowUser();
  6.             followUser.setId(ObjectId.get());
  7.             followUser.setUserId(userId);
  8.             followUser.setFollowUserId(followUserId);
  9.             followUser.setCreated(System.currentTimeMillis());
  10.             this.mongoTemplate.save(followUser);
  11.             return true;
  12.         } catch (Exception e) {
  13.             e.printStackTrace();
  14.         }
  15.         return false;
  16.     }
  18.     @Override
  19.     public Boolean disFollowUser(Long userId, Long followUserId) {
  20.         Query query = Query.query(Criteria.where("userId").is(userId).and("followUserId").is(followUserId));
  21.         DeleteResult deleteResult = this.mongoTemplate.remove(query, FollowUser.class);
  22.         return deleteResult.getDeletedCount() > 0;
  23.     }

8.4.2、服务实现

  1. //VideoController：
  2.     /**
  3.      * 视频用户关注
  4.      */
  5.     @PostMapping("/{id}/userFocus")
  6.     public ResponseEntity<Void> saveUserFocusComments(@PathVariable("id") Long userId) {
  7.         try {
  8.             Boolean bool = this.videoService.followUser(userId);
  9.             if (bool) {
  10.                 return ResponseEntity.ok(null);
  11.             }
  12.         } catch (Exception e) {
  13.             e.printStackTrace();
  14.         }
  15.         return ResponseEntity.status(HttpStatus.INTERNAL_SERVER_ERROR).build();
  16.     }
  18.     /**
  19.      * 取消视频用户关注
  20.      */
  21.     @PostMapping("/{id}/userUnFocus")
  22.     public ResponseEntity<Void> saveUserUnFocusComments(@PathVariable("id") Long userId) {
  23.         try {
  24.             Boolean bool = this.videoService.disFollowUser(userId);
  25.             if (bool) {
  26.                 return ResponseEntity.ok(null);
  27.             }
  28.         } catch (Exception e) {
  29.             e.printStackTrace();
  30.         }
  31.         return ResponseEntity.status(HttpStatus.INTERNAL_SERVER_ERROR).build();
  32.     }
  1. //VideoService:
  2.     /**
  3.      * 关注用户
  4.      *
  5.      * @param userId
  6.      * @return
  7.      */
  8.     public Boolean followUser(Long userId) {
  9.         User user = UserThreadLocal.get();
  10.         this.videoApi.followUser(user.getId(), userId);
  12.         //记录已关注
  13.         String followUserKey = "VIDEO_FOLLOW_USER_" + user.getId() + "_" + userId;
  14.         this.redisTemplate.opsForValue().set(followUserKey, "1");
  16.         return true;
  17.     }
  19.     /**
  20.      * 取消关注
  21.      *
  22.      * @param userId
  23.      * @return
  24.      */
  25.     public Boolean disFollowUser(Long userId) {
  26.         User user = UserThreadLocal.get();
  27.         this.videoApi.disFollowUser(user.getId(), userId);
  29.         String followUserKey = "VIDEO_FOLLOW_USER_" + user.getId() + "_" + userId;
  30.         this.redisTemplate.delete(followUserKey);
  32.         return true;
  33.     }