MongoDB客户端封装-MongoDS

介绍

针对MongoDB客户端封装。客户端需自行引入依赖。

使用

引入依赖

  1. <dependency>
  2.     <groupId>org.mongodb</groupId>
  3.     <artifactId>mongo-java-driver</artifactId>
  4.     <version>3.8.1</version>
  5. </dependency>

配置

在ClassPath（或者src/main/resources）的config目录下下新建mongo.setting

  1. #--------------------------------------
  2. # MongoDB 连接设定
  3. # author xiaoleilu
  4. #--------------------------------------
  6. #每个主机答应的连接数（每个主机的连接池大小），当连接池被用光时，会被阻塞住 ，默以为10 --int
  7. connectionsPerHost=100
  8. #线程队列数，它以connectionsPerHost值相乘的结果就是线程队列最大值。如果连接线程排满了队列就会抛出“Out of semaphores to get db”错误 --int
  9. threadsAllowedToBlockForConnectionMultiplier=10
  10. #被阻塞线程从连接池获取连接的最长等待时间（ms） --int
  11. maxWaitTime = 120000
  12. #在建立（打开）套接字连接时的超时时间（ms），默以为0（无穷） --int
  13. connectTimeout=0
  14. #套接字超时时间;该值会被传递给Socket.setSoTimeout(int)。默以为0（无穷） --int
  15. socketTimeout=0
  16. #是否打开长连接. defaults to false --boolean
  17. socketKeepAlive=false
  19. #---------------------------------- MongoDB实例连接
  20. [master]
  21. host = 127.0.0.1:27017
  23. [slave]
  24. host = 127.0.0.1:27018
  25. #-----------------------------------------------------

使用

  1. //master slave 组成主从集群
  2. MongoDatabase db = MongoFactory.getDS("master", "slave").getDb("test");