Исправление BeanNotOfRequiredTypeException на прокси-сервере Spring на не-singleton bean?
У меня возникла проблема с извлечением 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, которая настроена точно так же, как 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;
}
}
приложение-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>
Трассировка стека
2009-05-08 14:34:37,341 [main] DEBUG com.generic.OuterThread.init(OuterThread.java:59) - Initializing OuterThread object, [email protected][[email protected],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],[email protected],i[email protected]1524d43,threadLocals=<null>,[email protected]c86,stackSize=0,nativeParkEventPointer=0,tid=9,threadStatus=0,parkBlocker=<null>,blocker=<null>,[email protected],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, [email protected][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],[email protected],i[email protected]1524d43,threadLocals=<null>,[email protected]f16,stackSize=0,nativeParkEventPointer=0,tid=10,threadStatus=0,parkBlocker=<null>,blocker=<null>,[email protected],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 [[email protected]]
2009-05-08 14:34:37,591 [main] DEBUG com.generic.OuterThread.createInnerThreads(OuterThread.java:141) - [email protected][[email protected]]
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(): [email protected]
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(): [email protected]
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)
Аналогичные вопросы, которые не отвечают на мой вопрос
Ответы
Ответ 1
Еще раз, потратив часы на отладку, я нахожу ответ сразу после публикации в StackOverflow.
Ключевой момент, который я упустил из моего вопроса, заключается в том, что InnerThread имеет транзакционный метод (извините, что это не имеет значения). Это важное различие между OuterThread и InnerThread.
Из Spring документация:
Примечание
Несколько разделов сворачиваются в один унифицированный автопрокси-создатель во время выполнения, который применяет самые сильные настройки прокси-сервера, которые указаны в любом из разделов (как правило, из разных файлов определения XML bean). Это также относится к элементам и.
Чтобы быть ясным: , используя 'proxy-target- class= "true" ', или элементы заставят использовать Прокси CGLIB для всех трех из них.
Добавление вышеуказанной в мою конфигурацию (основанной на persistance-context.xml, которую вы можете видеть загруженной выше), похоже, устраняет проблему. Тем не менее, я думаю, что это может быть быстрым решением, а не реальным решением.
Я думаю, что у меня есть несколько более сложных вопросов, первый из которых заключается в том, что я нахожу Spring настолько запутанным, как исключающее исключение. Во-вторых, я должен, вероятно, использовать Spring TaskExecutor, чтобы начать мои потоки. В-третьих, мои потоки должны реализовывать Runnable вместо продолжения Thread (см. Вопрос SO ниже).
См. также
Ответ 2
Аннотировать свой @Configuration
класс
@EnableAspectJAutoProxy(proxyTargetClass = true)
Вам также необходимо добавить следующую зависимость:
<dependency>
<groupId>org.aspectj</groupId>
<artifactId>aspectjweaver</artifactId>
<version>1.7.2</version>
</dependency>
Ответ 3
Это всего лишь предположение, но попробуйте сделать интерфейс InnerThreadInterface, а затем пусть InnerThread расширяет его.
После этого вы сможете сделать:
InnerThreadInterface inner = ctx.getBean( "innerThread", InnerThread.class);
Ответ 4
У меня была эта проблема, хотя я ссылался на CGLIB и использовал настройку прокси-target- class= "true". Я определил ehcache: был виноват тег аннотации... Удаление следующей конфигурации разрешило это для меня. К счастью, я смог использовать кэширование уровня hibernate 2 вместо того, чтобы использовать декларативное кэширование ehcache.
<ehcache:annotations>
<ehcache:caching id="myCacheModel" cacheName="myCache"/>
<ehcache:flushing id="myFlushModel" cacheNames="myCache" when="after"/>
</ehcache:annotations>
Ответ 5
У меня была та же проблема:
Это всего лишь предположение, но попробуйте сделать интерфейс InnerThreadInterface, то пусть класс InnerThread расширяет его. После этого вы сможете сделать:
Я использую этот способ вместо того, что выложено выше, и он работал нормально. Не нужно было устанавливать для класса proxy-target-true значение true, для этого требовалось больше библиотек, которые не были в моем пути к классам.
InnerThreadInterface inner = (InnerThreadInterface)ctx.getBean("innerThread");
Ответ 6
Одним из способов решения этой проблемы является расширение работающего интерфейса и создание собственного:
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);
...
Ответ 7
Еще один способ справиться с этой проблемой - реализовать интерфейс и запросить интерфейс от spring, прокси-сервер полностью реализует интерфейс, и у приведения не должно быть проблем.
Ответ 8
создать интерфейс DAO и реализовать интерфейс DAO для класса SERVICE и предоставить конфигурационные данные класса SERVICE в файле applicationContext.xml, т.е. конфигурационный файл spring и получить доступ к bean с помощью идентификатора bean и ссылается на экземпляр так называемого объекта-посредника на интерфейс DAO... он будет работать отлично...