使用mongodb和java时连接错误太多

我使用MongoDbFactory与Java连接到mongodb.但是mongo服务每小时至少抛出一次套接字异常.因此我被迫重启mongodb服务以恢复操作.我认为这可能是由于与java的mongodb的未关闭连接的结果,并且MongoDbFactory也没有为我提...

我使用MongoDbFactory与Java连接到mongodb.但是mongo服务每小时至少抛出一次套接字异常.因此我被迫重启mongodb服务以恢复操作.我认为这可能是由于与java的mongodb的未关闭连接的结果,并且MongoDbFactory也没有为我提供关闭连接的功能.如何确保在特定会话后关闭所有连接.

这是我正在使用的代码：

package com.####.mongo.configuration;

import com.mongodb.Mongo;
import org.springframework.context.annotation.Bean;
import org.springframework.data.mongodb.MongoDbFactory;
import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.mongodb.core.SimpleMongoDbFactory;
import org.springframework.data.mongodb.core.convert.DefaultMongoTypeMapper;
import org.springframework.data.mongodb.core.convert.MappingMongoConverter;
import org.springframework.data.mongodb.core.mapping.MongoMappingContext;

@Configuration
public class SpringMongoFeedConfig {

public @Bean
MongoDbFactory mongoDbFactory() throws Exception {
    return new SimpleMongoDbFactory(new Mongo(), "feedDatabase");
}

public @Bean
MongoTemplate mongoTemplate() throws Exception {

    MappingMongoConverter converter = new MappingMongoConverter(mongoDbFactory(), new MongoMappingContext());
    converter.setTypeMapper(new DefaultMongoTypeMapper(null));
    MongoTemplate mongoTemplate = new MongoTemplate(mongoDbFactory(), converter);


    return mongoTemplate; 
} 

}

和：

private String insertFeedsToMongo(FeedMongoDTO feedObject, FeedType type) throws UnknownHostException {
    try {
        ApplicationContext ctx = new AnnotationConfigApplicationContext(SpringMongoFeedConfig.class);
        MongoOperations mongoOperation = (MongoOperations) ctx.getBean("mongoTemplate");

        switch (type) {

        case FOLLOW:
            mongoOperation.save(feedObject, "feedsByUid");
            break;

        case GENERAL:
            mongoOperation.save(feedObject, "allFeeds");
            break;

        default:
            break;
        }

        return feedObject.getId();

    } catch (Exception ex) {
        log.info("insertFeedsToMongo() : mongo Exception - ", ex);
        return null;
    }
}

解决方法:

我也遇到了Mongo对象的问题.确保在完成特定连接时调用myMongo.close()解决它.

我建议将你的工厂函数中使用新Mongo()创建的实例存储在某个允许以后关闭的地方(SimpleMongoDbFactory可能就是那个地方).刚才注意到这是一个春天的事情.建议仍然存在：跟踪您的Mongo实例.