Spring Data项目中Neo4j不可用时，如何保障其他服务正常运行？

当前问题的核心是：Spring Data Neo4j自动配置的Neo4jTransactionManager会被纳入Spring容器的事务管理器候选列表，当调用未明确指定事务管理器的@Transactional方法时，Spring可能会尝试使用Neo4j事务管理器；而Neo4j不可用时，该事务管理器无法打开会话，进而抛出异常。同时，Neo4j相关仓库Bean在连接不可用时仍会被创建，事务上下文关联会话时会触发错误。

1. 条件化加载Neo4j相关组件 #

通过自定义条件类判断Neo4j服务是否可达，仅当连接成功时才加载Neo4j的配置、仓库和事务管理器，避免无效Bean干扰容器。

自定义连接判断条件类 #

import org.springframework.context.annotation.Condition;
import org.springframework.context.annotation.ConditionContext;
import org.springframework.core.type.AnnotatedTypeMetadata;
import org.neo4j.driver.v1.AuthTokens;
import org.neo4j.driver.v1.Driver;
import org.neo4j.driver.v1.GraphDatabase;
import org.neo4j.driver.v1.exceptions.ServiceUnavailableException;

public class Neo4jAvailableCondition implements Condition {

    @Override
    public boolean matches(ConditionContext context, AnnotatedTypeMetadata metadata) {
        String uri = context.getEnvironment().getProperty("spring.data.neo4j.uri");
        String username = context.getEnvironment().getProperty("spring.data.neo4j.username");
        String password = context.getEnvironment().getProperty("spring.data.neo4j.password");
        
        try (Driver driver = GraphDatabase.driver(uri, AuthTokens.basic(username, password))) {
            driver.verifyConnectivity();
            return true;
        } catch (ServiceUnavailableException | IllegalArgumentException e) {
            return false;
        }
    }
}

条件化配置Neo4j #

创建配置类，仅在Neo4j可用时启用Neo4j仓库和事务管理：

import org.springframework.context.annotation.Conditional;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.neo4j.repository.config.EnableNeo4jRepositories;
import org.springframework.transaction.annotation.EnableTransactionManagement;

@Configuration
@EnableNeo4jRepositories(basePackages = "com.yourpackage.repository") // 替换为实际Neo4j仓库包路径
@EnableTransactionManagement
@Conditional(Neo4jAvailableCondition.class)
public class Neo4jConfig {
    // Spring Boot 2.1.x会自动配置SessionFactory等核心组件，无需额外代码
}

2. 配置默认事务管理器（针对非Neo4j服务） #

明确指定默认事务管理器，避免Spring默认选择Neo4j事务管理器。如果项目使用关系型数据库，可配置JDBC事务管理器并标记为默认：

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import javax.sql.DataSource;

@Configuration
public class DefaultTransactionConfig {

    @Bean
    @Primary // 标记为全局默认事务管理器
    public DataSourceTransactionManager defaultTransactionManager(DataSource dataSource) {
        return new DataSourceTransactionManager(dataSource);
    }
}

若无需其他数据源，可在非Neo4j服务的@Transactional注解中明确指定事务管理器名称，确保不关联Neo4j事务：

import org.springframework.transaction.annotation.Transactional;

@Transactional("defaultTransactionManager")
public void nonNeo4jBusinessMethod() {
    // 业务逻辑实现
}

3. 对Neo4j相关服务做容错处理 #

即使做了条件化加载，运行时Neo4j仍可能突然不可用，需对调用Neo4j的代码做容错处理：

方式一：try-catch捕获异常 #

import org.springframework.stereotype.Service;
import java.util.Collections;
import java.util.List;
import java.util.stream.Collectors;

@Service
public class UseService {

    private final UseRepository useRepository;

    // 仅当Neo4j可用时，useRepository才会被注入，否则为null
    public UseService(UseRepository useRepository) {
        this.useRepository = useRepository;
    }

    public List<Use> getAllUses() {
        if (useRepository == null) {
            // Neo4j不可用，返回默认空列表
            return Collections.emptyList();
        }
        try {
            return useRepository.findAll().stream().collect(Collectors.toList());
        } catch (Exception e) {
            // 捕获Neo4j连接异常，返回默认值
            return Collections.emptyList();
        }
    }
}

方式二：Spring Cloud Hystrix降级（适配Spring Cloud项目） #

添加Hystrix依赖：

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
</dependency>

启动类添加@EnableHystrix注解，然后在服务方法上配置降级逻辑：

import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
import org.springframework.stereotype.Service;
import java.util.Collections;
import java.util.List;
import java.util.stream.Collectors;

@Service
public class UseService {

    private final UseRepository useRepository;

    public UseService(UseRepository useRepository) {
        this.useRepository = useRepository;
    }

    @HystrixCommand(fallbackMethod = "getAllUsesFallback")
    public List<Use> getAllUses() {
        return useRepository.findAll().stream().collect(Collectors.toList());
    }

    // 降级方法，Neo4j不可用时触发
    public List<Use> getAllUsesFallback() {
        return Collections.emptyList();
    }
}

4. 可选：调整配置增强容错性 #

在application.yml中添加配置，允许容器在Neo4j连接失败时不中断初始化：

spring:
  data:
    neo4j:
      uri: bolt://localhost:7687
      username: neo4j
      password: neo4j
      open-in-view: false
  main:
    allow-bean-definition-overriding: true

内容的提问来源于stack exchange，提问作者vlddlv4