问题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 * */@componentpublic 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 */@componentpublic 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); }} |
总结
以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作具有一定的参考学习价值，谢谢大家对服务器之家的支持。如果你想了解更多相关内容请查看下面相关链接
