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

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

  •  1
  • user8363477  · 技术社区  · 7 年前

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

    1 回复  |  直到 7 年前
        1
  •  3
  •   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();
        }