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