如何优雅的进行Spring整合MongoDB详解
前言
本文重点是要将mongodb与spring整合到项目中去，在实践中发现问题，追踪问题，然后解决问题。下面话不多说了，来一起看看详细的介绍吧。
一、准备
- Maven、Spring(spring-data-mongodb)
- spring Data for MongoDB是Spring Data的一个子模块。 目标是为mongodb提供一个相近的一致的基于Spring的编程模型。
- Spring Data for MongoDB核心功能是映射POJO到Mongo的DBCollection中的文档，并且提供Repository 风格数据访问层。
二、特性
- MongoDB的提供了一个面向文档存储，操作起来比较简单和容易。
- 你可以在MongoDB记录中设置任何属性的索引 (如：FirstName="Ning",Address="Beijing")来实现更快的排序。
- 你可以通过本地或者网络创建数据镜像，这使得MongoDB有更强的扩展性。
- 如果负载的增加（需要更多的存储空间和更强的处理能力） ，它可以分布在计算机网络中的其他节点上这就是所谓的分片。
- Mongo支持丰富的查询表达式。查询指令使用JSON形式的标记，可轻易查询文档中内嵌的对象及数组。
- MongoDb 使用update()命令可以实现替换完成的文档（数据）或者一些指定的数据字段 。
- Mongodb中的Map/reduce主要是用来对数据进行批量处理和聚合操作。
- Map和Reduce。Map函数调用emit(key,value)遍历集合中所有的记录，将key与value传给Reduce函数进行处理。
- Map函数和Reduce函数是使用Javascript编写的，并可以通过db.runCommand或mapreduce命令来执行MapReduce操作。
- GridFS是MongoDB中的一个内置功能，可以用于存放大量小文件。
- MongoDB允许在服务端执行脚本，可以用Javascript编写某个函数，直接在服务端执行，也可以把函数的定义存储在服务端，下次直接调用即可。
- MongoDB支持各种编程语言:RUBY，PYTHON，JAVA，C++，PHP，C#等多种语言。
三、依赖包
<dependency> <groupId>org.springframework.data</groupId> <artifactId>spring-data-mongodb</artifactId> <version>1.5.0.RELEASE</version> </dependency> <dependency> <groupId>org.slf4j</groupId> <artifactId>slf4j-log4j12</artifactId> <version>1.5.10</version> </dependency>
spring 相关依赖
<!-- spring web相关依赖 -->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-web</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-webmvc</artifactId>
<version>3.1.2.RELEASE</version>
</dependency>
<!-- spring test依赖 -->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-test</artifactId>
<version>4.3.1.RELEASE</version>
</dependency>
四、集成MongoDB
【注：MongoDB添加权限管理请参见我的这篇文章:MongDB开启权限认证】
mongodb.properties
mongo.hostport=172.16.4.166:27017 mongo.dbname=ad_api_count mongo.username=hehaitao mongo.password=hehaitao mongo.connectionsPerHost=8 mongo.threadsAllowedToBlockForConnectionMultiplier=4 #\u8FDE\u63A5\u8D85\u65F6\u65F6\u95F4 mongo.connectTimeout=1000 #\u7B49\u5F85\u65F6\u95F4 mongo.maxWaitTime=1500 mongo.autoConnectRetry=true mongo.socketKeepAlive=true #Socket\u8D85\u65F6\u65F6\u95F4 mongo.socketTimeout=1500 mongo.slaveOk=true
mongoDB.xml
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:context="http://www.springframework.org/schema/context"
xmlns:mongo="http://www.springframework.org/schema/data/mongo"
xsi:schemaLocation="http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context-3.1.xsd
http://www.springframework.org/schema/data/mongo
http://www.springframework.org/schema/data/mongo/spring-mongo-1.0.xsd
http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-3.1.xsd">
<!-- 加载mongodb的属性配置文件 -->
<context:property-placeholder location="classpath:mongodb.properties" ignore-unresolvable="true"/>
<!-- 定义mongo对象，对应的是mongodb官方jar包中的Mongo，replica-set设置集群副本的ip地址和端口 -->
<mongo:mongo id="mongo" replica-set="${mongo.hostport}">
<mongo:options
connections-per-host="${mongo.connectionsPerHost}"
threads-allowed-to-block-for-connection-multiplier="${mongo.threadsAllowedToBlockForConnectionMultiplier}"
connect-timeout="${mongo.connectTimeout}"
max-wait-time="${mongo.maxWaitTime}"
auto-connect-retry="${mongo.autoConnectRetry}"
socket-keep-alive="${mongo.socketKeepAlive}"
socket-timeout="${mongo.socketTimeout}"
slave-ok="${mongo.slaveOk}"
write-number="1"
write-timeout="0"
write-fsync="true"/>
</mongo:mongo>
<mongo:db-factory id="mgFactory"
dbname="${mongo.dbname}"
username="${mongo.username}"
password="${mongo.password}"
mongo-ref="mongo" />
<bean id="mongoTemplate" class="org.springframework.data.mongodb.core.MongoTemplate">
<constructor-arg name="mongoDbFactory" ref="mgFactory"/>
</bean>
</beans>
spring-contex.xml
<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:context="http://www.springframework.org/schema/context" xmlns:tx="http://www.springframework.org/schema/tx" xmlns:aop="http://www.springframework.org/schema/aop" xmlns:task="http://www.springframework.org/schema/task" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.1.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.1.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.1.xsd http://www.springframework.org/schema/task http://www.springframework.org/schema/task/spring-task-3.1.xsd"> <aop:aspectj-autoproxy proxy-target-class="true"/> <!--使用注解管理bean --> <context:annotation-config/> <!-- 扫描com.lutongnet下的所有类 --> <context:component-scan base-package="com.lutong.cps"> <context:exclude-filter type = "annotation" expression = "org.springframework.stereotype.Controller"/> </context:component-scan> <import resource="mongoDB.xml"/> </beans>
五、代码实现
基础实现MongoDBService
/**
* File Name : MongoDBService.java
* Package : com.lutongnet.ad.service
* Description : TODO
* Author : zhangfj
* Date : 2012-11-29
* Version : V1.0
*/
package com.lutong.cps.schedule.service.fj;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.data.mongodb.core.query.Query;
import org.springframework.stereotype.Service;
/**
* @author zhangfj
*
*/
@Service("mongoDBService")
public class MongoDBService
{
/*@Resource(name = "mongoTemplate")
protected MongoTemplate mongoTemplate;*/
/**
*
* @param query
* @param entityClass
* @return T
*/
public <T> T findOne(Query query, Class<T> entityClass)
{
ApplicationContext context=new ClassPathXmlApplicationContext("mongoDB.xml");
MongoTemplate mongoTemplate= (MongoTemplate) context.getBean("mongoTemplate");
// 可以直接调用
return mongoTemplate.findOne(query, entityClass);
}
}
继承类UserAdCountService
/**
* File Name : UserAdCountService.java
* Package : com.lutongnet.ad.service
* Description : TODO
* Author : zhangfj
* Date : 2012-11-29
* Version : V1.0
*/
package com.lutong.cps.schedule.service.fj;
import org.springframework.data.mongodb.core.query.Criteria;
import org.springframework.data.mongodb.core.query.Query;
import org.springframework.stereotype.Service;
import com.lutong.cps.schedule.entity.UserAdCount;
/**
* @author zhangfj
*
*/
@Service("userAdCountService")
public class UserAdCountService extends MongoDBService
{
/**
* 获取单个广告的观看次数，查询不到则返回0
*
* @param adCode
* @return int
*/
public int getUserAdCount(UserAdCount adCode)
{
Criteria criteria = new Criteria();
criteria.andOperator(Criteria.where("userAd").is(adCode.getUserAd()),
Criteria.where("adCode").is(adCode.getAdCode()),
Criteria.where("countDate").is(adCode.getCountDate()));
Query query = new Query(criteria);
UserAdCount result = findOne(query, UserAdCount.class);
if (null != result)
{
return result.getTimesCount();
}
return 0;
}
}
实体类UserAdCount
package com.lutong.cps.schedule.entity;
import java.util.Date;
import org.springframework.data.annotation.PersistenceConstructor;
import org.springframework.data.mongodb.core.mapping.Document;
/**
* mongo专用统计单个用户的单个广告观看次数
* @author cancer
*
*/
@Document(collection="userAdCount")
public class UserAdCount
{
private int timesCount;
/**
* 用户账号
*/
private String userAd;
private String adCode;
private String countDate;
private Date expireAt;
@PersistenceConstructor
public UserAdCount(int timesCount, String userAd,String adCode,String countDate,Date expireAt)
{
this.timesCount = timesCount;
this.userAd = userAd;
this.adCode = adCode;
this.countDate = countDate;
this.expireAt = expireAt;
}
public UserAdCount(String userAd,String adCode,String countDate)
{
this.userAd = userAd;
this.adCode = adCode;
this.countDate = countDate;
}
public UserAdCount(String userAd,String adCode,String countDate,Date expireAt)
{
this.userAd = userAd;
this.adCode = adCode;
this.countDate = countDate;
this.expireAt = expireAt;
}
public UserAdCount(String countDate)
{
this.countDate = countDate;
}
public int getTimesCount()
{
return timesCount;
}
public void setTimesCount(int timesCount)
{
this.timesCount = timesCount;
}
public String getUserAd()
{
return userAd;
}
public void setUserAd(String userAd)
{
this.userAd = userAd;
}
public String getAdCode()
{
return adCode;
}
public void setAdCode(String adCode)
{
this.adCode = adCode;
}
public String getCountDate() {
return countDate;
}
public void setCountDate(String countDate) {
this.countDate = countDate;
}
public Date getExpireAt() {
return expireAt;
}
public void setExpireAt(Date expireAt) {
this.expireAt = expireAt;
}
}
最后写一个测试类来测试下
import java.util.List;
import javax.annotation.Resource;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
import com.acts.web.modules.mark.model.Users;
import com.lutong.cps.schedule.service.fj.UserAdCountService;
@ContextConfiguration({ "classpath:spring-context.xml",
"classpath:mongoDB.xml"})
@RunWith(SpringJUnit4ClassRunner.class)
public class UserTest {
@Resource(name = "userAdCountService")
private UserAdCountService userAdCountService;
@Test
public void testDao() {
try {
UserAdCount userAdCount = new UserAdCount("hehaitao", "pos001",
DateTime.now().toString("yyyy-MM-dd"));
int count = userAdCountService
.getUserAdCount(userAdCount);
System.out.println(count);
} catch (Exception e) {
e.printStackTrace();
}
}
}
总结
以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作具有一定的参考学习价值，如果有疑问大家可以留言交流，谢谢大家对我们的支持。
您可能感兴趣的文章:
- 详解springboot整合mongodb
- MongoDB整合Spring实例详细讲解(含代码)
- Spring + Spring Boot + MyBatis + MongoDB的整合教程
- 详解MongoDB和Spring整合的实例代码
相关推荐
-
Spring + Spring Boot + MyBatis + MongoDB的整合教程
前言 我之前是学Spring MVC的,后面听同学说Spring Boot挺好用,极力推荐我学这个鬼.一开始,在网上找Spring Boot的学习资料,他们博文写得不是说不好,而是不太详细. 我就在想我要自己写一篇尽可能详细的文章出来,下面话不多说了,来一看看详细的介绍吧. 技术栈 Spring Spring Boot MyBatis MongoDB MySQL 设计模式 MVC 功能 注册(用户完成注册后是默认未激活的,程序有个定时器在检测没有激活的用户,然后发一次邮件提醒用户激活) 登录 发
-
MongoDB整合Spring实例详细讲解(含代码)
写这篇文章也做了下思考,首先是本人技术欠佳.但就是喜欢研究一些东西.因为在此之前有很多的朋友已经写过类似的,很多我也看过,但是讲解的不够深入.对有些朋友提出的问题不能给出答案.在这里,我根据我目前的能力对其进行整理.并最终运行成功. 在测试过程中出现过一下问题: 1.org/springframework/data/mapping/context/MappingContextAware 2.src-resolve: Cannot resolve the name 'repository:repo
-
详解MongoDB和Spring整合的实例代码
MongoDB现在用的非常非常多,如何和Spring整合也是经常碰到的问题. Spring提供了MongoTemplate这样一个模板类的实现方法,简化了具体操作. 下面讲一下具体实现: 添加依赖 <dependency> <groupId>org.springframework.data</groupId> <artifactId>spring-data-mongodb</artifactId> <version>1.10.3.RE
-
详解springboot整合mongodb
这篇文章主要介绍springboot如何整合MongoDB. 准备工作 安装 MongoDB jdk 1.8 maven 3.0 idea 环境依赖 在pom文件引入spring-boot-starter-data-mongodb依赖: <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-mongodb</artifa
-
如何优雅的进行Spring整合MongoDB详解
前言 本文重点是要将mongodb与spring整合到项目中去,在实践中发现问题,追踪问题,然后解决问题.下面话不多说了,来一起看看详细的介绍吧. 一.准备 Maven.Spring(spring-data-mongodb) spring Data for MongoDB是Spring Data的一个子模块. 目标是为mongodb提供一个相近的一致的基于Spring的编程模型. Spring Data for MongoDB核心功能是映射POJO到Mongo的DBCollection中的文档,
-
Spring整合Junit详解
目录 1,整合Junit4 2,整合Junit5 1,整合Junit4 maven引入spring-test 和 junit4 <dependency> <groupId>org.springframework</groupId> <artifactId>spring-test</artifactId> <version>5.2.22.RELEASE</version> </dependency> <de
-
Junit写法及与spring整合过程详解
junit之前的写法: //在Before中注入service类 private IUserService userService; @Before public void setUp() throws Exception { //使用xml的方式 ApplicationContext applicationContext = new ClassPathXmlApplicationContext("applicationContext.xml"); //使用注解的方式 Applicat
-
spring Boot与Mybatis整合优化详解
SpringBoot官方文档http://docs.spring.io/spring-boot/docs/current/reference/htmlsingle/ 关于spring-boot与mybatis整合优化方面的介绍,就是Mybatis-Spring-boot-starter的介绍: 1.取消spring-mybatis.xml配置 ①自动检测已存在的Datasource 之前,需要在spring-mybatis.xml中配置datasource的Bean,现在只需要在applicat
-
Spring Boot示例代码整合Redis详解
目录 Redis 简介 Redis 优势 Redis与其他key-value存储有什么不同 添加Redis依赖包 配置Redis数据库连接 编写Redis操作工具类 测试 Redis 简介 Redis 是完全开源的,遵守 BSD 协议,是一个高性能的 key-value 数据库. Redis 与其他 key - value 缓存产品有以下三个特点: Redis支持数据的持久化,可以将内存中的数据保存在磁盘中,重启的时候可以再次加载进行使用. Redis不仅仅支持简单的key-value类型的数据
-
Spring boot整合security详解
目录 前言 配置依赖 用户配置 1.内存用户存储 2.数据库用户存储 3.LDAP用户存储 4.自定义用户存储 拦截配置 前言 在进行框架选型时最常用的选择就是在Spring security 和Shiro中进行抉择,Spring security 和 shiro 一样,都具有认证.授权.加密等用于权限管理的功能.但是对于Springboot而言,Spring Security比Shiro更合适一些,他们都是Spring生态里的内容,并且在使用上Spring boot只需要引入Security就
-
Spring Boot整合Thymeleaf详解
目录 Thymeleaf 基本介绍 基本语法 th:text文本替换 th:if和th:unless文本替换 th:each foreach循环 th:id.th:value.th:checked等(和form表单相关) 整合Thymeleaf 基本配置 三层架构 删除操作 编辑操作 用户登录 用户注销 点击注销用户 Thymeleaf 基本介绍 Spring Boot 官方推荐使用 Thymeleaf 作为其模板引擎.SpringBoot 为 Thymeleaf 提供了一系列默认配置,并且为T
-
springboot与mybatis整合实例详解(完美融合)
简介 从 Spring Boot 项目名称中的 Boot 可以看出来,Spring Boot 的作用在于创建和启动新的基于 Spring 框架的项目.它的目的是帮助开发人员很容易的创建出独立运行和产品级别的基于 Spring 框架的应用.Spring Boot 会选择最适合的 Spring 子项目和第三方开源库进行整合.大部分 Spring Boot 应用只需要非常少的配置就可以快速运行起来. Spring Boot 包含的特性如下: 创建可以独立运行的 Spring 应用. 直接嵌入 Tomc
-
spring缓存代码详解
本文研究的主要是spring缓存的相关内容,具体介绍如下. 这篇文章是根据谷歌翻译大致修改出来的,由于原文不知道是什么语,所以可能导致翻译的有错误和不准确的地方,但是大致的方向感觉还是蛮不错的,所以在这里整理了一下,希望能够有所帮助. 高速缓存一直是一个非常需要这两个提高应用程序性能并降低其工作量.此外,它的用处今天是特别明显,可以作出处理成千上万的游客concurrents.D'un架构上的Web应用,高速缓存管理正交于应用程序的业务逻辑和出于这个原因,应该对应用程序本身的发展产生的影响最小.
-
SpringBoot如何整合nacos详解
一.什么是nacos nacos支持基于dns和基于rpc的服务发现,可以作为springCloud的注册中心.动态配置服务.动态dns服务. nacos注册中心分为server和client,server采用java编写,为client提供注册发现与配置服务. 二.快速使用 下载中间件:https://nacos.io/zh-cn/docs/quick-start.html 因为推荐使用的是2.0.1版本,我这里下载2.0.1版本. 注意:下载文件放在英文目录下 三.启动nacos 解压nac