Mongo连接在RESTful API中多次创建，从未发布

Question

我已经使用ApacheJersey编写了一个RESTful API。我使用MongoDB作为后端。我使用Morphia（v.1.3.4）将POJO映射并持久化到数据库。我试着按照各地推荐的API中的“1应用1连接”，但我不确定我是否成功。我在Tomcat 8中运行API。我还运行了Mongostat查看了详细信息和连接。开始时，Mongostat显示了1个到MongoDB服务器的连接。我使用Postman测试了我的API，它运行良好。然后，我在SoapUI中创建了一个负载测试，模拟每秒100个用户。我在Mongostat上看到了更新。我看到有103个连接。下面是显示这种行为的gif。

我不确定为什么有这么多连接。有趣的事实是mongo连接的数量与我在SoapUI上创建的用户数量成正比。为什么？我发现了其他类似的问题，但我想我已经实施了那里的建议。

Mongo连接泄漏与吗啡

Spring data mongodb未关闭mongodb连接

我的代码是这样的。

数据库连接。JAVA

// Some imports
public class DatabaseConnection {

    private static volatile MongoClient instance;
    private static String cloudhost="localhost";

    private DatabaseConnection() { }

    public synchronized static MongoClient getMongoClient() {
        if (instance == null ) {
            synchronized (DatabaseConnection.class) {
                if (instance == null) {
                    ServerAddress addr = new ServerAddress(cloudhost, 27017);
                    List<MongoCredential> credentialsList = new ArrayList<MongoCredential>();
                    MongoCredential credentia = MongoCredential.createCredential(
                        "test", "test", "test".toCharArray());
                    credentialsList.add(credentia);
                    instance = new MongoClient(addr, credentialsList); 

                }
            }
        }
        return instance;
    }
}

PourService。JAVA

@Secured
@Path("pours")
public class PourService {

final static Logger logger = Logger.getLogger(Pour.class);
private static final int POUR_SIZE = 30;

    @POST
    @Consumes(MediaType.APPLICATION_JSON)
    @Produces(MediaType.APPLICATION_JSON)
    public Response createPour(String request)
    {
        WebApiResponse response = new WebApiResponse();
        Gson gson = new GsonBuilder().setDateFormat("dd/MM/yyyy HH:mm:ss").create();
        String message = "Pour was not created.";
        HashMap<String, Object> data = null;
        try
        {
            Pour pour = gson.fromJson(request, Pour.class);

            // Storing the pour to 
            PourRepository pourRepository = new PourRepository();           
            String id = pourRepository.createPour(pour);

            data = new HashMap<String, Object>();
            if ("" != id && null != id)
            {
                data.put("id", id);
                message = "Pour was created successfully.";
                logger.debug(message);
                return response.build(true, message, data, 200);
            }

            logger.debug(message);
            return response.build(false, message, data, 500);
        }
        catch (Exception e)
        {
            message = "Error while creating Pour.";
            logger.error(message, e);
            return response.build(false, message, new Object(),500);
        }
    }

倒ao.java

public class PourDao extends BasicDAO<Pour, String>{

    public PourDao(Class<Pour> entityClass, Datastore ds) {
        super(entityClass, ds);
    }
}

Pourrespository。JAVA

public class PourRepository {

    private PourDao pourDao;

    final static Logger logger = Logger.getLogger(PourRepository.class);

    public PourRepository ()
    {
        try 
        {
            MongoClient mongoClient = DatabaseConnection.getMongoClient();
            Datastore ds = new Morphia().map(Pour.class)
                    .createDatastore(mongoClient, "tilt45");
            pourDao = new PourDao(Pour.class,ds);
        } 
        catch (Exception e) 
        {
            logger.error("Error while creating PourDao", e);
        }
    }

    public String createPour (Pour pour)
    {
        try
        {
            return pourDao.save(pour).getId().toString();
        }
        catch (Exception e)
        {
            logger.error("Error while creating Pour.", e);
            return null;
        }
    } 
 }

Answer 1

当我使用Mongo Morphia时，我使用数据存储的工厂模式而不是MongoClient获得了更好的结果，例如，检查以下类：

public DatastoreFactory(String dbHost, int dbPort, String dbName) {
    final Morphia morphia = new Morphia();
    MongoClientOptions.Builder options = MongoClientOptions.builder().socketKeepAlive(true);
    morphia.getMapper().getOptions().setStoreEmpties(true);
    final Datastore store = morphia.createDatastore(new MongoClient(new ServerAddress(dbHost, dbPort), options.build()), dbName);
    store.ensureIndexes();
    this.datastore = store;
}

使用这种方法，每次您需要数据存储时，您都可以使用工厂提供的数据存储。当然，如果您使用支持工厂模式的框架/库（例如：带有org.glassfish.hk2.api.Factory的HK2），以及单例绑定，这可以实现得更好。

此外，您可以查看mongoclientations的builder方法的文档，也许您可以在那里找到更好的连接控件。