5

我正在通过 Spring MVC 中的 mongodb java 驱动程序连接到 MongoDB 分片服务器。我正在使用以下版本：

  • spring-webmvc-3.2.1.RELEASE
  • mongo-java-driver/2.10.0/mongo-java-driver-2.10.0
  • spring-data-mongodb-1.2.0.RELEASE

我的 Mongo 选项在 contextConfigLocation 文件 mvc-dispatcher-servlet.xml 中设置

<mongo:mongo host="mongo.sample.com" port="30000">
     <mongo:options auto-connect-retry="true"
                    slave-ok="true"/>
</mongo:mongo>

它工作得很好，但是 come.MongoDB.ReadPreference 不推荐使用 slave-ok。我只是想知道是否有任何方法可以在 contextConfiLocation 文件中设置 Spring MVC 的 readPreference。

4

7 回答 7

9

声明以下bean

<bean id="readPreferenceSecondary" class="com.mongodb.TaggableReadPreference.SecondaryReadPreference">
</bean>

和

你把它注入你的 mongotemplate

<bean id="mongoTemplateProdDb" class="org.springframework.data.mongodb.core.MongoTemplate" >
        <property name="readPreference" ref="readPreferenceSecondary"></property>
</bean>
于 2014-07-07T15:35:54.877 回答
8

将@Trisha 的响应扩展为一个答案：“以编程方式在 MongoTemplate 中执行”，方法是ReadPreference将SECONDARY.

MongoTemplate template = new MongoTemplate(...);
template.setReadPreference(com.mongodb.ReadPreference.SECONDARY);
于 2014-02-24T20:18:25.667 回答
4

如果您使用的是 spring-data-mongodb 并且需要基于查找查询使用多个读取首选项，则可以创建多个 Mongo 模板和/或存储库，例如

    @EnableMongoRepositories(basePackages = {
            "com.you.repo.package" }, mongoTemplateRef = "mongoTemplateOne")    
    @Configuration
    public class MongoConfig {

    @Bean(name="mongoTemplateOne")
    public MongoTemplate getMongoTemplateOne() throws UnknownHostException {
        MongoTemplate templateOne = new MongoTemplate(new SimpleMongoDbFactory(new MongoClientURI("YOUR_MONGO_URL")));
        templateOne.setReadPreference(ReadPreference.secondaryPreferred());

        //setting WriteConcern but not relevant for this thread
        templateOne.setWriteConcernResolver(yourWriteConcernResolver());
        return templateOne;
    }

    @Bean(name = "mongoTemplateTwo")
    public MongoTemplate getMongoTemplateTwo() throws UnknownHostException {
        MongoTemplate templateTwo = new MongoTemplate(new SimpleMongoDbFactory(new MongoClientURI("YOUR_MONGO_URL")));
        templateTwo.setReadPreference(ReadPreference.secondaryPreferred());
        return templateTwo;
    }


    private WriteConcernResolver yourWriteConcernResolver() {
        return action -> {
            if (action.getCollectionName()
                    .equals("your_collecton")
                    && (action.getMongoActionOperation() == MongoActionOperation.SAVE
                            || action.getMongoActionOperation() == MongoActionOperation.UPDATE)) {
                return WriteConcern.MAJORITY;
            }
            return action.getDefaultWriteConcern();
        };
    }
于 2018-07-04T05:05:30.610 回答
2

如果您有多个辅助（副本集），您可以更具体并使用tags明确告诉 mongo 驱动程序您要从哪个辅助读取。

在 mongo 方面，您运行以下命令：

db.getMongo().setReadPref('secondaryPreferred',
                          [{"tagName":"TagVal1"},
                            {"tagName":"TagVal2"},
                            {}])

在代码中它看起来像这样：

MongoTemplate template = new MongoTemplate(...)
template.setReadPreference(ReadPreference.secondaryPreferred("your DBObject that reflect your mongo tag names");

希望能帮助到你。

于 2015-07-08T10:58:59.680 回答
0

如果需要根据集合在主要和次要读取之间混合，您可以ReadPreference在DBCollection对象上设置。这有助于避免复杂的多重MongoTemplate配置。相反，在应用程序生命周期中设置一次收集级别首选项，如下所示。该特定集合的所有读取都将转到辅助集合，而对于其他集合，它将转到主要集合。

DBCollection dbCollection = mongoTemplate.getCollection(mongoTemplate.getCollectionName(collection));
dbCollection.setReadPreference(ReadPreference.secondaryPreferred());

如果您想了解实现它的不同选项，请查看Spring data mongodb secondary reads

于 2019-01-07T08:58:27.063 回答
0

这是使用 Mongo Repositories 执行此操作的另一种方法

@Configuration
@EnableMongoRepositories
class ApplicationConfig extends AbstractMongoClientConfiguration {

    @Autowired
    private Environment env;

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


    @Override
    protected String getDatabaseName() {
        return env.getProperty("spring.data.mongodb.database");
    }

    @Override
    protected void configureClientSettings(MongoClientSettings.Builder builder) {
        builder.applyConnectionString(new ConnectionString(mongoUri)).readPreference(ReadPreference.secondary());
    }

}

示例应用程序可用 @ https://github.com/prashanthmadi/cosmosdb-mongodb-readpreference-springboot-java/blob/main/src/main/java/azure/cosmosdb/mongodb/spring/cosmosdbmongodb/ApplicationConfig.java

于 2021-09-09T13:01:45.790 回答
0

从spring-mongo-2.0.xsd 开始，slave-ok已完全删除，但添加了对 .xml 配置的支持ReadPreference。这是为当前 XSD 翻译的原始问题的 XML：

<mongo:mongo-client host="mongo.sample.com" port="30000">
     <mongo:client-options read-preference="SECONDARY_PREFERRED" />
</mongo:mongo-client>
于 2019-09-16T17:54:12.867 回答