Spring3升级遇到的问题
在3.0版本中,对一些容器的生命周期的处理做了不小的改变,包括:
DefaultMessageListenerContainerGenericMessageEndpointManagerJmsMessageEndpointManagerSchedulerFactoryBeanSimpleMessageListenerContainer这些容器实现了一个叫SmartLifecycle的新接口,能够自动启动。看名字就很智能,它用一种新的方式来管理启动顺序,在application context初始化结束后,开始初始化这些容器,如果isAutoStartup()为true,通过getPhase()来确认启动顺序,值越小就优先启动,关闭时相反,下面是实现:
private void startBeans(boolean autoStartupOnly) { Map<String, Lifecycle> lifecycleBeans = getLifecycleBeans(); Map<Integer, LifecycleGroup> phases = new HashMap<Integer, LifecycleGroup>(); for (Map.Entry<String, ? extends Lifecycle> entry : lifecycleBeans.entrySet()) { Lifecycle lifecycle = entry.getValue(); if (!autoStartupOnly || (lifecycle instanceof SmartLifecycle && ((SmartLifecycle) lifecycle).isAutoStartup())) { int phase = getPhase(lifecycle); LifecycleGroup group = phases.get(phase); if (group == null) { group = new LifecycleGroup(phase, this.timeoutPerShutdownPhase, lifecycleBeans); phases.put(phase, group); } group.add(entry.getKey(), lifecycle); } } if (phases.size() > 0) { List<Integer> keys = new ArrayList<Integer>(phases.keySet()); Collections.sort(keys); for (Integer key : keys) { phases.get(key).start(); } } }?可以看到根据phase的值,分组到LifecycleGroup中,然后自然排序,调用start()方法初始化(无视bean的lazy-init为true)。默认phase的值设为Integer.MAX_VALUE,说明是最晚进行处理的。
?
这种处理方式非常优雅,但依赖于Spring2.5版本的项目迁移过来时,问题就来了。其实项目中已经实现了类似上面的处理流程,就是注册一个ContextRefreshedEvent事件监听器,事件触发时说明容器已经初始化结束了,使用的是DefaultMessageListenerContainer,这个容器需要通过编程方式实例化的,而不是配置在xml文件中,这样更加灵活。在2.5版本中,DefaultMessageListenerContainer的afterPropertiesSet()方法会调用doStart()开始接收消息,但在3.0版本中由于流程改变,下面这段代码在initialize()中已经被去掉:
if (this.autoStartup) { doStart();}doInitialize();而生命周期是先于ApplicationEvent前执行的,看下面代码就很清楚了:
protected void finishRefresh() { // Initialize lifecycle processor for this context. initLifecycleProcessor(); // Propagate refresh to lifecycle processor first. getLifecycleProcessor().onRefresh(); // Publish the final event. publishEvent(new ContextRefreshedEvent(this)); }?这样,这样处理的之后,问题就来了:
本来在创建单例对象回调afterPropertiesSet()中开始接受消息,现在延后了
spring准备在SmartLifecycle中初始化DefaultMessageListenerContainer准备接受消息时,由于对象是在ContextRefreshedEvent中创建的,此时getLifecycleBeans()还没有任何bean
触发ContextRefreshedEvent事件后需要的对象都创建好了,spring已经不鸟你了
这样的结果是整个流程中没有没有知道到DefaultMessageListenerContainer的start()方法,所有程序启动后不会监控任何的MQ服务器。
?
问题找到了,解决就简单了(大半个下午也没了-_-!),用spring的SmartLifecycle方式来处理,以前的那陀实现删光光。