问题1:
有个异步线程runnable里面需要用到dao，无法通过autowired和compoment注解传递进来。
于是希望通过spring context主动去获取bean。
问题2：
getbean(name) 获取失败。
解决:
默认的dao的name=类名(首字母小写)
例如:
接口名称:templatedao 则 getname([templatedao]) 即可
通用的springcontextutil获取bean
1.实现applicationcontextaware接口
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 |
/** * spring上下文配置 * @author mingchenchen * */ @component public class springcontextutil implements applicationcontextaware { private static logger logger = logger.getlogger(springcontextutil. class ); private static applicationcontext applicationcontext = null ; public void setapplicationcontext(applicationcontext applicationcontext) throws beansexception { logger.info( "------springcontextutil setapplicationcontext-------" ); springcontextutil.applicationcontext = applicationcontext; } public static applicationcontext getapplicationcontext() { return applicationcontext; } /** * 注意 bean name默认 = 类名(首字母小写) * 例如: a8sclusterdao = getbean("k8sclusterdao") * @param name * @return * @throws beansexception */ public static object getbean(string name) throws beansexception { return applicationcontext.getbean(name); } /** * 根据类名获取到bean * @param <t> * @param clazz * @return * @throws beansexception */ @suppresswarnings ( "unchecked" ) public static <t> t getbeanbyname( class <t> clazz) throws beansexception { try { char [] cs=clazz.getsimplename().tochararray(); cs[ 0 ] += 32 ; //首字母大写到小写 return (t) applicationcontext.getbean(string.valueof(cs)); } catch (exception e) { e.printstacktrace(); return null ; } } public static boolean containsbean(string name) { return applicationcontext.containsbean(name); } public static boolean issingleton(string name) throws nosuchbeandefinitionexception { return applicationcontext.issingleton(name); } } |
2.在web项目中的web.xml中配置加载spring容器的listener
|
1 2 3 4 |
<!-- 初始化spring容器，让spring容器随web应用的启动而自动启动 --> <listener> <listener- class >org.springframework.web.context.contextloaderlistener</listener- class > </listener> |
getbeanbyname(class clazz)
这个方法更好使用,不过需要注意dao和service的impl里面需要配置好名称为@service([myservice])
规则为接口service的类名首字母小写。
第二种方式:
目前又做了个系统初始化的东东systeminit，然后发现上面的getbean()用不了了。看了下发现是因为在系统初始化的时候springcontextutil还没有初始化，导致在systeminit类里面的东西getbean()失败。
于是小改造了下，把applicationcontextaware放在systeminit类，然后注入到springcontextutil，这样就保证了在执行系统初始化方法之前，applicationcontext一定不是null。
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 |
/** * spring上下文配置 * @author mingchenchen * */ public class springcontextutil { private static logger logger = logger.getlogger(springcontextutil. class ); //@autowired 沿用springtest的这种方法 是否会更好？ //applicationcontext ctx; private static applicationcontext applicationcontext = null ; public static void setapplicationcontext(applicationcontext applicationcontext) throws beansexception { logger.info( "------springcontextutil setapplicationcontext-------" ); springcontextutil.applicationcontext = applicationcontext; } //注意此处变成了static public static applicationcontext getapplicationcontext() { return applicationcontext; } /** * 注意 bean name默认 = 类名(首字母小写) * 例如: a8sclusterdao = getbean("k8sclusterdao") * @param name * @return * @throws beansexception */ public static object getbean(string name) throws beansexception { return applicationcontext.getbean(name); } /** * 根据类名获取到bean * @param <t> * @param clazz * @return * @throws beansexception */ @suppresswarnings ( "unchecked" ) public static <t> t getbeanbyname( class <t> clazz) throws beansexception { try { char [] cs=clazz.getsimplename().tochararray(); cs[ 0 ] += 32 ; //首字母大写到小写 return (t) applicationcontext.getbean(string.valueof(cs)); } catch (exception e) { e.printstacktrace(); return null ; } } public static boolean containsbean(string name) { return applicationcontext.containsbean(name); } public static boolean issingleton(string name) throws nosuchbeandefinitionexception { return applicationcontext.issingleton(name); } } /** * descripties: 系统初始化 * @author wangkaiping * 2016年5月23日 上午11:58:09 */ @component public class systeminit implements initializingbean,applicationcontextaware{ private static logger logger = logger.getlogger(systeminit. class ); @autowired private clusterdao clusterdao; @override public void afterpropertiesset() throws exception { logger.info( "--------------系统初始化中-------------------" ); initclustercache(); //初始化集群数据 必须最开始完成 initrefreshappstatustask(); initupdateappstatustodb(); initupdatesession(); logger.info( "--------------系统初始化完成-------------------" ); } /** * 1.初始化集群数据 */ private void initclustercache(){ logger.info( "1.初始化集群信息到缓存中:clustercache开始" ); //查询数据库所有的集群数据 list<clusterentity> allclusterinfolist = clusterdao.selectall(clusterentity. class , "delete_flag=0" ); for (clusterentity k8sclusterentity : allclusterinfolist) { clustercache.put(k8sclusterentity.getuuid() , k8sclusterentity); //存入缓存 } logger.info( "1.初始化集群信息到缓存中:clustercache完成,总共" + allclusterinfolist.size() + "条数据" ); } /** * 2.初始化异步任务:刷新所有应用状态 */ private void initrefreshappstatustask() { logger.info( "2.初始化任务:refreshallappstatustask 刷新应用下的k8s的pod状态并存入待更新队列" ); refreshappstatusexcutor.init(); logger.info( "2.初始化任务:refreshallappstatustask 完成" ); } /** * 3.初始化异步任务:更新状态到数据库 */ private void initupdateappstatustodb() { logger.info( "3.初始化任务:refreshtodbtask 从待更新appinstance队列取出数据并更新数据库" ); updateappstatustodbexcutor.init(); logger.info( "3.初始化任务:refreshtodbtask 完成" ); } /** * 4. 初始化异步任务： 更新用户的所有session */ private void initupdatesession() { logger.info( "4.初始化任务：更新session开始" ); usersessionupdateexcutor.init(); logger.info( "4.初始化任务：更新session结束" ); } //////////////////////////////////////////////////////////////// //此方法一定不要写成static @override public void setapplicationcontext(applicationcontext applicationcontext) throws beansexception { //实际上是把applicationcontext传入到了springcontextutil里面 springcontextutil.setapplicationcontext(applicationcontext); } } |
总结
以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作具有一定的参考学习价值，谢谢大家对的支持。如果你想了解更多相关内容请查看下面相关链接
查看更多关于Spring通过ApplicationContext主动获取bean的方法讲解的详细内容...