深圳罗湖网站制作,网络挣钱,cn域名网站,wordpress官网的文档在本文中#xff0c;我将介绍如何从无状态Java EE应用程序连接到MongoDB#xff0c;以利用与MongoDB Java驱动程序提供的数据库的内置连接池。 如果您开发的REST API对MongoDB执行操作#xff0c;则可能是这种情况。 获取Java MongoDb驱动程序 要将Java连接到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 SetString getCollectionNames(){MongoClient mongoClient mongoClientProvider.getMongoClient();DB db mongoClient.getDB(myMongoDB); SetString 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
