MongoDB实战:应用场景以及Spring和mongodb的整合
创始人
2024-03-01 14:12:59
0

前言

mongodb是非关系型数据库,他的存储数据可以超过上亿条(老版本的mongodb有丢数据的情况,新版本不会有,网上说的),mongodb适合存储 一些量大表关系较简单的数据,例如用户信息,用户注册信息,公司注册信息,留言,评论,操作日志,mongodb还能用分布式文件存储信息,我们主要用mongodb来存储我们项目里面的操作日志(银行的付款转账记录,角色权限的变动日志),我们主要是结合aop来使用的,首先我们来配置一个aop的切面类,再给aop的使用规则,哪个类里面的哪个方法使用当前切面类,利用后置通知类获取当前方法的操作日志,将操作日志存储到mongodb,然后进行分类管理查看。利用后置通知传到数据库。一键获取Spring和mongodb西相关资料和面试题。

从目前阿里云 MongoDB 云数据库上的用户看,MongoDB的应用已经涉及到各个领域,比如游戏、物流、电商、内容管理、社交、物联网、视频直播等,之所以采用mongodb是因为:

MongoDB是NoSQL的非关系型数据库,他的存储数据可以超过上亿条(老版本的mongodb有丢数据的情况,新版本不会有,网上说的),mongodb适合存储 一些量大表关系较简单的数据,易于扩展,可以进行分布式文件存储,适用于大数据量、高并发、弱事务的互联网应用,以下是几个实际的应用案例:

  • 游戏场景,使用MongoDB存储游戏用户信息,用户的装备、积分等直接以内嵌文档的形式存储,方便查询、更新
  • 物流场景,使用MongoDB存储订单信息,订单状态在运送过程中会不断更新,以MongoDB内嵌数组的形式来存储,一次查询就能将订单所有的变更读取出来。
  • 社交场景,使用MongoDB存储存储用户信息,以及用户发表的朋友圈信息,通过地理位置索引实现附近的人、地点等功能
  • 物联网场景,使用MongoDB存储所有接入的智能设备信息,以及设备汇报的日志信息,并对这些信息进行多维度的分析
  • 视频直播,使MongoDB存储用户信息、礼物信息等

在我们实际项目中:

  1. 我们主要用mongodb来存储我们项目里面的操作日志(银行的付款转账记录,角色权限的变动日志),我们主要是结合aop来使用的,首先我们来配置一个aop的切面类,再给aop的使用规则,哪个类里面的哪个方法使用当前切面类,利用后置通知类获取当前方法的操作日志,将操作日志存储到mongodb,然后进行分类管理查看。利用后置通知传到数据库。
  2. 我们在项目中使用它来存储电商产品详情页的评论信息(评论id,商品id,标题,评分,内容,评论人信息,评论的发布时间,评论标签组)并且为了提高可用性和高并发用了3台服务器做了mongodb的副本集,其中一台作为主节点,另外两台作为副本节点,这样在任何一台mongodb服务器宕机时就会自动进行故障转移,不会影响应用程序对mongodb的操作,为了减轻主节点的读写压力过大的问题,我还对mongodb副本集做了读写分离,使写操作在主节点进行,读取操作在副本节点进行。为了控制
    留言,我们留言的界面设置在了订单状态,只有状态为5,也就是交易成功收货后才能评论,并在评论成功后将订单状态改为6

【补充:如果问到副本集是怎么搭建的,就说我们有专门的运维人员来负责搭建,我只负责用Java程序去进行操作】

MongoDB 副本集(Replica Set)是有自动故障恢复功能的主从集群,有一个Primary节点和一个或多个Secondary节点组成。

在副本集的环境中,要是所有的Secondary都宕机了,只剩下Primary。最后Primary会变成Secondary,不能提供服务。

副本集的同步和主从同步一样,都是异步同步的过程,不同的是副本集有个自动故障转移的功能。其原理是:slave端从primary端获取日志,然后在自己身上完全顺序的执行日志所记录的各种操作(该日志是不记录查询操作的)

Spring和mongodb整合步骤:

1.添加依赖的jar包

要想整合Spring和Mongodb必须下载相应的jar,这里主要是用到两种jar一种是spring-data-document和spring-data-commons两种类型的jar

2.定义实体类

3.Spring配置

新建application.xml配置文件

这个必须要的引入mongodb标签xmlns:mongo=“ http://www.springframework.org/schema/data/mongo”

在配置文件中加入链接mongodb客服端

   

注入mogondb的bean对象

              

4.然后编写操作mongodb增删查改的接口

 public interface AbstractRepository {  public void insert(Person person);  public Person findOne(String id);  public List findAll();  public List findByRegex(String regex);  public void removeOne(String id);  public void removeAll();  public void findAndModify(String id);  }  

再写对应接口的实现类:

 import java.util.List;  import java.util.regex.Pattern;    import org.springframework.data.document.mongodb.MongoTemplate;  import org.springframework.data.document.mongodb.query.Criteria;  import org.springframework.data.document.mongodb.query.Query;  import org.springframework.data.document.mongodb.query.Update;  import com.mongo.entity.Person;  import com.mongo.intf.AbstractRepository;  public class PersonRepository implements AbstractRepository{  private MongoTemplate mongoTemplate;  @Override  public List findAll() {  ​     return getMongoTemplate().find(new Query(), Person.class);  }  @Override  public void findAndModify(String id) {  ​    getMongoTemplate().updateFirst(new Query(Criteria.where("id").is(id)), new Update().inc("age", 3)); }  ​    @Override  public List findByRegex(String regex) {  ​     Pattern pattern = Pattern.compile(regex,Pattern.CASE_INSENSITIVE);  ​     Criteria criteria = new Criteria("name").regex(pattern.toString());       return getMongoTemplate().find(new Query(criteria), Person.class);     }  ​    @Override  public Person findOne(String id) {  ​     return getMongoTemplate().findOne(new Query(Criteria.where("id").is(id)), Person.class);  }  ​    @Override  public void insert(Person person) {  ​     getMongoTemplate().insert(person);  }  ​    @Override  public void removeAll() {  ​     List list = this.findAll();  ​     if(list != null){  ​       for(Person person : list){  ​         getMongoTemplate().remove(person);  ​       }  ​     }  }  @Override  public void removeOne(String id){  ​     Criteria criteria = Criteria.where("id").in(id);  ​     if(criteria == null){  ​        Query query = new Query(criteria);  ​        if(query != null && getMongoTemplate().findOne(query, Person.class) != null)  ​     getMongoTemplate().remove(getMongoTemplate().findOne(query, Person.class));       }}  public MongoTemplate getMongoTemplate() {  ​     return mongoTemplate;  }  ​     public void setMongoTemplate(MongoTemplate mongoTemplate) {  ​     this.mongoTemplate = mongoTemplate;  }}

5.实现类注入到service层调用

最后

在这里插入图片描述

👇🏻 添加 博主 获取图中PDF文档 👇🏻

相关内容

热门资讯

喜欢穿一身黑的男生性格(喜欢穿... 今天百科达人给各位分享喜欢穿一身黑的男生性格的知识,其中也会对喜欢穿一身黑衣服的男人人好相处吗进行解...
发春是什么意思(思春和发春是什... 本篇文章极速百科给大家谈谈发春是什么意思,以及思春和发春是什么意思对应的知识点,希望对各位有所帮助,...
网络用语zl是什么意思(zl是... 今天给各位分享网络用语zl是什么意思的知识,其中也会对zl是啥意思是什么网络用语进行解释,如果能碰巧...
为什么酷狗音乐自己唱的歌不能下... 本篇文章极速百科小编给大家谈谈为什么酷狗音乐自己唱的歌不能下载到本地?,以及为什么酷狗下载的歌曲不是...
家里可以做假山养金鱼吗(假山能... 今天百科达人给各位分享家里可以做假山养金鱼吗的知识,其中也会对假山能放鱼缸里吗进行解释,如果能碰巧解...
华为下载未安装的文件去哪找(华... 今天百科达人给各位分享华为下载未安装的文件去哪找的知识,其中也会对华为下载未安装的文件去哪找到进行解...
四分五裂是什么生肖什么动物(四... 本篇文章极速百科小编给大家谈谈四分五裂是什么生肖什么动物,以及四分五裂打一生肖是什么对应的知识点,希...
怎么往应用助手里添加应用(应用... 今天百科达人给各位分享怎么往应用助手里添加应用的知识,其中也会对应用助手怎么添加微信进行解释,如果能...
苏州离哪个飞机场近(苏州离哪个... 本篇文章极速百科小编给大家谈谈苏州离哪个飞机场近,以及苏州离哪个飞机场近点对应的知识点,希望对各位有...
客厅放八骏马摆件可以吗(家里摆... 今天给各位分享客厅放八骏马摆件可以吗的知识,其中也会对家里摆八骏马摆件好吗进行解释,如果能碰巧解决你...