大家对于 spring 的 scope 应该都不会默认。所谓 scope,字面理解就是“作用域”、“范围”,如果一个 bean 的 scope 配置为 singleton,则从容器中获取 bean 返回的对象都是相同的;如果 scope 配置为prototype,则每次返回的对象都不同。
一般情况下,spring 提供的 scope 都能满足日常应用的场景。但如果你的需求极其特殊,则本文所介绍自定义 scope 合适你。
spring 内置的 scope
默认时,所有 spring bean 都是的单例的,意思是在整个 spring 应用中,bean的实例只有一个。可以在 bean 中添加 scope 属性来修改这个默认值。scope 属性可用的值如下:
范围 | 描述 |
---|---|
singleton | 每个 spring 容器一个实例(默认值) |
prototype | 允许 bean 可以被多次实例化(使用一次就创建一个实例) |
request | 定义 bean 的 scope 是 http 请求。每个 http 请求都有自己的实例。只有在使用有 web 能力的 spring 上下文时才有效 |
session | 定义 bean 的 scope 是 http 会话。只有在使用有 web 能力的 spring applicationcontext 才有效 |
application | 定义了每个 servletcontext 一个实例 |
websocket | 定义了每个 websocket 一个实例。只有在使用有 web 能力的 spring applicationcontext 才有效 |
如果上述 scope 仍然不能满足你的需求,spring 还预留了接口,允许你自定义 scope。
scope 接口
org.springframework.beans.factory.config.scope
接口用于定义scope的行为:
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
|
package org.springframework.beans.factory.config; import org.springframework.beans.factory.objectfactory; import org.springframework.lang.nullable; public interface scope { object get(string name, objectfactory<?> objectfactory); @nullable object remove(string name); void registerdestructioncallback(string name, runnable callback); @nullable object resolvecontextualobject(string key); @nullable string getconversationid(); } |
一般来说,只需要重新 get 和 remove 方法即可。
自定义线程范围内的scope
现在进入实战环节。我们要自定义一个spring没有的scope,该scope将bean的作用范围限制在了线程内。即,相同线程内的bean是同个对象,跨线程则是不同的对象。
1. 定义scope
要自定义一个spring的scope,只需实现 org.springframework.beans.factory.config.scope接口。代码如下:
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
|
package com.waylau.spring.scope; import java.util.hashmap; import java.util.map; import org.springframework.beans.factory.objectfactory; import org.springframework.beans.factory.config.scope; /** * thread scope. * * @since 1.0.0 2019年2月13日 * @author <a href="https://waylau.com" rel="external nofollow" rel="external nofollow" rel="external nofollow" rel="external nofollow" rel="external nofollow" >way lau</a> */ public class threadscope implements scope { private final threadlocal<map<string, object>> threadloacal = new threadlocal<map<string, object>>() { @override protected map<string, object> initialvalue() { return new hashmap<string, object>(); } }; public object get(string name, objectfactory<?> objectfactory) { map<string, object> scope = threadloacal.get(); object obj = scope.get(name); // 不存在则放入threadlocal if (obj == null ) { obj = objectfactory.getobject(); scope.put(name, obj); system.out.println( "not exists " + name + "; hashcode: " + obj.hashcode()); } else { system.out.println( "exists " + name + "; hashcode: " + obj.hashcode()); } return obj; } public object remove(string name) { map<string, object> scope = threadloacal.get(); return scope.remove(name); } public string getconversationid() { return null ; } public void registerdestructioncallback(string arg0, runnable arg1) { } public object resolvecontextualobject(string arg0) { return null ; } } |
在上述代码中,threadloacal用于做线程之间的数据隔离。换言之,threadloacal实现了相同的线程相同名字的bean是同一个对象;不同的线程的相同名字的bean是不同的对象。
同时,我们将对象的hashcode打印了出来。如果他们是相同的对象,则hashcode是相同的。
2. 注册scope
定义一个appconfig配置类,将自定义的scope注册到容器中去。代码如下:
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
|
package com.waylau.spring.scope; import java.util.hashmap; import java.util.map; import org.springframework.beans.factory.config.customscopeconfigurer; import org.springframework.context.annotation.bean; import org.springframework.context.annotation.componentscan; import org.springframework.context.annotation.configuration; /** * app config. * * @since 1.0.0 2019年2月13日 * @author <a href="https://waylau.com" rel="external nofollow" rel="external nofollow" rel="external nofollow" rel="external nofollow" rel="external nofollow" >way lau</a> */ @configuration @componentscan public class appconfig { @bean public static customscopeconfigurer customscopeconfigurer() { customscopeconfigurer customscopeconfigurer = new customscopeconfigurer(); map<string, object> map = new hashmap<string, object>(); map.put( "threadscope" , new threadscope()); // 配置scope customscopeconfigurer.setscopes(map); return customscopeconfigurer; } } |
“threadscope”就是自定义threadscope的名称。
3. 使用scope
接下来就根据一般的scope的用法,来使用自定义的scope了。代码如下:
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
|
package com.waylau.spring.scope.service; import org.springframework.context.annotation.scope; import org.springframework.stereotype.service; /** * message service impl. * * @since 1.0.0 2019年2月13日 * @author <a href="https://waylau.com" rel="external nofollow" rel="external nofollow" rel="external nofollow" rel="external nofollow" rel="external nofollow" >way lau</a> */ @scope ( "threadscope" ) @service public class messageserviceimpl implements messageservice { public string getmessage() { return "hello world!" ; } } |
其中@scope("threadscope")中的“threadscope”就是自定义threadscope的名称。
4. 定义应用入口
定义spring应用入口:
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
|
package com.waylau.spring.scope; import org.springframework.context.applicationcontext; import org.springframework.context.annotation.annotationconfigapplicationcontext; import com.waylau.spring.scope.service.messageservice; /** * application main. * * @since 1.0.0 2019年2月13日 * @author <a href="https://waylau.com" rel="external nofollow" rel="external nofollow" rel="external nofollow" rel="external nofollow" rel="external nofollow" >way lau</a> */ public class application { public static void main(string[] args) { @suppresswarnings ( "resource" ) applicationcontext context = new annotationconfigapplicationcontext(appconfig. class ); messageservice messageservice = context.getbean(messageservice. class ); messageservice.getmessage(); messageservice messageservice2 = context.getbean(messageservice. class ); messageservice2.getmessage(); } } |
运行应用观察控制台输出如下:
not exists messageserviceimpl; hashcode: 2146338580
exists messageserviceimpl; hashcode: 2146338580
输出的结果也就验证了threadscope“相同的线程相同名字的bean是同一个对象”。
如果想继续验证threadscope“不同的线程的相同名字的bean是不同的对象”,则只需要将application改造为多线程即可。
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
|
package com.waylau.spring.scope; import java.util.concurrent.completablefuture; import java.util.concurrent.executionexception; import org.springframework.context.applicationcontext; import org.springframework.context.annotation.annotationconfigapplicationcontext; import com.waylau.spring.scope.service.messageservice; /** * application main. * * @since 1.0.0 2019年2月13日 * @author <a href="https://waylau.com" rel="external nofollow" rel="external nofollow" rel="external nofollow" rel="external nofollow" rel="external nofollow" >way lau</a> */ public class application { public static void main(string[] args) throws interruptedexception, executionexception { @suppresswarnings ( "resource" ) applicationcontext context = new annotationconfigapplicationcontext(appconfig. class ); completablefuture<string> task1 = completablefuture.supplyasync(()->{ //模拟执行耗时任务 messageservice messageservice = context.getbean(messageservice. class ); messageservice.getmessage(); messageservice messageservice2 = context.getbean(messageservice. class ); messageservice2.getmessage(); //返回结果 return "result" ; }); completablefuture<string> task2 = completablefuture.supplyasync(()->{ //模拟执行耗时任务 messageservice messageservice = context.getbean(messageservice. class ); messageservice.getmessage(); messageservice messageservice2 = context.getbean(messageservice. class ); messageservice2.getmessage(); //返回结果 return "result" ; }); task1.get(); task2.get(); } } |
观察输出结果;
not exists messageserviceimpl; hashcode: 1057328090
not exists messageserviceimpl; hashcode: 784932540
exists messageserviceimpl; hashcode: 1057328090
exists messageserviceimpl; hashcode: 784932540
上述结果验证threadscope“相同的线程相同名字的bean是同一个对象;不同的线程的相同名字的bean是不同的对象”
源码
见 的 s5-ch02-custom-scope-annotation项目。
以https://github.com/waylau/spring-5-book上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持服务器之家。
原文链接:https://my.oschina.net/waylau/blog/3009991