在本文中，我将介绍如何从无状态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
