Spring Boot：处理 mongodb timeoutException

Question

当mongodb宕机时，spring boot应用宕机。我希望在不停止应用程序的情况下处理连接超时异常并记录错误。 当由于无法连接而从数据库中查找项目失败时，应用程序应该进行另一种处理，例如调用 Web 服务来查找数据。 您对此有任何想法吗？

配置

spring.data.mongodb.uri=mongodb://${MONGODB_DB_HOST}:${MONGODB_DB_PORT}/${MONGODB_DB_DATABASE}?connectTimeoutMS=${mongodb.connection.timeout}

Answer 1

我使用下面的代码在 Spring Boot 中配置 mongodb 连接

您可以根据需要指定socket超时和连接超时。

@Configuration
public class DatabaseConfiguration {

    private static final Logger LOGGER = LoggerFactory.getLogger(DatabaseConfiguration.class);


    @Value("${spring.data.mongodb.uri}")
    private String mongoUri;

    @Value("${spring.data.mongodb.database}")
    private String mongoDbName;

    @Value("${spring.data.mongodb.host}")
    private String host;

    @Value("${spring.data.mongodb.port}")
    private int port;

    @Value("${spring.data.mongodb.username}")
    private String username;

    @Value("${spring.data.mongodb.password}")
    private String password;

    @Bean
    public MongoTemplate mongoTemplate() {

        LOGGER.debug(" instantiating MongoDbFactory ");

        SimpleMongoDbFactory mongoDbFactory = new SimpleMongoDbFactory(mongoClient(), mongoDbName);

        MongoTemplate mongoTemplate = new MongoTemplate(mongoDbFactory);

        return mongoTemplate;

    }

    @Bean
    public MongoClient mongoClient() {

        List<ServerAddress> servers = new ArrayList<ServerAddress>();
        servers.add(new ServerAddress(host, port));

        MongoClientOptions mongoClientOptions = MongoClientOptions.builder()
                .connectionsPerHost(10)
                .socketTimeout(2000)
                .connectTimeout(2000)
                .build();

        if (Utils.isNotEmpty(username) && Utils.isNotEmpty(password)) {
            List<MongoCredential> creds = new ArrayList<MongoCredential>();
            creds.add(MongoCredential.createCredential(username, mongoDbName, password.toCharArray()));
            return new MongoClient(servers,creds, mongoClientOptions);
        } else
            return new MongoClient(servers, mongoClientOptions);
    }

    @Bean
    public MongoClientURI mongoClientURI() {
        LOGGER.debug(" creating connection with mongodb with uri [{}] ", mongoUri);
        return new MongoClientURI(mongoUri);
    }

}

在您的 application.yml 文件中定义以下属性

mongodb 特定属性

spring:
  data:
    mongodb:
      database: dbname
      host: localhost
      port: 27017
      username: dbusername
      password: dbpassword

Answer 2

您可以使用以下示例配置 mongodb 超时。我希望很容易转换为springboot的bean annonation。否则你可以导入资源 bean (@ImportResource)

<beans>

  <mongo:mongo host="localhost" port="27017">
    <mongo:options connections-per-host="8"
                   threads-allowed-to-block-for-connection-multiplier="4"
                   connect-timeout="1000"
                   max-wait-time="1500}"
                   auto-connect-retry="true"
                   socket-keep-alive="true"
                   socket-timeout="1500"
                   slave-ok="true"
                   write-number="1"
                   write-timeout="0"
                   write-fsync="true"/>
  </mongo:mongo/>

</beans>