奇怪的弹簧“无法解决的循环引用问题”

Question

在我的应用程序中，我们使用多个数据源，因此我们有多个数据库配置（会话工厂）。在我们的本地（windows 机器）上一切正常，但是当我们将 war 文件部署到 Unix 应用程序时失败，出现以下异常：

org.springframework.beans.factory.BeanCreationException: 错误 创建名为“cpnRepository”的bean：注入自动装配 依赖失败；嵌套异常是 org.springframework.beans.factory.BeanCreationException：不能 自动装配字段：私有 org.hibernate.SessionFactory org.npcc.ccms.dao.GenericDB1Dao.sessionFactory；嵌套异常是 org.springframework.beans.factory.BeanCreationException：错误 创建名为“DB1Config”的bean：注入自动装配 依赖失败；嵌套异常是 org.springframework.beans.factory.BeanCreationException：不能 自动装配字段：私有 org.hibernate.SessionFactory org.npcc.ccms.config.db.DB1Config.sessionFactory；嵌套异常是 org.springframework.beans.factory.BeanCurrentlyInCreationException： 创建名为“DB1SessionFactory”的 bean 时出错：请求的 bean 是 当前正在创建中：是否存在无法解析的循环引用？

这里是dao的实现：

@Repository("cpnRepository")
public class ProgramNodeDaoImpl extends GenericDB1Dao<Integer, CustomProgramNode> implements CPNRepositoryDao {
    @Override
    public List<CustomProgramNode> findAllNodes() {
        Criteria criteria = createEntityCriteria();
        return (List<CustomProgramNode>) criteria.list();
    }

    @Override
    public List<CustomProgramNode> findByStatus(String status) {
        Query query = getSession().createQuery("from CustomProgramNode where status = :status");
        query.setParameter("status", status);
        List<CustomProgramNode> list = query.list();
        return list;        

    }

}

DB1 的通用 DAO：

public abstract class GenericDB1Dao<PK extends Serializable, T> {

    private final Class<T> persistentClass;

    @SuppressWarnings("unchecked")
    public GenericAgrgtrDao(){
        this.persistentClass =(Class<T>) ((ParameterizedType) this.getClass().getGenericSuperclass()).getActualTypeArguments()[1];
    }

    @Autowired
    @Qualifier("DB1SessionFactory")
    private SessionFactory sessionFactory;

    protected Session getSession(){
        return sessionFactory.getCurrentSession();
    }

    @SuppressWarnings("unchecked")
    public T getByKey(PK key) {
        return (T) getSession().get(persistentClass, key);
    }

    public void persist(T entity) {
        getSession().persist(entity);
    }

    public void delete(T entity) {
        getSession().delete(entity);
    }

    protected Criteria createEntityCriteria(){
        return getSession().createCriteria(persistentClass);
    }
}

Database1 配置：

@Configuration
public class DB1Config {
    final static Logger logger = LogManager.getLogger(DB1Config.class);

    @Autowired
    private Environment environment;

    @Autowired
    @Qualifier("DB1SessionFactory")
    private SessionFactory sessionFactory;

    @Bean(name="DB1SessionFactory")
    public LocalSessionFactoryBean db1SessionFactory() {
        LocalSessionFactoryBean sessionFactory = new LocalSessionFactoryBean();
        sessionFactory.setDataSource(dataSource());
        sessionFactory.setPackagesToScan(new String[] { "org.npcc.ccms.model.db1" });
        sessionFactory.setHibernateProperties(hibernateProperties());
        return sessionFactory;
     }

    @Bean(destroyMethod="")
    public DataSource dataSource() {
        JndiTemplate jndi = new JndiTemplate();
        DataSource dataSource = null;
        try {
            dataSource = (DataSource) jndi.lookup(environment.getRequiredProperty("datasource.db1"));
        } catch (NamingException e) {
        }
        return dataSource;
    }

    private Properties hibernateProperties() {
        Properties properties = new Properties();
        properties.put("hibernate.dialect", environment.getRequiredProperty("hibernate.dialect"));
        properties.put("hibernate.show_sql", environment.getRequiredProperty("hibernate.show_sql"));
        properties.put("hibernate.format_sql", environment.getRequiredProperty("hibernate.format_sql"));
        return properties;        
    }
    @Primary
    @Bean(name="DB1TransactionManager")
    public HibernateTransactionManager db1TransactionManager() {
       HibernateTransactionManager txManager = new HibernateTransactionManager();
       txManager.setSessionFactory(this.sessionFactory);
       txManager.setDataSource(dataSource());
       return txManager;
    }
}

Spring 如何解决 bean 依赖关系？为什么两个操作系统之间的顺序不一致？提前致谢。

Answer 1

我认为您的问题来自于您正在创建 LocalSessionFactoryBean 并同时尝试自动连接 SessionFactory ...

您的DB1Config 课程中不需要该班级成员sessionFactory，请尝试类似的方法：

@Bean(name="DB1SessionFactory")
public LocalSessionFactoryBean db1SessionFactory() {
    LocalSessionFactoryBean sessionFactory = new LocalSessionFactoryBean();
    sessionFactory.setDataSource(dataSource());
    sessionFactory.setPackagesToScan(new String[] { "org.npcc.ccms.model.db1" });
    sessionFactory.setHibernateProperties(hibernateProperties());
    return sessionFactory;
 }

@Bean
public SessionFactory sessionFactory() {
    return db1SessionFactory().getObject();
}