Springboot整合mongo

引言

springboot整合是采用原生的mongo-driver 来实现，可以动态链接多个库，无需关注整合springboot，只要自己实现springboot-starter。快速入门文档：http://mongodb.github.io/mongo-java-driver/3.11/driver/getting-started/quick-start/#mongodb-driver-quick-start 。介绍的非常详细，完全可以操作入门。

pom依赖

本文采用的版本号是3.10.2版本

<dependency><groupId>org.mongodb</groupId><artifactId>mongodb-driver-sync</artifactId><version>3.10.2</version></dependency><dependency><groupId>com.alibaba</groupId><artifactId>fastjson</artifactId><version>2.0.1</version></dependency>

只需要你在springboot框架中引入俩个依赖就可以操作，用原生的去操作更加灵活，个人不介意用mongo-template 用起来很不方便。

代码整合

配置文件参数

1、application.properties文件中加以下参数
server.port= 9009

mongo.properties.userName = bikeBos
#密码我这边不做展示了，自己的mongo 库的密码
mongo.properties.password = ****
mongo.properties.database = bikeBos

2、新增一个spring.factories文件
文件参数：
org.springframework.boot.autoconfigure.EnableAutoConfiguration=
com.example.demo.mongo.MongoConfig

代码实现

采用springboot-starter的形式的去进行实现

package com.example.demo.config;import com.example.demo.dao.MongoDao;
import org.springframework.boot.context.properties.EnableConfigurationProperties;
import org.springframework.context.ApplicationListener;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.event.ContextRefreshedEvent;import javax.annotation.Resource;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;/*** @Author: xiaozhu13539* @Date: 2022/4/27*/
@Configuration
@EnableConfigurationProperties(MongoProperties.class)
public class MongoConfig implements ApplicationListener<ContextRefreshedEvent> {@Resourceprivate MongoProperties mongoProperties;@Resourceprivate MongoDao mongoDao;@Overridepublic void onApplicationEvent(ContextRefreshedEvent contextRefreshedEvent) {mongoDao.buildMongoClient(mongoProperties);}
}

加载的实体参数：

package com.example.demo.config;import lombok.Data;
import org.springframework.boot.context.properties.ConfigurationProperties;/*** @Author: xiaozhu13539* @Date: 2022/4/27*/
@ConfigurationProperties(prefix = "mongo.properties")
@Data
public class MongoProperties {private String userName;private String password;private String database;private String ip;private Integer port;}

构建mongoClient 和 Dao提供对外的查询方法，这里举例根据主键查询，其余的api根据我上面提供的快速入门来进行封装。

package com.example.demo.dao;import com.alibaba.fastjson.JSONObject;
import com.example.demo.config.MongoProperties;
import com.mongodb.MongoClientSettings;
import com.mongodb.MongoCredential;
import com.mongodb.ServerAddress;
import com.mongodb.client.*;
import com.mongodb.client.model.Filters;
import org.bson.Document;
import org.bson.conversions.Bson;
import org.springframework.stereotype.Service;import java.util.Arrays;
import java.util.concurrent.ConcurrentHashMap;/*** @Author: xiaozhu13539* @Date: 2022/4/28*/
@Service
public class MongoDao {//缓存client的数据源private final ConcurrentHashMap<String, MongoClient> daoMap = new ConcurrentHashMap<>();/*** client* @param mongoProperties*/public void buildMongoClient(MongoProperties mongoProperties) {String userName = mongoProperties.getUserName();String password = mongoProperties.getPassword();String database = mongoProperties.getDatabase();MongoCredential credential = MongoCredential.createCredential(userName, database, password.toCharArray());MongoClientSettings settings = MongoClientSettings.builder().credential(credential)//.applyToSslSettings(builder -> builder.enabled(true)).applyToClusterSettings(builder ->//ip 是mongo服务器的主机builder.hosts(Arrays.asList(new ServerAddress("127.0.0.1", 27017)))).build();MongoClient mongoClient = MongoClients.create(settings);daoMap.put("test", mongoClient);}/*** 获取注解* @param bikeNo* @return*/public String getDataByUk(String bikeNo) {Bson bson = Filters.eq("bikeNo", "2100009315");MongoClient mongoClient = daoMap.get("test");MongoCollection<Document> mongoCollection = mongoClient.getDatabase("bikeBos").getCollection("bik4c");FindIterable<Document> documents = mongoCollection.find(bson);String result = "";for (Document document : documents) {result = JSONObject.toJSONString(document);break;}return result;}
}

整合很简单，深入得继续去研究mongo的官方文档。