我使用 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;
}
}