前言

redis性能基准是10w次读写/秒；

但是不适用于下面的场景：

需要缓存，但是经常需要统计，分析和查询。

这种场景适合使用Mongodb;

他是最接近关系数据库的NOSQL;

mongodb介绍:::infoC 语言编写，基于分布式文件存储的开源数据库系统，在负载高的时候，可以添加更多的节点，保证服务器性能。可扩展高性能的数据存储方案。

mongodb把数据存储为一个文档，数据结构是键值对，字段值还可以包含其他的文档，数组等；:::

安装mongodb

我的是mac电脑，简单记录一下安装和使用步骤；

brew cask install mongodb

设置path ；

mongo 连接mongodb

use database_name 创建数据库

配置

依赖


       
    
     org.springframework.boot
      
    
     spring-boot-starter-data-mongodb
    
   
       
    
     com.alibaba
      
    
     fastjson
      
    
     1.2.39

属性配置

spring.data.mongodb.host=127.0.0.1spring.data.mongodb.username=springspring.data.mongodb.password=123456spring.data.mongodb.port=27017spring.data.mongodb.database=springboot

MongoTemplate

可以直接通过MongoTemplate操作mongodb；

代码

package com.springbootpractice.demo.mongodb.service;import com.mongodb.client.result.DeleteResult;import com.mongodb.client.result.UpdateResult;import com.springbootpractice.demo.mongodb.dao.entity.User;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.Service;import java.util.List;/** * 说明：mongodb操作代码 * @author carter * 创建时间： 2020年01月15日 3:02 下午 **/@Servicepublic class UserService {    private final MongoTemplate mongoTemplate;    public UserService(MongoTemplate mongoTemplate) {        this.mongoTemplate = mongoTemplate;    }    public void saveUser(User user) {        mongoTemplate.save(user);    }    public DeleteResult deleteUser(Long id) {        Query query = Query.query(Criteria.where("id").is(id));        return mongoTemplate.remove(query, User.class);    }    public List
   
     findUser(String userName, String note, int skip, int limit) {        final Criteria criteria = Criteria.where("userName")                .regex(userName)                .and("note")                .regex(note);        Query query = Query.query(criteria)                .limit(limit)                .skip(skip);        return mongoTemplate.find(query, User.class);    }    public UpdateResult updateUser(Long id, String userName, String note) {        Update update = new Update();        update.set("userName", userName);        update.set("note", note);        Query query = Query.query(Criteria.where("id").is(id));        return mongoTemplate.updateFirst(query, update, User.class);    }    public User getUser(Long id) {        return mongoTemplate.findById(id, User.class);    }}

测试代码

package com.springbootpractice.demo.mongodb;import com.springbootpractice.demo.mongodb.dao.entity.Role;import com.springbootpractice.demo.mongodb.dao.entity.User;import com.springbootpractice.demo.mongodb.service.UserService;import org.junit.jupiter.api.Test;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.boot.test.context.SpringBootTest;import java.util.Arrays;import java.util.stream.IntStream;@SpringBootTestclass DemoMongodbApplicationTests {    @Autowired    private UserService userService;    @Test    void mongodbTest() {        IntStream.rangeClosed(1, 10).forEach((item) -> {            final long id = System.currentTimeMillis();            userService.saveUser(User.builder().id(id)                    .userName("user")                    .note("note")                    .roles(Arrays.asList(Role.builder().id(id)                                    .roleName("role"   id)                                    .note("note"   id)                                    .build(),                            Role.builder().id(id   1000000)                                    .roleName("_role"   id)                                    .note("_note"   id)                                    .build()                    ))                    .build());        });        userService.findUser("user", "note", 0, 10)                .forEach(System.out::println);    }}