当前位置： 首页 > news >正文

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

news 来源：原创 2025/5/31 21:31:14

目录

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 - 

相关文章：

  • RK3568 OH5.1 镜像烧录
  • C++将地址转换为字符串
  • 行为型：中介者模式
  • Python requests
  • 文件类型汇总
  • Liunx部署ES单机集群
  • C# 数组与字符串：全面解析与应用实践
  • 企业宣传网站系统项目
  • C++？继承！！！
  • 鸿蒙OSUniApp 开发的滑动图片墙组件#三方框架 #Uniapp
  • mobaxterm通过ssh登录docker无图形界面
  • 智能的结构化觉醒：GraphRAG引领AI进入关系世界
  • [yolov11改进系列]基于yolov11引入可改变核卷积AKConv的python源码+训练源码
  • Python优雅执行SSH命令：10种方法+虚拟环境深度实践
  • 防火墙的访问控制
  • Linux网络编程（一）
  • 题目 3341: 蓝桥杯2025年第十六届省赛真题-抽奖
  • 冒泡排序：像煮汤一样让数字「冒泡」
  • 企业级RAG技术实战指南：从理论到落地的全景解析
  • 文件上传白名单绕过（图片马 - 图片二次渲染绕过）
  • 互联网网站建设案例/百度浏览器网址大全
  • u8无可用数据源/seo官网优化详细方法
  • 淘宝联盟链接的网站怎么做/平台推广是什么工作
  • 如何把自己做的网站放到内网/yandex搜索入口
  • 郑州cms建站模板/升华网络推广软件
  • 免费建手机网站/网站网络优化外包