在非单例bean上进行Spring代理转换时如何解决BeanNotOfRequiredTypeException问题?

32

我在从应用程序上下文中提取Spring Bean时遇到了问题。

当我尝试这样做时;

InnerThread instance = (InnerThread) SpringContextFactory.getApplicationContext().getBean("innerThread", InnerThread.class);

我理解为:

org.springframework.beans.factory.BeanNotOfRequiredTypeException: Bean named 'innerThread' must be of type [com.generic.InnerThread], but was actually of type [$Proxy26]

在getBean()调用中没有指定类别,导致出现ClassCastException异常(详细信息如下所示)。
InnerThread bean被初始化为非单例模式,因为我需要多个实例。InnerThread类也扩展了Thread。有趣的是,这个错误出现在OuterThread中,而OuterThread的设置方式与InnerThread完全相同。
我尝试在下面包含所有相关的代码列表/堆栈跟踪。有更多Spring经验的人能告诉我这里发生了什么吗?
代码/配置清单
OuterThread.java片段:
public class OuterThread extends Thread {
    private Queue<InnerThread> createInnerThreads() {
        Queue<InnerThread> threads = new ArrayBlockingQueue();

        ApplicationContext ctx = SpringContextFactory.getApplicationContext();
        int i = 0;
        for (SearchRule search : searches) {
            logger.debug("Number of times looped " + i++);
            //Seprated lines to get a better sense of what is going on
            Object proxy = ctx.getBean("innerThread", InnerThread.class);
            logger.debug(ReflectionToStringBuilder.toString(proxy));
            logger.debug("proxy.getClass(): " + proxy.getClass());
            logger.debug("proxy.getClass().getClassLoader(): " + proxy.getClass().getClassLoader());
            logger.debug("proxy.getClass().getDeclaringClass(): " + proxy.getClass().getDeclaringClass());
            logger.debug("InnerThread.class.getClassLoader(): " + InnerThread.class.getClassLoader());

            //---Exception here---
            InnerThread cst = (InnerThread) proxy;

            threads.add(cst);
        }
        return threads;
    }

    public static void main(String[] args) throws Exception {
        try {
            OuterThread instance = (OuterThread) SpringContextFactory.getApplicationContext().getBean("outerThread", OuterThread.class);
            instance.run();
        } catch (Exception ex) {
            logger.error("Fatal exception.", ex);
            throw ex;
        }
    }
}

SpringContextFactory.java:

public class SpringContextFactory {
    static final Logger logger = LoggerFactory.getLogger(SpringContextFactory.class);
    private static ApplicationContext ctx;
    private static final String DEFAULT_PATH = "META-INF/app-context.xml";

    public static ApplicationContext getApplicationContext() {
        return getApplicationContext(DEFAULT_PATH);
    }

    public static synchronized ApplicationContext getApplicationContext(String path) {
        if (ctx == null) return createApplicationContext(path);
        else return ctx;
    }

    private static ApplicationContext createApplicationContext(String path) {
        if (logger.isDebugEnabled()) logger.debug("Loading Spring Context...");
        ctx = new ClassPathXmlApplicationContext(path);
        if (logger.isDebugEnabled()) logger.debug("Spring Context Loaded");
        return ctx;
    }
}

app-context.xml:

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:context="http://www.springframework.org/schema/context"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd">

    <!-- persistence context from separate jar -->
    <import resource="persistence-context.xml"/>

    <bean id="outerThread" class="com.generic.OuterThread" scope="prototype"/>
    <bean id="innerThread" class="com.generic.InnerThread" scope="prototype"/>

</beans>

Stack Trace

2009-05-08 14:34:37,341 [main] DEBUG com.generic.OuterThread.init(OuterThread.java:59) - Initializing OuterThread object, com.generic.OuterThread@1c8fb4b[em=org.hibernate.ejb.EntityManagerImpl@e2892b,currentTime=java.util.GregorianCalendar[time=1241634874841,areFieldsSet=true,areAllFieldsSet=true,lenient=true,zone=sun.util.calendar.ZoneInfo[id="America/New_York",offset=-18000000,dstSavings=3600000,useDaylight=true,transitions=235,lastRule=java.util.SimpleTimeZone[id=America/New_York,offset=-18000000,dstSavings=3600000,useDaylight=true,startYear=0,startMode=3,startMonth=2,startDay=8,startDayOfWeek=1,startTime=7200000,startTimeMode=0,endMode=3,endMonth=10,endDay=1,endDayOfWeek=1,endTime=7200000,endTimeMode=0]],firstDayOfWeek=1,minimalDaysInFirstWeek=1,ERA=1,YEAR=2009,MONTH=4,WEEK_OF_YEAR=19,WEEK_OF_MONTH=2,DAY_OF_MONTH=6,DAY_OF_YEAR=126,DAY_OF_WEEK=4,DAY_OF_WEEK_IN_MONTH=1,AM_PM=1,HOUR=2,HOUR_OF_DAY=14,MINUTE=34,SECOND=34,MILLISECOND=841,ZONE_OFFSET=-18000000,DST_OFFSET=3600000],maxConcurrentThreads=5,reconId=3,reportUsername=TEST,useOffset=false,username=removed,uuid=bf61494d-ff96-431c-a41f-1e292d0c9fbe,name={T,h,r,e,a,d,-,1},priority=5,threadQ=<null>,eetop=0,single_step=false,daemon=false,stillborn=false,target=<null>,group=java.lang.ThreadGroup[name=main,maxpri=10],contextClassLoader=sun.misc.Launcher$AppClassLoader@11b86e7,inheritedAccessControlContext=java.security.AccessControlContext@1524d43,threadLocals=<null>,inheritableThreadLocals=java.lang.ThreadLocal$ThreadLocalMap@2cbc86,stackSize=0,nativeParkEventPointer=0,tid=9,threadStatus=0,parkBlocker=<null>,blocker=<null>,blockerLock=java.lang.Object@a68fd8,stopBeforeStart=false,throwableFromStop=<null>,uncaughtExceptionHandler=<null>]
2009-05-08 14:34:37,341 [main] DEBUG org.springframework.orm.jpa.ExtendedEntityManagerCreator$ExtendedEntityManagerInvocationHandler.doJoinTransaction(ExtendedEntityManagerCreator.java:385) - No local transaction to join
2009-05-08 14:34:37,529 [main] DEBUG com.generic.OuterThread.createInnerThreads(OuterThread.java:139) - Number of times looped 0
2009-05-08 14:34:37,529 [main] DEBUG org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory$1.run(AbstractAutowireCapableBeanFactory.java:458) - Creating instance of bean 'searchThread' with merged definition [Root bean: class [com.generic.InnerThread]; scope=prototype; abstract=false; lazyInit=false; autowireCandidate=true; autowireMode=0; dependencyCheck=0; factoryBeanName=null; factoryMethodName=null; initMethodName=null; destroyMethodName=null; defined in class path resource [META-INF/app-context.xml]]
2009-05-08 14:34:37,545 [main] DEBUG com.generic.InnerThread.<init>(InnerThread.java:50) - Constructing InnerThread object, com.generic.InnerThread@1080876[em=<null>,coolScheme=<null>,coolUrl=<null>,date=<null>,error=<null>,millisecondsTaken=0,thresholdMet=false,reconId=0,result=-2,searchId=0,username=<null>,uuid=<null>,name={T,h,r,e,a,d,-,2},priority=5,threadQ=<null>,eetop=0,single_step=false,daemon=false,stillborn=false,target=<null>,group=java.lang.ThreadGroup[name=main,maxpri=10],contextClassLoader=sun.misc.Launcher$AppClassLoader@11b86e7,inheritedAccessControlContext=java.security.AccessControlContext@1524d43,threadLocals=<null>,inheritableThreadLocals=java.lang.ThreadLocal$ThreadLocalMap@3aef16,stackSize=0,nativeParkEventPointer=0,tid=10,threadStatus=0,parkBlocker=<null>,blocker=<null>,blockerLock=java.lang.Object@126c6ea,stopBeforeStart=false,throwableFromStop=<null>,uncaughtExceptionHandler=<null>]
2009-05-08 14:34:37,545 [main] DEBUG org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:203) - Returning cached instance of singleton bean 'entityManagerFactory'
2009-05-08 14:34:37,545 [main] DEBUG org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:203) - Returning cached instance of singleton bean 'org.springframework.transaction.config.internalTransactionAdvisor'
2009-05-08 14:34:37,560 [main] DEBUG org.springframework.transaction.interceptor.AbstractFallbackTransactionAttributeSource.getTransactionAttribute(AbstractFallbackTransactionAttributeSource.java:108) - Adding transactional method [report] with attribute [PROPAGATION_REQUIRED,ISOLATION_DEFAULT]
2009-05-08 14:34:37,560 [main] DEBUG org.springframework.aop.framework.autoproxy.AbstractAutoProxyCreator.buildAdvisors(AbstractAutoProxyCreator.java:494) - Creating implicit proxy for bean 'searchThread' with 0 common interceptors and 1 specific interceptors
2009-05-08 14:34:37,560 [main] DEBUG org.springframework.aop.framework.JdkDynamicAopProxy.getProxy(JdkDynamicAopProxy.java:113) - Creating JDK dynamic proxy: target source is SingletonTargetSource for target object [com.generic.InnerThread@1080876]
2009-05-08 14:34:37,591 [main] DEBUG com.generic.OuterThread.createInnerThreads(OuterThread.java:141) - $Proxy26@1594a88[h=org.springframework.aop.framework.JdkDynamicAopProxy@1f0cf51]
2009-05-08 14:34:37,591 [main] DEBUG com.generic.OuterThread.createInnerThreads(OuterThread.java:142) - proxy.getClass(): class $Proxy26
2009-05-08 14:34:37,591 [main] DEBUG com.generic.OuterThread.createInnerThreads(OuterThread.java:143) - proxy.getClass().getClassLoader(): sun.misc.Launcher$AppClassLoader@11b86e7
2009-05-08 14:34:37,591 [main] DEBUG com.generic.OuterThread.createInnerThreads(OuterThread.java:144) - proxy.getClass().getDeclaringClass(): null
2009-05-08 14:34:37,591 [main] DEBUG com.generic.OuterThread.createInnerThreads(OuterThread.java:145) - InnerThread.class.getClassLoader(): sun.misc.Launcher$AppClassLoader@11b86e7
2009-05-08 14:34:37,591 [main] ERROR com.generic.OuterThread.run(OuterThread.java:101) - Exception in OuterThread, ending reconciliation.
java.lang.ClassCastException: $Proxy26 cannot be cast to com.generic.InnerThread
    at com.generic.OuterThread.createInnerThreads(OuterThread.java:148)
    at com.generic.OuterThread.run(OuterThread.java:65)
    at com.generic.OuterThread.main(OuterThread.java:170)

与我问题无关的类似问题

9个回答

45

使用@Configuration注释您的类。

@EnableAspectJAutoProxy(proxyTargetClass = true) 

您还需要添加以下依赖项:

<dependency>
<groupId>org.aspectj</groupId>
<artifactId>aspectjweaver</artifactId>
<version>1.7.2</version>
</dependency> 

2
这个答案应该真正被标记为“已接受的答案”。 - Andrew Landsverk
2
实际上,为了正确的类型匹配,不需要使用CGLIB代理。 - antonu17
这个对我非常有效,应该被接受为答案。 - gonella
这对我帮助很大。应该标记为“已接受的答案”。 - DTnapaT
它能正常工作。但我同意antonu17的观点。这有些过度了。解决这个问题要简单得多。问题在于tom的答案方向。 - mahieus

27
再一次,在花费数小时尝试调试后,我发现在发布到StackOverflow上之后就找到了答案。
我从问题中遗漏的一个关键点是InnerThread有一个事务方法(抱歉,我认为这与问题无关)。这是OuterThread和InnerThread之间的重要区别。
Spring文档中可以看到:
多个部分在运行时合并为单个统一的自动代理创建器,该创建器应用任何一个部分(通常来自不同的XML bean定义文件)指定的最强代理设置。这也适用于和元素。
明确一下:在、或元素上使用'proxy-target-class="true"'将强制使用CGLIB代理 将上述内容添加到我的配置中(基于persistance-context.xml,您可以在上面看到它已加载)似乎解决了问题。但是,我认为这可能只是一个快速修复的解决方法,而不是真正的解决方案。
我认为我在这里有一些更深层次的问题,其中第一点是我认为Spring与expletive deleted一样令人困惑。其次,我应该使用Spring的TaskExecutor启动我的线程。第三,我的线程应该实现Runnable而不是扩展Thread(请参见下面的SO问题)。

参见


请检查Tom的答案(第一类应该是接口,已经修复但等待同行审查)。我认为这是解决问题的正确方向。请重新考虑“正确答案”,因为它可能会让人们添加他们实际上不需要/不想要的额外依赖和配置。 - mahieus

4

解决这个问题的一种方法是通过扩展Runnable接口并创建自己的接口:

public interface MyInterface extends Runnable {
  // your own method declarations here
  void doSomething();
  ...
}

那么你应该实现你的接口而不是实现Runnable接口:

@Component("myInterface")
@Scope("prototype")
     public class MyInterfaceImpl implements MyInterface {

          // your own method declarations here
          public void doSomething(){
          ...
          }


          // implement run from Runnable Interface
          @Transactional
          public void run(){
                .....
          }

             ...
        }

这将正常工作:

...
    MyInterface mynterface = SpringApplicationContext.getBean("myInterface", MyInterface.class);

    myInterface.doSomething();
  ExecutorService executor = Executors.newSingleThreadExecutor();
    executor.submit(myInterface);
...

2
这只是一个猜测,但可以尝试创建一个名为InnerThreadInterface的接口,然后让InnerThread类继承它。

之后你应该能够执行以下代码:
InnerThreadInterface inner = ctx.getBean("innerThread", InnerThread.class);

我尝试了一下,不幸的是这个行不通。 - James McMahon
这个对我的情况确实有所帮助,但是示例稍微有点问题。正确的应该是:InnerThreadInterface inner = ctx.getBean("innerThread", InnerThreadInterface.class); - xor_eq

1

我也遇到了同样的问题:

这只是一个猜测,但可以尝试创建一个 InnerThreadInterface 接口,然后让 InnerThread 类扩展它。 然后你应该能够执行以下操作:

我使用了这种方式,而不是上面发布的方法,它运行得很好。没有必要将代理目标类设置为 true,这需要更多不在我的类路径上的库。

InnerThreadInterface inner = (InnerThreadInterface)ctx.getBean("innerThread");

1

尽管我引用了CGLIB并使用了proxy-target-class="true"设置,但我仍然遇到了这个问题。我确定是ehcache:annotation标签的问题...删除以下配置解决了我的问题。幸运的是,我能够使用Hibernate二级缓存而不必使用ehcache声明性缓存。

<ehcache:annotations>
    <ehcache:caching id="myCacheModel" cacheName="myCache"/>
    <ehcache:flushing id="myFlushModel" cacheNames="myCache" when="after"/>
</ehcache:annotations> 

1

另一种处理这个问题的方法是实现一个接口并从Spring请求该接口,代理将完全实现该接口,强制转换不应该有问题。


1
并不总是实用的解决方案。 - Snekse

-1

创建一个 DAO 接口并实现将其应用于 SERVICE 类,提供 SERVICE 类的配置细节在 applicationContext.xml 文件中,即 Spring 配置文件,并使用 bean 编号访问该 bean,引用所生成的代理对象的实例到 DAO 接口... 这样就能完美运行了....


-2

之前有个问题,直到我重启了Idea并重新构建了Maven项目才解决了。


网页内容由stack overflow 提供, 点击上面的
可以查看英文原文,
原文链接