如何从Java EE无状态应用程序连接到MongoDB

在本文中，我将介绍如何从无状态Java EE应用程序连接到MongoDB，以利用与MongoDB Java驱动程序提供的数据库的内置连接池。如果您开发的REST API对MongoDB执行操作，则可能是这种情况。

获取Java MongoDb驱动程序

要将Java连接到MongoDB，可以使用Java MongoDB Driver 。如果使用Maven构建应用程序，则可以将依赖项添加到pom.xml文件中：

MongoDB Java驱动程序依赖性

org.mongodbmongo-java-driver2.12.3

该驱动程序为MongoDB客户端（com.mongodb.MongoClient）提供了内部池。 MongoClient类被设计为线程安全的并在线程之间共享。对于大多数应用程序，整个JVM应该具有一个MongoClient安装。因此，您不希望在Java EE无状态应用程序中为每个请求创建一个新的MongoClient实例。

实现一个@Singleton EJB

一个简单的解决方案是使用@Singleton EJB来保存MongoClient：

Singleton持有MongoClient

package org.codingpedia.demo.mongoconnection;import java.net.UnknownHostException;import javax.annotation.PostConstruct;
import javax.ejb.ConcurrencyManagement;
import javax.ejb.ConcurrencyManagementType;
import javax.ejb.Lock;
import javax.ejb.LockType;
import javax.ejb.Singleton;import com.mongodb.MongoClient;@Singleton
@ConcurrencyManagement(ConcurrencyManagementType.CONTAINER)
public class MongoClientProvider {private MongoClient mongoClient = null;@Lock(LockType.READ)public MongoClient getMongoClient(){ return mongoClient;}@PostConstructpublic void init() {String mongoIpAddress = "x.x.x.x";Integer mongoPort = 11000;try {mongoClient = new MongoClient(mongoIpAddress, mongoPort);} catch (UnknownHostException e) {// TODO Auto-generated catch blocke.printStackTrace();}     }}

注意：

@Singleton –可能是此类中最重要的代码行。此注释指定在应用程序中将仅存在一个这种类型的bean的单例。该bean可以由多个线程同时调用。它还带有@PostConstruct批注。此注释用于需要依赖注入完成后才能执行任何初始化的方法上（在我们的情况下是初始化MongoClient）
@ConcurrencyManagement(ConcurrencyManagementType.CONTAINER)声明单例会话bean的并发管理类型。默认情况下，它设置为Container,在这里我仅用它来突出显示它的存在。另一个选项ConcurrencyManagementType.BEAN指定Bean开发人员负责管理对Bean实例的并发访问。
@Lock(LockType.READ)指定具有容器管理的并发性的单例bean的并发锁定类型。当设置为LockType.READ ，它将强制执行该方法以允许对其进行完全并发访问（假定未持有任何写锁）。这允许多个线程访问相同的MongoClient实例，并利用与数据库的内部连接池。这非常重要，因为另一个更保守的选项@Lock(LockType.WRITE)是DEFAULT，并强制对bean实例的独占访问。这应该在高度并发的环境中使方法变慢。

使用@Singleton EJB

现在您已经在应用程序中“保留了” MongoClient，您可以注入MongoClientProvider来访问MongoDB（例如，获取集合名称）：

从其他bean示例访问MongoClient

package org.codingpedia.demo.mongoconnection;import java.util.Set;import javax.ejb.EJB;
import javax.ejb.Stateless;import com.mongodb.BasicDBObject;
import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.DBObject;
import com.mongodb.MongoClient;
import com.mongodb.util.JSON;@Stateless
public class TestMongoClientProvider {@EJBMongoClientProvider mongoClientProvider;public Set<String> getCollectionNames(){MongoClient mongoClient = mongoClientProvider.getMongoClient();DB db = mongoClient.getDB("myMongoDB");     Set<String> colls = db.getCollectionNames();for (String s : colls) {System.out.println(s);}      return colls;}}

注意： db对象将是到指定数据库的MongoDB服务器的连接。有了它，您可以进行进一步的操作。我鼓励您阅读有关Java驱动程序入门的更多信息……

意识到

要记住的一方面：

“对于对数据库的每个请求（查找，插入等），Java线程都会从池中获取一个连接，执行该操作，然后释放该连接。 这意味着每次使用的连接（插座）可能不同。

此外，如果启用了slaveOk选项的副本集，则读取操作将在所有从属设备之间平均分配。 这意味着在同一个线程中，写入和读取之后的数据可能会发送到不同的服务器（主服务器然后是从服务器）。 反过来，由于复制是异步的，因此读取操作可能看不到刚刚写入的数据。 如果要确保“会话”（也许是http请求）中的完全一致性，则希望驱动程序使用相同的套接字，这可以通过使用“一致请求”来实现。 在操作之前调用requestStart（），然后调用requestDone（）将连接释放回池：

确保完整的一致性

DB db...;
db.requestStart();
try {db.requestEnsureConnection();code....
} finally {db.requestDone();
}

DB和DBCollection是完全线程安全的。 实际上，它们被缓存了，因此无论如何您都可以得到相同的实例。” [3]

资源资源

Java MongoDB驱动程序
Java驱动程序入门
Java驱动程序并发
GitHub – mongodb / mongo-java-driver示例

翻译自: https://www.javacodegeeks.com/2014/10/how-to-connect-to-mongodb-from-a-java-ee-stateless-application.html