代码之家 › 专栏 › 技术社区 › user8363477

使用Spring Boot中的MongoTemplate检查MongoDB连接

spring-mongodb spring-mongo spring-kafka spring-boot java

user8363477 · 技术社区 · 7 年前

我正在研究spring kafka mongo的插入/更新操作集成,并使用mongotemplate执行这些操作。我想知道是否有任何方法可以检查MongoDB连接是否打开/关闭,以便在数据库关闭时手动提交Kafka偏移量。目前,所有数据库配置都在application.properties文件中提供

1 回复 | 直到 7 年前

Sampisa 7 年前

像这样的事情怎么样?

@Autowired
private MongoTemplate mt;

public String ping()
{
    DBObject ping = new BasicDBObject("ping", "1");
    try {
        CommandResult answer = mt.getDb().command(ping);
        return answer.getErrorMessage();
    } catch (Exception e) {
        return e.getMessage();
    }

推荐文章