如何使用 spring mongodb 将 WriteConcern 设置为 ACKNOWLEDGED?

Posted

技术标签:

【中文标题】如何使用 spring mongodb 将 WriteConcern 设置为 ACKNOWLEDGED?【英文标题】:How do you set WriteConcern using spring mongodb to ACKNOWLEDGED? 【发布时间】:2017-01-16 08:43:38 【问题描述】:

我想将 spring mongodb 中的 WriteConcern 设置为确认。另外,我想知道这是否是默认值?我在 application.properties 中使用 spring.data.mongodb.uri 所以我没有任何 mongo 配置类。

【问题讨论】:

【参考方案1】:

仅提供WriteConcernResolver over Bean 配置是不够的。 MongoTemplate 不会使用它。 要做到这一点,您必须创建一个像这样的类,其中有两个选项来设置WriteConcern

import com.mongodb.WriteConcern;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.mongodb.MongoDatabaseFactory;
import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.data.mongodb.core.WriteResultChecking;
import org.springframework.data.mongodb.core.convert.MongoConverter;

@Configuration
public class MongoConfiguration 
    Logger logger = LoggerFactory.getLogger(MongoConfiguration.class);

    public MongoConfiguration() 
        logger.info("MongoConfiguration applied  ...");
    

    @Bean
    MongoTemplate mongoTemplate(MongoDatabaseFactory mongoDbFactory, MongoConverter converter) 
        MongoTemplate mongoTemplate = new MongoTemplate(mongoDbFactory, converter);+
        // Version 1: set statically
        logger.debug("Setting WriteConcern statically to ACKNOWLEDGED");
        mongoTemplate.setWriteConcern(WriteConcern.ACKNOWLEDGED);
        // Version 2: provide a WriteConcernResolver, which is called for _every_ MongoAction
        // which might degrade performance slightly (not tested)
        // and is very flexible to determine the value
        mongoTemplate.setWriteConcernResolver(action -> 
            logger.debug("Action  called on collection  for document  with WriteConcern.MAJORITY. Default WriteConcern was ", action.getMongoActionOperation(), action.getCollectionName(), action.getDocument(), action.getDefaultWriteConcern());
            return WriteConcern.ACKNOWLEDGED;
        );
        mongoTemplate.setWriteResultChecking(WriteResultChecking.EXCEPTION);
        return mongoTemplate;
    

【讨论】:

【参考方案2】:

您可以在 xml-configuration 中设置 write-concern(如果适用)

<mongo:db-factory ... write-concern="SAFE"/>

【讨论】:

【参考方案3】:

你可以通过 Spring bean 做到这一点

@Configuration
public class MongoConfiguration 

@Bean
public WriteConcernResolver writeConcernResolver() 
    return action -> 
        System.out.println("Using Write Concern of Acknowledged");
        return WriteConcern.ACKNOWLEDGED;
    ;



【讨论】:

【参考方案4】:

来自 SpringData 的文档here

9.4.3。写关注 如果尚未通过更高级别的驱动程序(例如 com.mongodb.Mongo)指定,您可以设置 MongoTemplate 将用于写入操作的 com.mongodb.WriteConcern 属性。如果未设置 MongoTemplate 的 WriteConcern 属性,它将默认为 MongoDB 驱动程序的 DB 或 Collection 设置中的设置。

9.4.4。 WriteConcernResolver 对于更高级的情况,您希望在每个操作的基础上设置不同的 WriteConcern 值(用于删除、更新、插入和保存操作),可以在 MongoTemplate 上配置一个名为 WriteConcernResolver 的策略接口。由于 MongoTemplate 用于持久化 POJO,因此 WriteConcernResolver 允许您创建可以将特定 POJO 类映射到 WriteConcern 值的策略。 WriteConcernResolver 接口如下图所示。

public interface WriteConcernResolver 
 WriteConcern resolve(MongoAction action);

找到直接实现here

【讨论】:

以上是关于如何使用 spring mongodb 将 WriteConcern 设置为 ACKNOWLEDGED?的主要内容,如果未能解决你的问题,请参考以下文章

如何使用 spring security 和 spring boot 对 Google 用户进行身份验证,将 mongoDB 作为存储库?

如何使用Spring Data可伸缩地将元素插入MongoDB中的集合字段?

如何使用 Spring Boot 在 Mongodb 中保存重复项?

如何使`org.mongodb.driver.cluster`在spring boot中使用嵌入式mongodb?

在将它们添加到 MongoDB 之前,如何在 Spring Data 中处理插入请求?

如何在 Spring Rest Call 中使用 GridFS 从 Mongodb 发送和检索图像?