当前位置: 首页 > article >正文

Mongodb | 基于Springboot开发综合社交网络应用的项目案例(中英)

目录

Project background 

Development time

Project questions

Create Project

create springboot project

project framework

create folder

Create Models

user

post

Comment

Like

Message

Serive tier

user login and register

Dynamic Publishing and Browsing

Comment likes

message notification

Page-based query implementation

关联查询实现

用户和动态关联

动态和评论关联

部署与扩展



Project background 

Function description: Achieve functions such as user social relationship management, dynamic posting and browsing, comment and like functions, and message notification.

功能描述 :实现用户的社交关系管理、动态发布与浏览、评论点赞、消息通知等功能。


Handling the association relationships of documents: The user's basic information, social relationships, published content, comments, etc. can be stored in different document collections. Then, through the references or nested structures within the documents, association relationships can be established, facilitating data querying and operations. For example, when querying a user's friend's dynamic, the content published by the friend can be obtained through an association query.
Efficient data pagination and querying: For scenarios such as users browsing dynamic posts and message lists, MongoDB provides efficient data pagination query functions, which can quickly return data within a specified range and improve user experience.
Flexible scalability: As the number of users and data volume increase, MongoDB's storage cluster can be easily expanded to meet the expansion requirements of the application.

文档的关联关系处理 :可以将用户的基本信息、社交关系、发布的内容、评论等存储在不同的文档集合中,然后通过文档中的引用或嵌套结构来建立关联关系,方便进行数据的查询和操作,例如查询一个用户的好友动态时,可以通过关联查询获取好友发布的内容。 高效的数据分页与查询 :对于用户浏览动态、消息列表等场景,MongoDB 提供了高效的数据分页查询功能,能够快速返回指定范围内的数据,提高用户体验。 灵活的扩展性 :随着用户数量和数据量的增长,可以方便地扩展 MongoDB 的存储集群,满足应用的扩展需求。

Development time

Start time : May 27,2025 23:00

End Time : now

Project questions

  • null

Create Project

create springboot project

project framework

social-network-app/
├── src/
│   ├── main/
│   │   ├── java/
│   │   │   ├── com.example.socialnetwork/
│   │   │   │   ├── SocialNetworkApplication.java
│   │   │   │   ├── config/
│   │   │   │   │   └── MongoConfig.java
│   │   │   │   ├── controller/
│   │   │   │   │   ├── UserController.java
│   │   │   │   │   ├── PostController.java
│   │   │   │   │   ├── CommentController.java
│   │   │   │   │   ├── LikeController.java
│   │   │   │   │   └── MessageController.java
│   │   │   │   ├── model/
│   │   │   │   │   ├── User.java
│   │   │   │   │   ├── Post.java
│   │   │   │   │   ├── Comment.java
│   │   │   │   │   ├── Like.java
│   │   │   │   │   └── Message.java
│   │   │   │   ├── repository/
│   │   │   │   │   ├── UserRepository.java
│   │   │   │   │   ├── PostRepository.java
│   │   │   │   │   ├── CommentRepository.java
│   │   │   │   │   ├── LikeRepository.java
│   │   │   │   │   └── MessageRepository.java
│   │   │   │   ├── service/
│   │   │   │   │   ├── UserService.java
│   │   │   │   │   ├── PostService.java
│   │   │   │   │   ├── CommentService.java
│   │   │   │   │   ├── LikeService.java
│   │   │   │   │   └── MessageService.java
│   │   │   │   └── dto/
│   │   │   │       ├── UserDto.java
│   │   │   │       ├── PostDto.java
│   │   │   │       ├── CommentDto.java
│   │   │   │       ├── LikeDto.java
│   │   │   │       └── MessageDto.java
│   │   └── resources/
│   │       ├── application.properties
│   │       └── static/
│   └── test/
└── pom.xml

create folder

Create Models

user

package com.socialnetwork.www.model;import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.ToString;
import org.springframework.data.annotation.Id;
import org.springframework.data.mongodb.core.mapping.Document;import java.util.ArrayList;
import java.util.List;@Data
@AllArgsConstructor
@NoArgsConstructor
@ToString
@Document(collection = "users")
public class User {@Idprivate String id;private String username;private String password;private String email;private String profilePicture;private String bio;private List<String> followers = new ArrayList<>();private List<String> following = new ArrayList<>();
}

post

package com.socialnetwork.www.model;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.ToString;
import org.springframework.data.annotation.Id;
import org.springframework.data.mongodb.core.mapping.Document;import javax.xml.stream.events.Comment;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;@Data
@AllArgsConstructor
@NoArgsConstructor
@ToString
@Document(collection = "posts")
public class Post {@Idprivate String id;private String userId;private String content;private List<String> images;private Date createdAt;private int likeCount = 0;private List<Comment> comments = new ArrayList<>();
}

Comment

package com.socialnetwork.www.model;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.ToString;
import org.springframework.data.annotation.Id;
import org.springframework.data.mongodb.core.mapping.Document;import java.util.Date;@Data
@AllArgsConstructor
@NoArgsConstructor
@ToString
@Document(collection = "comments")
public class Comments {@Idprivate String id;private String userId;private String postId;private String content;private Date createdAt;private int likeCount = 0;
}

Like

package com.socialnetwork.www.model;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.ToString;
import org.springframework.data.annotation.Id;
import org.springframework.data.mongodb.core.mapping.Document;import java.util.Date;@Data
@AllArgsConstructor
@NoArgsConstructor
@ToString
@Document(collection = "likes")
public class Like {@Idprivate String id;private String userId;private String postId;private String commentId;private Date createdAt;// Getters and Setters
}

Message

package com.socialnetwork.www.model;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.ToString;
import org.springframework.data.annotation.Id;
import org.springframework.data.mongodb.core.mapping.Document;import java.util.Date;@Data
@AllArgsConstructor
@NoArgsConstructor
@ToString
@Document(collection = "messages")
public class Message {@Idprivate String id;private String senderId;private String receiverId;private String content;private Date sentAt;private boolean read = false;
}

Serive tier

user login and register

用户 登录和注册

@RestController
@RequestMapping("/api/users")
public class UserController {@Autowiredprivate UserService userService;@PostMapping("/register")public ResponseEntity<?> registerUser(@RequestBody UserDto userDto) {User user = userService.registerUser(userDto);return ResponseEntity.ok(user);}@PostMapping("/login")public ResponseEntity<?> loginUser(@RequestBody UserDto userDto) {User user = userService.loginUser(userDto);return ResponseEntity.ok(user);}
}
@Service
public class UserService {@Autowiredprivate UserRepository userRepository;public User registerUser(UserDto userDto) {User user = new User();user.setUsername(userDto.getUsername());user.setPassword(bCryptPasswordEncoder.encode(userDto.getPassword()));user.setEmail(userDto.getEmail());return userRepository.save(user);}public User loginUser(UserDto userDto) {User user = userRepository.findByUsername(userDto.getUsername());if (user != null && bCryptPasswordEncoder.matches(userDto.getPassword(), user.getPassword())) {return user;}return null;}
}

Dynamic Publishing and Browsing

动态发布与浏览

@RestController
@RequestMapping("/api/posts")
public class PostController {@Autowiredprivate PostService postService;@PostMappingpublic ResponseEntity<?> createPost(@RequestBody PostDto postDto, @AuthenticationPrincipal String userId) {Post post = postService.createPost(postDto, userId);return ResponseEntity.ok(post);}@GetMappingpublic ResponseEntity<?> getPosts(@RequestParam int page, @RequestParam int size) {Pageable pageable = PageRequest.of(page, size, Sort.by(Sort.Direction.DESC, "createdAt"));Page<Post> posts = postService.getPosts(pageable);return ResponseEntity.ok(posts);}
}
@Service
public class PostService {@Autowiredprivate PostRepository postRepository;public Post createPost(PostDto postDto, String userId) {Post post = new Post();post.setUserId(userId);post.setContent(postDto.getContent());post.setImages(postDto.getImages());post.setCreatedAt(new Date());return postRepository.save(post);}public Page<Post> getPosts(Pageable pageable) {return postRepository.findAll(pageable);}
}

Comment likes

评论点赞

@RestController
@RequestMapping("/api/comments")
public class CommentController {@Autowiredprivate CommentService commentService;@PostMappingpublic ResponseEntity<?> addComment(@RequestBody CommentDto commentDto, @AuthenticationPrincipal String userId) {Comment comment = commentService.addComment(commentDto, userId);return ResponseEntity.ok(comment);}@PostMapping("/{commentId}/like")public ResponseEntity<?> likeComment(@PathVariable String commentId, @AuthenticationPrincipal String userId) {Like like = commentService.likeComment(commentId, userId);return ResponseEntity.ok(like);}
}
@Service
public class CommentService {@Autowiredprivate CommentRepository commentRepository;@Autowiredprivate LikeRepository likeRepository;public Comment addComment(CommentDto commentDto, String userId) {Comment comment = new Comment();comment.setUserId(userId);comment.setPostId(commentDto.getPostId());comment.setContent(commentDto.getContent());comment.setCreatedAt(new Date());return commentRepository.save(comment);}public Like likeComment(String commentId, String userId) {Like like = new Like();like.setUserId(userId);like.setCommentId(commentId);like.setCreatedAt(new Date());return likeRepository.save(like);}
}

message notification

消息通知

@RestController
@RequestMapping("/api/messages")
public class MessageController {@Autowiredprivate MessageService messageService;@PostMappingpublic ResponseEntity<?> sendMessage(@RequestBody MessageDto messageDto, @AuthenticationPrincipal String userId) {Message message = messageService.sendMessage(messageDto, userId);return ResponseEntity.ok(message);}@GetMappingpublic ResponseEntity<?> getMessages(@RequestParam String receiverId, @RequestParam int page, @RequestParam int size) {Pageable pageable = PageRequest.of(page, size, Sort.by(Sort.Direction.DESC, "sentAt"));Page<Message> messages = messageService.getMessages(receiverId, pageable);return ResponseEntity.ok(messages);}
}
@Service
public class MessageService {@Autowiredprivate MessageRepository messageRepository;public Message sendMessage(MessageDto messageDto, String userId) {Message message = new Message();message.setSenderId(userId);message.setReceiverId(messageDto.getReceiverId());message.setContent(messageDto.getContent());message.setSentAt(new Date());message.setRead(false);return messageRepository.save(message);}public Page<Message> getMessages(String receiverId, Pageable pageable) {return messageRepository.findByReceiverId(receiverId, pageable);}
}

Page-based query implementation

分页查询实现

在 Spring Data MongoDB 中,可以使用 Pageable 接口来实现分页查询。

public interface PostRepository extends MongoRepository<Post, String> {Page<Post> findAll(Pageable pageable);
}

在控制器中使用:

@GetMapping
public ResponseEntity<?> getPosts(@RequestParam int page, @RequestParam int size) {Pageable pageable = PageRequest.of(page, size, Sort.by(Sort.Direction.DESC, "createdAt"));Page<Post> posts = postService.getPosts(pageable);return ResponseEntity.ok(posts);
}

关联查询实现

使用 MongoDB 的 @DBRef 注解可以实现文档之间的关联查询。

用户和动态关联

Post 文档中,userId 字段关联到 User 文档。

@Document(collection = "posts")
public class Post {@Idprivate String id;private String userId;private String content;private List<String> images;private Date createdAt;private int likeCount = 0;private List<Comment> comments = new ArrayList<>();// Getters and Setters
}

在控制器中,可以通过 userId 查询用户信息:

@GetMapping("/{postId}")
public ResponseEntity<?> getPost(@PathVariable String postId) {Post post = postService.getPost(postId);User user = userService.getUser(post.getUserId());return ResponseEntity.ok(post);
}

动态和评论关联

Comment 文档中,postId 字段关联到 Post 文档。

@Document(collection = "comments")
public class Comment {@Idprivate String id;private String userId;private String postId;private String content;private Date createdAt;private int likeCount = 0;// Getters and Setters
}

在控制器中,可以通过 postId 查询评论列表:

@GetMapping("/{postId}/comments")
public ResponseEntity<?> getComments(@PathVariable String postId) {List<Comment> comments = commentService.getComments(postId);return ResponseEntity.ok(comments);
}

部署与扩展

在生产环境中,可以使用 MongoDB 的分片功能来支持大规模数据的存储和查询。

spring.data.mongodb.uri=mongodb://username:password@host1:port1,host2:port2,host3:port3/database?replicaSet=replicaSetName

 - Thanks you - 

http://www.lryc.cn/news/2394799.html

相关文章:

  • 飞腾D2000与FPGA结合的主板
  • 百度量子蜘蛛3.0横空出世,搜索引擎迎来“量子跃迁“级革命
  • GitHub开源|AI顶会论文中文翻译PDF合集(gpt-translated-pdf-zh)
  • JSR 303(即 Bean Validation)是一个通过​​注解在 Java Bean 上定义和执行验证规则​​的规范
  • 5G 网络中的双向认证机制解析
  • DAY07:Vue Router深度解析与多页面博客系统实战
  • Drawio编辑器二次开发
  • 1.测试过程之需求分析和测试计划
  • 第三十七天打卡
  • Qt 窗口标志(Window Flags)详解:控制窗口样式与行为
  • ABP VNext + CRDT 打造实时协同编辑
  • 微信小程序真机调试时如何实现与本地开发环境服务器交互
  • Linux: network: dpdk, VF, ip link set down 对VF不生效
  • [春秋云镜] CVE-2023-23752 writeup
  • Java集合操作常见错误与最佳实践
  • CSS专题之水平垂直居中
  • python打卡day41@浙大疏锦行
  • vue3 基本语法 父子关系
  • 算法-js-子集
  • (新)MQ高级-MQ的可靠性
  • Android设置界面层级为最上层实现
  • 云原生微服务架构演进之路:理念、挑战与实践
  • Go语言使用阿里云模版短信服务
  • Leetcode 3231. 要删除的递增子序列的最小数量
  • 4.2.5 Spark SQL 分区自动推断
  • 基于昇腾MindSpeed训练加速库玩转智谱GLM-4-0414模型
  • 【图像处理入门】2. Python中OpenCV与Matplotlib的图像操作指南
  • Spring Boot微服务架构(九):设计哲学是什么?
  • GRCh38版本染色体位置转换GRCh37(hg19)
  • TC/BC/OC P2P/E2E有啥区别?-PTP协议基础概念介绍