欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

如何优雅的进行Spring整合MongoDB详解

程序员文章站 2022-07-28 15:49:57
前言 本文重点是要将mongodb与spring整合到项目中去,在实践中发现问题,追踪问题,然后解决问题。下面话不多说了,来一起看看详细的介绍吧。 一、准备...

前言

本文重点是要将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();
 }
 }
}

总结

以上就是这篇文章的全部内容了,希望本文的内容对大家的学习或者工作具有一定的参考学习价值,如果有疑问大家可以留言交流,谢谢大家对的支持。