SpringBoot整合redis及mongodb的详细过程

更新时间：2022年10月23日 10:19:23 作者：14号程序员

这篇文章主要介绍了SpringBoot整合redis及mongodb,本节我们来把关注点转向NoSQL，文章结合示例代码给大家讲解的非常详细，需要的朋友可以参考下

NoSQL，泛指非关系型的数据库。随着互联网web2.0网站的兴起，传统的关系数据库在处理web2.0网站，特别是超大规模和高并发的SNS类型的web2.0纯动态网站已经显得力不从心，出现了很多难以克服的问题，而非关系型的数据库则由于其本身的特点得到了非常迅速的发展。NoSQL数据库的产生就是为了解决大规模数据集合多重数据种类带来的挑战，特别是大数据应用难题。（——来自百度百科）

得益于其直接基于内存的存储方式，NoSQL的访问速度可以用“飞快”两个字来形容

在生产环境中，NoSQL常常配合传统关系型数据库来使用，比如构建一层数据缓存来极大的提升数据的读取速度

NoSQL在日常业务的驱动之下，逐渐发展出几个主要的类别：键值对数据库、文档型数据库、列存储数据库以及图形化数据库

这4类NoSQL数据库之中最具代表性的，当属键值对数据库类别下的Redis，以及文档型数据库的Mongodb，本节我们重点关注这两个产品在SpringBoot下的整合及使用

照惯例先上项目结构：

一、先看Redis的使用：

1. 在pom.xml中添加Redis相关依赖项

<!-- 引入redis依赖(基于lettuce) -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-redis</artifactId>
        </dependency>
        <dependency>
            <groupId>org.apache.commons</groupId>
            <artifactId>commons-pool2</artifactId>
        </dependency>

2. 在application.properties中添加Redis的相关配置

# redis相关设置
spring.redis.database=0
spring.redis.host=127.0.0.1
spring.redis.port=6379
spring.redis.password=
# redis默认基于lettuce内核
spring.redis.lettuce.pool.max-active=8
spring.redis.lettuce.pool.max-idle=8
spring.redis.lettuce.pool.max-wait=-1ms
spring.redis.lettuce.pool.min-idle=0

这里关于lettuce内核有必要给大家解释一下：

在SpringBoot2.x版本之前，其集成的默认Redis库是Jedis，而在2.x版本之后才改为默认基于Lettuce

Jedis默认和Redis直连，为非线程安全模型，并发环境下需要池化使用

而Lettuce则是线程安全的，并发环境下可以通过一个实例搞定

当然，你也可以在SpringBoot2.x环境下依然使用Jedis，只需要把spring.redis.lettuce 相关配置替换为spring.redis.jedis 即可

更多内容大家感兴趣可以从网上查阅相关资料，这里推荐一篇：https://blog.csdn.net/kenkao/article/details/127085687

3. 新建 service/RedisService 接口及其实现类 service/impl/RedisServiceImpl

package com.example.hellospringboot.service;

public interface RedisService {
    void set(String key, String val);
    String get(String key);
}

package com.example.hellospringboot.service.impl;

import com.example.hellospringboot.service.RedisService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.data.redis.core.ValueOperations;
import org.springframework.stereotype.Service;

@Service
public class RedisServiceImpl implements RedisService {

    @Autowired
    StringRedisTemplate redis;

    public void set(String key, String val){
        ValueOperations<String,String> ops = redis.opsForValue();
        ops.set(key, val);
    }

    public String get(String key){
        ValueOperations<String,String> ops = redis.opsForValue();
        return ops.get(key);
    }
}

我们在Service中自动装载一个StringRedisTemplate实例，而后通过其创建Operation对象，进行可以进行各种Redis读写操作

4. 新建 controller/RedisController

package com.example.hellospringboot.controller;

import com.example.hellospringboot.service.RedisService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import javax.servlet.http.HttpSession;

@RestController
@RequestMapping("/redis")
public class RedisController {

    @Autowired
    RedisService service;

    @PostMapping("/set")
    public void set(String key, String val){
        service.set(key, val);
    }

    @GetMapping("/get")
    public String get(String key){
        return service.get(key);
    }

}

5. 通过Postman进行结果验证

通过RDM查看写入redis的数据：

之后是读操作：

至此我们便完成了SpringBoot中集成Redis的操作

二、MongoDB的使用

1. 首先还是先添加MongoDB相关依赖项

 <!-- 引入mongodb依赖 -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-mongodb</artifactId>
        </dependency>

2. 然后是添加MongoDB相关配置

# mongodb相关设置
spring.data.mongodb.authentication-database=admin
spring.data.mongodb.database=local
spring.data.mongodb.host=127.0.0.1
spring.data.mongodb.port=27017
#spring.data.mongodb.username=admin
#spring.data.mongodb.password=admin

各注释项内容依次是：身份验证库、目标数据库、主机地址、端口以及用户名和口令

由于我没有设置用户名和口令，所以直接注释掉这两项

3. 新建 repository/PersonRepository

package com.example.hellospringboot.repository;

import com.example.hellospringboot.model.Person;
import org.springframework.data.mongodb.repository.MongoRepository;
import org.springframework.stereotype.Repository;

@Repository
public interface PersonRepository extends MongoRepository<Person, Integer> {
    Person findByNameIs(String name);
    Person findByIdIs(int id);
    Person findByIdAndName(int id, String name);
    Person findByIdOrName(int id, String name);
}

这里出现了非常神奇的一幕：

我们仅需要提供一个接口，而不用提供具体实现！

仅凭方法的命名规范，spring.data.mongodb就能自行分析开发者的意图，进行补全内部的业务逻辑！

而同样具备这种智能化能力的还有spring.jpa，后者也是一种非常便捷高效数据库驱动，与mybatis属于同类产品

顺便也给大家提供一份方法命名规范清单，请各位在方法命名时务必遵循以下规则：

关键字	方法命名	sql where字句
And	findByNameAndPwd	where name= ? and pwd =?
Or	findByNameOrSex	where name= ? or sex=?
Is,Equals	findById,findByIdEquals	where id= ?
Between	findByIdBetween	where id between ? and ?
LessThan	findByIdLessThan	where id < ?
LessThanEqual	findByIdLessThanEqual	where id <= ?
GreaterThan	findByIdGreaterThan	where id > ?
GreaterThanEqual	findByIdGreaterThanEqual	where id > = ?
After	findByIdAfter	where id > ?
Before	findByIdBefore	where id < ?
IsNull	findByNameIsNull	where name is null
isNotNull,NotNull	findByNameNotNull	where name is not null
Like	findByNameLike	where name like ?
NotLike	findByNameNotLike	where name not like ?
StartingWith	findByNameStartingWith	where name like '?%'
EndingWith	findByNameEndingWith	where name like '%?'
Containing	findByNameContaining	where name like '%?%'
OrderBy	findByIdOrderByXDesc	where id=? order by x desc
Not	findByNameNot	where name <> ?
In	findByIdIn(Collection<?> c)	where id in (?)
NotIn	findByIdNotIn(Collection<?> c)	where id not in (?)
True	findByAaaTue	where aaa = true
False	findByAaaFalse	where aaa = false
IgnoreCase	findByNameIgnoreCase	where UPPER(name)=UPPER(?)

4. Service接口定义及实现

package com.example.hellospringboot.service;

import com.example.hellospringboot.model.Person;

public interface MongoService {
    public void insert(Person person);
    public Person findByName(String name);
    public Person findById(int id);
    public Person findByIdAndName(int id, String name);
    public Person findByIdOrName(int id, String name);
}

package com.example.hellospringboot.service.impl;

import com.example.hellospringboot.model.Person;
import com.example.hellospringboot.repository.PersonRepository;
import com.example.hellospringboot.service.MongoService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

@Service
public class MongoServiceImpl implements MongoService {

    @Autowired
    PersonRepository repository;

    public void insert(Person person){
        repository.insert(person);
    }

    public Person findByName(String name){
        return repository.findByNameIs(name);
    }

    public Person findById(int id){
        return repository.findByIdIs(id);
    }

    public Person findByIdAndName(int id, String name){
        return repository.findByIdAndName(id, name);
    }

    public Person findByIdOrName(int id, String name){
        return repository.findByIdOrName(id, name);
    }
}

5. Controller实现

package com.example.hellospringboot.controller;

import com.example.hellospringboot.model.Person;
import com.example.hellospringboot.service.MongoService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
@RequestMapping("/mongo")
public class MongoController {

    @Autowired
    MongoService service;

    @PostMapping("/insert")
    public void insert(Person person){
        service.insert(person);
    }

    @GetMapping("/findByName")
    public Person findByName(String name){
        return service.findByName(name);
    }

    @GetMapping("/findById")
    public Person findById(int id){
        return service.findById(id);
    }

    @GetMapping("/findByIdAndName")
    public Person findByIdAndName(int id, String name){
        return service.findByIdAndName(id, name);
    }

    @GetMapping("/findByIdOrName")
    public Person findByIdOrName(int id, String name) {
        return service.findByIdOrName(id, name);
    }
}

Service及Controller的实现不再做过多赘述，还是老一套

6. Postman验证结果

向mongodb中写入一条数据

之后是几种读取操作：

不论是与或操作，我们都可以得到正确的结果

到这里，mongodb的集成就完成了

三、基于Redis实现Session配置共享

这部分纯属附送内容 ^ ^

前边我们已经完成了对Redis的集成操作，而基于Redis我们可以非常便捷的实现服务端Session配置的跨节点共享

服务端Session默认存储在本地，而当我们需要多台服务器共享一套Session配置时，本地化Session便不再满足我们的要求

而基于SpringSession，我们可以完全透明化的替换掉默认的Session容器，直接改为基于Redis存储

1. 添加相关依赖

 <!-- 引入spring session无缝替换原有的session系统 -->
        <dependency>
            <groupId>org.springframework.session</groupId>
            <artifactId>spring-session-data-redis</artifactId>
        </dependency>

2. 新增两个RedisController方法

@PostMapping("/setSession")
    public void setSession(String key, String val, HttpSession session){
        session.setAttribute(key, val);
    }

    @GetMapping("/getSession")
    public Object getSession(String key, HttpSession session){
        return session.getAttribute(key);
    }

就完事儿了？对！就完事儿了 ^ ^，超级简单是吧？

到此，我们就完成了SpringBoot对于Redis以及MongoDB的集成和使用

非常感慨于SpringBoot框架设计的智能化及人性化，就像身边有一哥们说的：这年头，框架都能直接听懂人话了！哈哈

到此这篇关于SpringBoot整合redis及mongodb的文章就介绍到这了,更多相关SpringBoot整合redis内容请搜索程序员之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持程序员之家！

您可能感兴趣的文章:

MongoDB Shell 命令实例总结【进阶篇】
这篇文章主要介绍了MongoDB Shell 命令,结合实例形式总结分析了MongoDB数据库常用的查询、更新、插入、集合、函数等相关操作技巧与注意事项,需要的朋友可以参考下
2019-02-02
C#实现窗体中的各个控件同比自动放缩大小
这篇文章主要介绍了C#实现窗体中的各个控件同比自动放缩大小,实现方式主要是利用panel控件为主题,对于每个控件的大小位置和字体这几个属性进行记录,然后根据窗体改变的大小同时放缩,需要的朋友可以参考下
2014-10-10
java操作mongoDB查询的实例详解
这篇文章主要介绍了java操作mongo查询的实例详解的相关资料,希望通过本文能帮助到大家，需要的朋友可以参考下
2017-09-09
MongoDB连接本地失败的原因及解决办法
这篇文章主要介绍了MongoDB连接本地失败解决办法,错误原因是没有启动mongo服务，所以启动失败，只要把mongo服务启动就好了，需要的朋友可以参考下
2023-05-05
MongoDB释放空闲空间的几种常用方法
这篇文章主要给大家介绍了关于MongoDB释放空闲空间的几种常用方法，分别包括compact、db.repairDatabase()、secondary节点重同步以及db.copyDatabase()这几种方法，需要的朋友可以参考借鉴，下面来一起看看吧
2018-07-07
分布式文档存储数据库之MongoDB访问控制的操作方法
这篇文章主要介绍了分布式文档存储数据库之MongoDB访问控制的操作方法,本文通过实例代码给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下
2020-11-11
MongoDB学习以及集群搭建的实践全纪录
这篇文章主要给大家介绍了关于MongoDB学习以及集群搭建的相关资料，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
2018-09-09
MongoDB卸载安装的详细安装教程
MongoDB是一个是一个基于分布式文件存储的数据库,下面这篇文章主要给大家介绍了关于MongoDB卸载安装的相关资料,文中通过实例代码介绍的非常详细,需要的朋友可以参考下
2023-04-04
深入讲解MongoDB的慢日志查询（profile）
在MySQL中，慢查询日志是经常作为我们优化数据库的依据，那在MongoDB中是否有类似的功能呢?答案是肯定的，那就是MongoDB Database Profiler。下面这篇文章主要给大家介绍了关于MongoDB慢日志查询（profile）的相关资料，需要的朋友可以参考下。
2017-06-06
Mongodb常用的身份验证方式
对MongoDB部署启用访问控制会强制执行用户身份验证，要求在登录MongoDB系统用户识别自己。当访问启用了访问控制的MongoDB部署时，用户只能执行由其角色确定的操作。
2017-08-08