NickName:ravindrab Ask DateTime:2016-02-15T23:06:16

Configure mongodb property maxWaitQueueSize in Spring boot application?

I get the error com.mongodb.MongoWaitQueueFullException: Too many threads are already waiting for a connection. Max number of threads (maxWaitQueueSize) of 500 has been exceeded. while doing a stress test on my application.

So I am thinking of configuring the maxWaitQueueSize property via configuration.

I am using spring boot to configure mongodb connection. I am using @EnableAutoConfiguration in my Application and I have declared only spring.data.mongodb.uri=mongodb://user:password@ip:27017 in the application.properties file.

How do I configure the maxWaitQueueSize property with spring boot?

How do I decide a good value for the maxWaitQueueSize?

Copyright Notice：Content Author:「ravindrab」，Reproduced under the CC 4.0 BY-SA copyright license with a link to the original source and this disclaimer.
Link to original article：https://stackoverflow.com/questions/35412696/configure-mongodb-property-maxwaitqueuesize-in-spring-boot-application

Answers

Ali Dehghani 2016-02-15T16:20:32

If you're using MongoDB 3.0+, you can set waitQueueMultiple in your mongouri :\n\nspring.data.mongodb.uri=mongodb://user:password@ip:27017/?waitQueueMultiple=10\n\n\nwaitQueueMultiple is a number that the driver multiples the maxPoolSize value to, to provide the maximum number of threads allowed to wait for a connection to become available from the pool.\n\n\n How do I decide a good value for the maxWaitQueueSize?\n\n\nIt's not directly related to MongoDB but you can read more about Pool Sizing in Hikari github wiki.",

Jong Su Park 2016-06-21T05:35:11

In com.mongodb.MongoClientURI, you can find the parameters which can be used in MongoClientOption.\n\n if (key.equals(\"maxpoolsize\")) {\n builder.connectionsPerHost(Integer.parseInt(value));\n } else if (key.equals(\"minpoolsize\")) {\n builder.minConnectionsPerHost(Integer.parseInt(value));\n } else if (key.equals(\"maxidletimems\")) {\n builder.maxConnectionIdleTime(Integer.parseInt(value));\n } else if (key.equals(\"maxlifetimems\")) {\n builder.maxConnectionLifeTime(Integer.parseInt(value));\n } else if (key.equals(\"waitqueuemultiple\")) {\n builder.threadsAllowedToBlockForConnectionMultiplier(Integer.parseInt(value));\n } else if (key.equals(\"waitqueuetimeoutms\")) {\n builder.maxWaitTime(Integer.parseInt(value));\n } else if (key.equals(\"connecttimeoutms\")) {\n builder.connectTimeout(Integer.parseInt(value));\n } else if (key.equals(\"sockettimeoutms\")) {\n builder.socketTimeout(Integer.parseInt(value));\n } else if (key.equals(\"autoconnectretry\")) {\n builder.autoConnectRetry(_parseBoolean(value));\n } else if (key.equals(\"replicaset\")) {\n builder.requiredReplicaSetName(value);\n } else if (key.equals(\"ssl\")) {\n if (_parseBoolean(value)) {\n builder.socketFactory(SSLSocketFactory.getDefault());\n }\n }\n",

richard 2019-06-04T08:03:45

I am using spring boot starter webflux. This issue also happens. \nI tried to add MongoClientFactoryBean. It doesn't work.\nThe whole application is located in https://github.com/yigubigu/webfluxbenchmark. I tried to test performance benchmark of webflux and original mvc. \n\n@Bean\n public MongoClientFactoryBean mongoClientFactoryBean() {\n MongoClientFactoryBean factoryBean = new MongoClientFactoryBean();\n factoryBean.setHost(\"localhost\");\n factoryBean.setPort(27017);\n factoryBean.setSingleton(true); \n MongoClientOptions options = MongoClientOptions.builder()\n .connectionsPerHost(1000) \n .minConnectionsPerHost(500)\n .threadsAllowedToBlockForConnectionMultiplier(10)\n .build();\n factoryBean.setMongoClientOptions(options);\n return factoryBean;\n }\n",

Hbargujar 2016-02-15T15:47:50

you can achieve this by injecting an object of MongoOptions to your MongoTemplate. ",