問題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); }} |
總結
以上就是這篇文章的全部內容了，希望本文的內容對大家的學習或者工作具有一定的參考學習價值，謝謝大家對服務器之家的支持。如果你想了解更多相關內容請查看下面相關鏈接
