探花交友_第5章_圈子功能实现(新版)

探花交友_第5章_圈子功能实现(新版)

课程说明

• 首页推荐
• MongoDB集群

• 圈子功能说明
• 圈子技术实现与方案
• 圈子实现发布动态
• 圈子实现个人动态

1、首页推荐

1.1、接口分析

地址：http://192.168.136.160:3000/project/19/interface/api/118

响应：

{"counts": 4698,"pagesize": 20,"pages": 58,"page": 16,"items": [{"id": 1011,"avatar": "assets/images/avatar_2.png","nickname": "黑马小妹","gender": "woman","age": 23,"tags": ["本科","年龄相仿","单身"],"fateValue": 96},{"id": 2495,"avatar": "assets/images/avatar_1.png","nickname": "米朵妹妹","gender": "man","age": 28,"tags": ["年龄相仿","本科","单身"],"fateValue": 87},{"id": 5708,"avatar": "assets/images/avatar_4.png","nickname": "黑马小妹","gender": "man","age": 24,"tags": ["单身","本科","年龄相仿"],"fateValue": 94},{"id": 4768,"avatar": "assets/images/avatar_3.png","nickname": "黑马小妹","gender": "man","age": 24,"tags": ["年龄相仿","单身","本科"],"fateValue": 80}]
}

1.2、功能实现

1.2.1 controller

TanhuaController编写推荐列表方法

/*** 查询分页推荐好友列表*/
@GetMapping("/recommendation")
public ResponseEntity recommendation(RecommendUserDto dto) {PageResult pr = tanhuaService.recommendation(dto);return ResponseEntity.ok(pr);
}

1.2.2 service

TanhuaService编写推荐列表方法

//查询分页推荐好友列表
public PageResult recommendation(RecommendUserDto dto) {//1、获取用户idLong userId = UserHolder.getUserId();//2、调用recommendUserApi分页查询数据列表（PageResult -- RecommendUser）PageResult pr = recommendUserApi.queryRecommendUserList(dto.getPage(),dto.getPagesize(),userId);//3、获取分页中的RecommendUser数据列表List<RecommendUser> items = (List<RecommendUser>) pr.getItems();//4、判断列表是否为空if(items == null || items.size() <=0) {return pr;}//5、提取所有推荐的用户id列表List<Long> ids = CollUtil.getFieldValues(items, "userId", Long.class);UserInfo userInfo = new UserInfo();userInfo.setAge(dto.getAge());userInfo.setGender(dto.getGender());//6、构建查询条件，批量查询所有的用户详情Map<Long, UserInfo> map = userInfoApi.findByIds(ids, userInfo);//7、循环推荐的数据列表，构建vo对象List<TodayBest> list = new ArrayList<>();for (RecommendUser item : items) {UserInfo info = map.get(item.getUserId());if(info!=null) {TodayBest vo = TodayBest.init(info, item);list.add(vo);}}//8、构造返回值pr.setItems(list);return pr;
}

1.2.3 API接口

在RecommendUserApi 接口和RecommendUserApiImpl实现类中添加方法查询

//分页查询
public PageResult queryRecommendUserList(Integer page, Integer pagesize, Long toUserId) {//1、构建Criteria对象Criteria criteria = Criteria.where("toUserId").is(toUserId);//2、创建Query对象Query query = Query.query(criteria).with(Sort.by(Sort.Order.desc("score"))).limit(pagesize).skip((page - 1) * pagesize);//3、调用mongoTemplate查询List<RecommendUser> list = mongoTemplate.find(query, RecommendUser.class);long count = mongoTemplate.count(query, RecommendUser.class);//4、构建返回值PageResultreturn  new PageResult(page,pagesize,count,list);
}

1.2.4 请求dto对象

import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;@Data
@NoArgsConstructor
@AllArgsConstructor
public class RecommendUserDto {private Integer page = 1; //当前页数private Integer pagesize = 10; //页尺寸private String gender; //性别 man womanprivate String lastLogin; //近期登陆时间private Integer age; //年龄private String city; //居住地private String education; //学历
}

2、圈子功能

2.1、功能说明

探花交友项目中的圈子功能，类似微信的朋友圈，基本的功能为：发布动态、浏览好友动态、浏览推荐动态、点赞、评论、喜欢等功能。

发布：

1.2、实现方案分析

对于圈子功能的实现，我们需要对它的功能特点做分析：

• 数据量会随着用户数增大而增大
• 读多写少
• 非好友看不到其动态内容
• ……

针对以上特点，我们来分析一下：

• 对于数据量大而言，显然不能够使用关系型数据库进行存储，我们需要通过MongoDB进行存储
• 对于读多写少的应用，需要减少读取的成本
  • 比如说，一条SQL语句，单张表查询一定比多张表查询要快
• 对于每个人数据在存储层面最好做到相互隔离，这样的话就不会有影响

所以对于存储而言，主要是核心的4张表：

• 发布表：记录了所有用户的发布的东西信息，如图片、视频等。
• 自己时间线：相册是每个用户独立的，记录了该用户所发布的所有内容。
• 好友时间线：所谓“刷朋友圈”，就是刷时间线，就是一个用户所有的朋友的发布内容。
• 好友表：记录好友关系

1.3、技术方案(重点)

根据之前我们的分析，对于技术方案而言，将采用MongoDB+Redis来实现，其中MongoDB负责存储，Redis负责缓存数据。

1.4、表结构设计

发布表：动态总记录表（记录每个人发送的动态详情）

#表名：movement
{"_id": ObjectId("5e82dc416401952928c211d8"),"pid": NumberLong("10064"),"userId": NumberLong("6"),"textContent": "最悲伤却又是最痛苦的谎言，就是我还好，没有关系。","medias": ["https://tanhua-dev.oss-cn-zhangjiakou.aliyuncs.com/photo/7/1.jpg","https://tanhua-dev.oss-cn-zhangjiakou.aliyuncs.com/photo/7/1564567349498.jpg","https://tanhua-dev.oss-cn-zhangjiakou.aliyuncs.com/photo/7/1564567352977.jpg","https://tanhua-dev.oss-cn-zhangjiakou.aliyuncs.com/photo/7/1564567360406.jpg"],"longitude": "121.588627","latitude": "30.935781","state": NumberInt("0"),"locationName": "中国上海市奉贤区人民路445弄","created": NumberLong("1585634369493"),"_class": "com.tanhua.dubbo.server.pojo.Publish"
}

好友时间线表：记录当前好友发布的动态数据

#表名：movement_timeline
{"_id": ObjectId("609cf6538743d448c02c61f0"),"movementId": ObjectId("609cf6538743d448c02c61ef"),"userId": NumberLong("106"),"friendId": NumberLong("1"),"created": NumberLong("1620899411043"),"_class": "com.tanhua.model.mongo.MovementTimeLine"
}

好友关系表：记录好友的双向关系（双向）

#表名：friend
{"_id": ObjectId("6018bc055098b2230031e2da"),"created": NumberLong("1612233733056"),"userId": NumberLong("1"),"friendId": NumberLong("106"),"_class": "com.itheima.domain.mongo.Friend"
}

3、圈子实现

3.1、环境搭建

Mongodb中实现字段的自增：两种解决方法（1、使用redis保证自动增长，2、使用mongodb自定义表）

3.1.1、mongo主键自增

第一步：创建实体类

package com.tanhua.domain.mongo;import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import org.bson.types.ObjectId;
import org.springframework.data.annotation.Id;
import org.springframework.data.mongodb.core.mapping.Document;
import org.springframework.data.mongodb.core.mapping.Field;@Document(collection = "sequence")
@Data
@AllArgsConstructor
@NoArgsConstructor
public class Sequence {private ObjectId id;private long seqId; //自增序列private String collName;  //集合名称
}

第二步：编写service

package com.tanhua.dubbo.utils;import com.tanhua.domain.mongo.Sequence;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.mongodb.core.FindAndModifyOptions;
import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.data.mongodb.core.query.Criteria;
import org.springframework.data.mongodb.core.query.Query;
import org.springframework.data.mongodb.core.query.Update;
import org.springframework.stereotype.Component;@Component
public class IdWorker {@Autowiredprivate MongoTemplate mongoTemplate;public Long getNextId(String collName) {Query query = new Query(Criteria.where("collName").is(collName));Update update = new Update();update.inc("seqId", 1);FindAndModifyOptions options = new FindAndModifyOptions();options.upsert(true);options.returnNew(true);Sequence sequence = mongoTemplate.findAndModify(query, update, options, Sequence.class);return sequence.getSeqId();}
}

3.1.2、实体类

写到tanhua-domain工程中：

Movement

Movement：发布信息表（总记录表数据）

package com.tanhua.domain.mongo;import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import org.bson.types.ObjectId;
import org.springframework.data.mongodb.core.mapping.Document;import java.util.List;//动态详情表
@Data
@NoArgsConstructor
@AllArgsConstructor
@Document(collection = "movement")
public class Movement implements java.io.Serializable {private ObjectId id; //主键idprivate Long pid; //Long类型，用于推荐系统的模型(自动增长)private Long created; //发布时间private Long userId;private String textContent; //文字private List<String> medias; //媒体数据，图片或小视频 urlprivate String longitude; //经度private String latitude; //纬度private String locationName; //位置名称private Integer state = 0;//状态 0：未审（默认），1：通过，2：驳回
}

MovementTimeLine

MovementTimeLine：好友时间线表，用于存储好友发布（或推荐）的数据，每一个用户一张表进行存储

package com.tanhua.domain.mongo;import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import org.bson.types.ObjectId;
import org.springframework.data.mongodb.core.mapping.Document;/*** 好友时间线表，用于存储好友发布的数据*/
@Data
@NoArgsConstructor
@AllArgsConstructor
@Document(collection = "movement_timeLine")
public class MovementTimeLine implements java.io.Serializable {private static final long serialVersionUID = 9096178416317502524L;private ObjectId id;private ObjectId movementId;//动态idprivate Long userId;   //发布动态用户idprivate Long friendId; // 可见好友idprivate Long created; //发布的时间
}

Friend

Friend 好友关系表

package com.tanhua.domain.mongo;import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import org.bson.types.ObjectId;
import org.springframework.data.mongodb.core.mapping.Document;/*** 好友表:好友关系表*/
@Data
@NoArgsConstructor
@AllArgsConstructor
@Document(collection = "friend")
public class Friend implements java.io.Serializable{private static final long serialVersionUID = 6003135946820874230L;private ObjectId id;private Long userId; //用户idprivate Long friendId; //好友idprivate Long created; //时间}

3.1.3、API接口

package com.tanhua.dubbo.api.mongo;import com.tanhua.domain.mongo.Publish;
import com.tanhua.domain.vo.PageResult;public interface MovementApi {}

3.1.4、API实现类

package com.tanhua.dubbo.api.mongo;import com.tanhua.domain.mongo.*;
import com.tanhua.domain.vo.PageResult;
import com.tanhua.dubbo.utils.IdService;
import org.apache.dubbo.config.annotation.Service;
import org.bson.types.ObjectId;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.domain.PageRequest;
import org.springframework.data.domain.Pageable;
import org.springframework.data.domain.Sort;
import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.data.mongodb.core.query.Criteria;
import org.springframework.data.mongodb.core.query.Query;import java.util.ArrayList;
import java.util.List;@Service
public class MovementApiImpl implements PublishApi {}

3.1.5、MovementsController

package com.tanhua.server.controller;import com.tanhua.domain.mongo.Publish;
import com.tanhua.server.service.MovementsService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;import java.io.IOException;@RestController
@RequestMapping("/movements")
public class MovementsController {@Autowiredprivate MovementsService movementsService;}

3.1.6、MovementsService

package com.tanhua.server.service;import com.tanhua.autoconfig.templates.OssTemplate;
import com.tanhua.domain.db.UserInfo;
import com.tanhua.domain.mongo.Publish;
import com.tanhua.domain.vo.Movements;
import com.tanhua.domain.vo.PageResult;
import com.tanhua.dubbo.api.UserInfoApi;
import com.tanhua.dubbo.api.mongo.PublishApi;
import com.tanhua.server.interceptor.UserHolder;
import io.jsonwebtoken.lang.Collections;
import org.apache.dubbo.config.annotation.Reference;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.ResponseEntity;
import org.springframework.stereotype.Service;
import org.springframework.util.StringUtils;
import org.springframework.web.multipart.MultipartFile;import java.io.IOException;
import java.text.SimpleDateFormat;
import java.util.*;@Service
public class MovementsService {@Autowiredprivate OssTemplate ossTemplate;@DubboReferenceprivate MovementApi movementApi;@DubboReferenceprivate UserInfoApi userInfoApi;@Autowiredprivate RedisTemplate<String,String> redisTemplate;
}

3.2、发布动态

后续的测试：使用106（13800138000）和1号用户（13500000000）

3.2.0、思路步骤

3.2.1、MovementsController

tanhua-server工程编写MovementsController，完成发布动态功能

@RestController
@RequestMapping("/movements")
public class MovementController {@Autowiredprivate MovementService movementService;@Autowiredprivate CommentsService commentsService;/*** 发布动态*/@PostMappingpublic ResponseEntity movements(Movement movement,MultipartFile imageContent[]) throws IOException {movementService.publishMovement(movement,imageContent);return ResponseEntity.ok(null);}
}

3.2.2、编写service

tanhua-server工程编写MovementsService，完成发布动态功能

/*** 发布动态*/
public void publishMovement(Movement movement, MultipartFile[] imageContent) throws IOException {//1、判断发布动态的内容是否存在if(StringUtils.isEmpty(movement.getTextContent())) {throw  new BusinessException(ErrorResult.contentError());}//2、获取当前登录的用户idLong userId = UserHolder.getUserId();//3、将文件内容上传到阿里云OSS，获取请求地址List<String> medias = new ArrayList<>();for (MultipartFile multipartFile : imageContent) {String upload = ossTemplate.upload(multipartFile.getOriginalFilename(), multipartFile.getInputStream());medias.add(upload);}//4、将数据封装到Movement对象movement.setUserId(userId);movement.setMedias(medias);//5、调用API完成发布动态movementApi.publish(movement);
}

3.2.3、API层

    //发布动态public void publish(Movement movement) {//1、保存动态详情try {//设置PIDmovement.setPid(idWorker.getNextId("movement"));//设置时间movement.setCreated(System.currentTimeMillis());//movement.setId(ObjectId.get());mongoTemplate.save(movement);//2、查询当前用户的好友数据
//            Criteria criteria = Criteria.where("userId").is(movement.getUserId());
//            Query query = Query.query(criteria);
//            List<Friend> friends = mongoTemplate.find(query, Friend.class);//3、循环好友数据，构建时间线数据存入数据库
//            for (Friend friend : friends) {
//                MovementTimeLine timeLine = new MovementTimeLine();
//                timeLine.setMovementId(movement.getId());
//                timeLine.setUserId(friend.getUserId());
//                timeLine.setFriendId(friend.getFriendId());
//                timeLine.setCreated(System.currentTimeMillis());
//                mongoTemplate.save(timeLine);
//            }//写入好友的时间线表（异步写入）timeLineService.saveTimeLine(movement.getUserId(), movement.getId());} catch (Exception e) {//忽略事务处理e.printStackTrace();}}

3.2.4、异步处理工具类

@Component
public class TimeLineService {@Autowiredprivate MongoTemplate mongoTemplate;@Async //异步执行，原理：底层开一个线程去执行该方法public CompletableFuture<String> saveTimeLine(Long userId, ObjectId movementId) {//写入好友的时间线表try {//1、查询当前用户的好友数据Criteria criteria = Criteria.where("userId").is(userId);Query query = Query.query(criteria);List<Friend> friends = mongoTemplate.find(query, Friend.class);if (CollUtil.isEmpty(friends)) {return CompletableFuture.completedFuture("ok");//返回成功}//2、循环好友数据，构建时间线数据存入数据库for (Friend friend : friends) {MovementTimeLine timeLine = new MovementTimeLine();timeLine.setMovementId(movementId);timeLine.setUserId(friend.getUserId());timeLine.setFriendId(friend.getFriendId());timeLine.setCreated(System.currentTimeMillis());mongoTemplate.save(timeLine);}} catch (Exception e) {e.printStackTrace();//TODO 事务回滚问题return CompletableFuture.completedFuture("error");}return CompletableFuture.completedFuture("ok");}
}

3.2.5、整合测试

@RunWith(SpringRunner.class)
@SpringBootTest(classes = AppServerApplication.class)
public class MovementApiTest {@DubboReferenceprivate MovementApi movementApi;@Testpublic void testPublish() {Movement movement = new Movement();movement.setUserId(106l);movement.setTextContent("你的酒窝没有酒，我却醉的像条狗");List<String> list = new ArrayList<>();list.add("https://tanhua-dev.oss-cn-zhangjiakou.aliyuncs.com/images/tanhua/avatar_1.png");list.add("https://tanhua-dev.oss-cn-zhangjiakou.aliyuncs.com/images/tanhua/avatar_2.png");movement.setMedias(list);movement.setLatitude("40.066355");movement.setLongitude("116.350426");movement.setLocationName("中国北京市昌平区建材城西路16号");movementApi.publish(movement);}
}

3.3、查询个人动态

查询好友动态其实就是查询自己的时间线表，好友在发动态时已经将动态信息写入到了自己的时间线表中。

3.3.0、思路分析

3.3.1、vo对象

package com.tanhua.model.vo;import com.tanhua.model.domain.UserInfo;
import com.tanhua.model.mongo.Movement;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import org.springframework.beans.BeanUtils;
import org.springframework.util.StringUtils;import java.io.Serializable;
import java.text.SimpleDateFormat;
import java.util.Date;@Data
@NoArgsConstructor
@AllArgsConstructor
public class MovementsVo  implements Serializable {private String id; //动态idprivate Long userId; //用户idprivate String avatar; //头像private String nickname; //昵称private String gender; //性别 man womanprivate Integer age; //年龄private String[] tags; //标签private String textContent; //文字动态private String[] imageContent; //图片动态private String distance; //距离private String createDate; //发布时间 如: 10分钟前private Integer likeCount; //点赞数private Integer commentCount; //评论数private Integer loveCount; //喜欢数private Integer hasLiked; //是否点赞（1是，0否）private Integer hasLoved; //是否喜欢（1是，0否）public static MovementsVo init(UserInfo userInfo, Movement item) {MovementsVo vo = new MovementsVo();//设置动态数据BeanUtils.copyProperties(item, vo);vo.setId(item.getId().toHexString());//设置用户数据BeanUtils.copyProperties(userInfo, vo);if(!StringUtils.isEmpty(userInfo.getTags())) {vo.setTags(userInfo.getTags().split(","));}//图片列表vo.setImageContent(item.getMedias().toArray(new String[]{}));//距离vo.setDistance("500米");Date date = new Date(item.getCreated());vo.setCreateDate(new SimpleDateFormat("yyyy-MM-dd hh:mm:ss").format(date));//设置是否点赞(后续处理)vo.setHasLoved(0);vo.setHasLiked(0);return vo;}
}

3.3.2、controller

修改MovementsController完成查询好友动态功能

/*** 查询我的动态*/
@GetMapping("/all")
public ResponseEntity findByUserId(Long userId,@RequestParam(defaultValue = "1") Integer page,@RequestParam(defaultValue = "10") Integer pagesize) {PageResult pr = movementService.findByUserId(userId,page,pagesize);return ResponseEntity.ok(pr);
}

3.3.3、service

修改MovementsService完成查询好友动态功能

//查询个人动态
public PageResult findByUserId(Long userId, Integer page, Integer pagesize) {//1、根据用户id，调用API查询个人动态内容（PageResult  -- Movement）PageResult pr = movementApi.findByUserId(userId,page,pagesize);//2、获取PageResult中的item列表对象List<Movement> items = (List<Movement>) pr.getItems();//3、非空判断if(items == null) {return pr;}//4、循环数据列表UserInfo userInfo = userInfoApi.findById(userId);List<MovementsVo> vos = new ArrayList<>();for (Movement item : items) {//5、一个Movement构建一个Vo对象MovementsVo vo = MovementsVo.init(userInfo, item);vos.add(vo);}//6、构建返回值pr.setItems(vos);return pr;
}

3.3.4、API层

修改PublishApi和PublishApiImpl完成查询好友动态功能

@Override
public PageResult findByUserId(Long userId, Integer page, Integer pagesize) {Criteria criteria = Criteria.where("userId").is(userId);Query query = Query.query(criteria).skip((page -1 ) * pagesize).limit(pagesize).with(Sort.by(Sort.Order.desc("created")));List<Movement> movements = mongoTemplate.find(query, Movement.class);return new PageResult(page,pagesize,0l,movements);
}

3.3.5、测试