接口回調(diào)
監(jiān)聽器本質(zhì)上就是利用回調(diào)機(jī)制，在某個動作發(fā)生前或后，執(zhí)行我們自己的一些代碼。在Java語言中，可以使用接口來實(shí)現(xiàn)。
實(shí)現(xiàn)一個監(jiān)聽器案例
為了方便，直接在spring環(huán)境中定義：以工作(work)為例，定義工作開始時（或結(jié)束時）的監(jiān)聽器。
1. 定義回調(diào)的接口
|
1
2
3
4
5
6
7
8
9
|
package com.yawn.demo.listener;/** * @author Created by yawn on 2018-01-21 13:53 */public interface WorkListener { void onStart(String name);} |
2. 定義動作
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
|
package com.yawn.demo.service;import com.yawn.demo.listener.WorkListener;/** * @author Created by yawn on 2018-01-21 13:39 */@Servicepublic class MyService { @Resource private PersonService personService; private WorkListener listener; public void setWorkListener(WorkListener workListener) { this.listener = workListener; } public void work(String name) { listener.onStart(name); personService.work(); }} |
動作work為一個具體的方法，在work()方法的適當(dāng)時機(jī)，調(diào)用前面定義的接口。此外，在這個動作定義類中，需要提高設(shè)置監(jiān)聽器的方法。
3. 監(jiān)聽測試
|
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
|
@RunWith(SpringRunner.class)@SpringBootTestpublic class DemoSpringAnnotationApplicationTests { @Resource private MyService myService; @Test public void test1() { // 接口設(shè)置監(jiān)聽器 myService.setWorkListener(new WorkListener() { @Override public void onStart(String name) { System.out.println("Start work for " + name + " !"); } });// // lambda 表達(dá)式設(shè)置監(jiān)聽器// myService.setWorkListener(name -> System.out.println("Start work for " + name + " !")); // 工作 myService.work("boss"); } @Test public void test2() { // 繼承實(shí)現(xiàn)類設(shè)置監(jiān)聽器 myService.setWorkListener(new myWorkListener()); // 工作 myService.work("boss"); } class myWorkListener extends WorkListenerAdaptor { @Override public void onStart(String name) { System.out.println("Start work for " + name + " !"); } }} |
使用以上兩種方法測試，得到了結(jié)果為：
|
1
2
|
Start work for boss !working hard ... |
說明在動作work發(fā)生之前，執(zhí)行了我們在測試類中寫下的監(jiān)聽代碼，實(shí)現(xiàn)類監(jiān)聽的目的。
使用注解實(shí)現(xiàn)監(jiān)聽器
在以上代碼中，調(diào)用 setWorkListener(WorkListener listener) 方法一般稱作設(shè)置（注冊）監(jiān)聽器，就是將自己寫好的監(jiān)聽代碼，設(shè)置為動作的監(jiān)聽器。然而，在每次注冊監(jiān)聽器時，一般需要寫一個類，實(shí)現(xiàn)定義好的接口或繼承實(shí)現(xiàn)接口的類，再重寫接口定義的方法即可。因此，聰明的程序員就想簡化這個過程，所以就想出了使用注解的方法。使用注解，將監(jiān)聽代碼段寫在一個方法中，使用一個注解標(biāo)記這個方法即可。
的確，使用變得簡單了，但實(shí)現(xiàn)卻不見得。
1. 定義一個注解
|
1
2
3
4
5
|
package com.yawn.demo.anno;@Target(ElementType.METHOD)@Retention(RetentionPolicy.RUNTIME)public @interface WorkListener {} |
2. 解析注解
|
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
|
package com.yawn.demo.anno;import com.yawn.demo.service.MyService;import org.springframework.beans.BeansException;import org.springframework.beans.factory.InitializingBean;import org.springframework.context.ApplicationContext;import org.springframework.context.ApplicationContextAware;import org.springframework.stereotype.Component;import javax.annotation.Resource;import java.lang.annotation.Annotation;import java.lang.reflect.Method;import java.util.LinkedHashMap;import java.util.Map;/** * @author Created by yawn on 2018-01-21 14:46 */@Componentpublic class WorkListenerParser implements ApplicationContextAware, InitializingBean { @Resource private MyService myService; private ApplicationContext applicationContext; @Override public void afterPropertiesSet() throws Exception { Map<String, Object> listenerBeans = getExpectListenerBeans(Controller.class, RestController.class, Service.class, Component.class); for (Object listener : listenerBeans.values()) { for (Method method : listener.getClass().getDeclaredMethods()) { if (!method.isAnnotationPresent(WorkListener.class)) { continue; } myService.setWorkListener(name -> { try { method.invoke(listener, name); } catch (Exception e) { e.printStackTrace(); } }); } } } /** * 找到有可能使用注解的bean * @param annotationTypes 需要進(jìn)行掃描的類級注解類型 * @return 掃描到的beans的map */ private Map<String, Object> getExpectListenerBeans(Class<? extends Annotation>... annotationTypes) { Map<String, Object> listenerBeans = new LinkedHashMap<>(); for (Class<? extends Annotation> annotationType : annotationTypes) { Map<String, Object> annotatedBeansMap = applicationContext.getBeansWithAnnotation(annotationType); listenerBeans.putAll(annotatedBeansMap); } return listenerBeans; } @Override public void setApplicationContext(ApplicationContext applicationContext) throws BeansException { this.applicationContext = applicationContext; }} |
在注解的解析過程中，設(shè)置監(jiān)聽器。
在解析類中，實(shí)現(xiàn)了接口ApplicationContextAware，為了在類中拿到ApplicationContext的引用，用于得到 IOC 容器中的 Bean；而實(shí)現(xiàn)接口InitializingBean，則是為了在一個合適的時機(jī)執(zhí)行解析注解、設(shè)置監(jiān)聽器的代碼。 如果不這樣做，可以在CommandLineRunner執(zhí)行時調(diào)用解析、設(shè)置的代碼，而ApplicationContext也可以自動注入。
3. 測試
在執(zhí)行完以上代碼后，監(jiān)聽器就已經(jīng)設(shè)置好了，可以進(jìn)行測試了。
|
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
|
package com.yawn.demo.controller;import com.yawn.demo.anno.WorkListener;import com.yawn.demo.service.MyService;import org.springframework.web.bind.annotation.GetMapping;import org.springframework.web.bind.annotation.RestController;import javax.annotation.Resource;/** * @author Created by yawn on 2018-01-21 13:28 */@RestControllerpublic class TestController { @Resource private MyService myService; @GetMapping("/work") public Object work() { myService.work("boss"); return "done"; } @WorkListener public void listen(String name) { System.out.println("Start work for " + name + " !"); }} |
寫一個監(jiān)聽方法，參數(shù)類型和個數(shù)與接口相同，然后加上自定義的注解即可。當(dāng)啟動環(huán)境后，監(jiān)聽器就已經(jīng)設(shè)置好了。
然后通過url調(diào)用myService的work()方法，可以看到結(jié)果：
|
1
2
|
Start work for boss !working hard ... |
已經(jīng)調(diào)用了監(jiān)聽方法。在接下來的開發(fā)中，就可以使用這個注解注冊監(jiān)聽器了。
以上就是本文的全部內(nèi)容，希望對大家的學(xué)習(xí)有所幫助，也希望大家多多支持服務(wù)器之家。
原文鏈接：https://my.oschina.net/silenceyawen/blog/1610900
