Verwenden Sie einen einzelnen MongoClient über einen JavaEE-Webservice

Question

Nachdem ich die Mongo-Dokumentation gelesen habe, die besagt, dass jede MongoClient-Instanz ihr eigenes Pooling handhabt, wie würde ich dann nur eine Instanz für meine gesamte Anwendung verwenden?

Dies scheint, als könnte es ein Szenario für die Verwendung einer Singleton-Bean sein, aber dies scheint, wie es den Zweck der Verbindungspooling besiegen würde. Wenn nur ein Benutzer gleichzeitig auf die Bean zugreifen könnte, die die MongoClient-Instanz enthält, werden mehrere Verbindungen im Pool niemals gleichzeitig verwendet.

Habe ich mein Verständnis von Singletons falsch verstanden, oder ist das wirklich der richtige Weg?

Answer 1

aber dies scheint, wie es den Zweck der Verbindung pooling.If besiegen würde nur ein Benutzer die Bean zuzugreifen wäre in der Lage, die die MongoClient Instanz zu einer Zeit enthält, sicherlich mehrere Verbindungen im Pool würde nie gleichzeitig benutzt werden.

The javadoc sagt:

Der Java MongoDB-Treiber Thread-sicher ist. Wenn Sie z. B. in einer Web- Serverumgebung arbeiten, sollten Sie eine einzige MongoClient-Instanz erstellen, die Sie in jeder Anfrage verwenden können. Das MongoClient-Objekt verwaltet einen internen Pool von Verbindungen zur -Datenbank (Standardgröße für den maximalen Pool von 100). Für jede Anfrage an die DB (find, insert, etc) erhält der Java-Thread eine Verbindung vom Pool , führt den Vorgang aus und gibt die Verbindung frei. Diese bedeutet, dass die verwendete Verbindung (Buchse) jedes Mal anders sein kann.

Also, wenn Sie ein Singleton mit dem Client darin erstellen. Es kann wie im Javadoc erwähnt wiederverwendet werden. Es ist keine Synchronisation erforderlich, da es Thread-sicher ist.

Wie würde ich vorgehen, nur eine Instanz über meine gesamte Anwendung zu haben?

Einer der Implementierungen könnte sein:

public enum ConnectionFactory { 
    CONNECTION; 
    private MongoClient client = null; 

    private ConnectionFactory() { 
     try { 
      client = new MongoClient(); 
     } catch (Exception e) { 
      // Log it. 
     } 
    } 

    public MongoClient getClient() { 
     if (client == null) 
      throw new RuntimeException(); 
     return client; 
    } 
} 

und verwenden Sie den Client wie in der gesamten Anwendung. Connection pooling wird durch die MongoClient wie dokumentiert.

MongoClient client = ConnectionFactory.CONNECTION.getClient(); 

oder verwenden Sie die @singleton Anmerkung:

@Singleton 
public class SingletonA { 

} 

Siehe: http://tomee.apache.org/singleton-example.html

Answer 2

Da Sie in einem Java EE-Umgebung sind, ist der beste Weg, dies CDI Hersteller verwenden zu implementieren wäre:

@Stateless 
public class ConnetionFactory { 

    @ApplicationScoped 
    @Produces 
    public MongoClient mongoClient() { 
    return new MongoClient(); 
    } 
} 

Dann in jeder Bohne, die Sie es verwenden möchten:

@Stateless 
public class MyServiceBean { 

    @Inject 
    private MongoClient mongoClient; 
}