一、观察者模式介绍
1. 解决的问题
主要解决将一个对象的状态改变通知给其他对象的问题。
2. 定义
观察者模式是一种行为设计模式，允许你定义一种订阅机制，可在对象事件发生时通知多个 “观察” 该对象的其他对象。
3. 应用场景
- 当一个对象的改变需要改变其他对象，或实际对象时是事先未知的或动态变化时，可使用观察者模式。
- 当应用中的一些对象必须观察其他对象时，可使用观察者模式，但仅能在有限时间内或特定情况下使用。
二、观察者模式优缺点
1. 优点
- 开闭原则：无需修改发布者代码就能引入新的订阅者（如果是发布者接口，则可轻松引入发布者类）。
- 可以在运行时建立与对象之间的联系。
2. 缺点
三、观察者模式应用实例：您的快递已到达蜂站，请及时签收
1. 实例场景
现在大部分快递都不会交付到手上了，除非我们特意选了上门服务。
一般都是买完两三天，收到条短信：您好，您的快递已到蜂站，请凭取件码K16888取件，取件时间09:30-21:00，请及时取件。
刚看完短信，APP也跳出一则通知：您的快递已被蜂站签收，请及时取件。
今天，就以快递到达，同时收到APP和短信通知为例，介绍一下观察者模式。
2. 观察者模式实现
2.1 工程结构
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
| observer-pattern
└─ src
├─ main
│ └─ java
│ └─ org.design.pattern.observer
│ ├─ model
│ │ ├─ ExpressPackage.java
│ │ ├─ Courier.java
│ │ └─ User.java
│ ├─ subscriber
│ │ ├─ ExpressEventSubscriber.java
│ │ └─ impl
│ │ ├─ AppExpressEventListener.java
│ │ └─ SmsExpressEventSubscriber.java
│ ├─ publisher
│ │ └─ ExpressEventPublisher.java
│ └─ service
│ ├─ ExpressService.java
│ └─ impl
│ └─ ExpressServiceImpl.java
└─ test
└─ java
└─ org.design.pattern.observer.test
└─ ExpressEventTest.java
|
2.2 代码实现
2.2.1 实体类
快递实体类
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
|
@Getter
@Setter
@AllArgsConstructor
public class Express {
private String id;
private String recipientName;
private String recipientPhone;
private String recipientAddress;
}
|
2.2.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
|
public class ExpressEventPublisher {
private List<ExpressEventSubscriber> subscriberList = new ArrayList<>();
public void subscribe(ExpressEventSubscriber expressEventSubscriber) {
subscriberList.add(expressEventSubscriber);
}
public void unsubscribe(ExpressEventSubscriber expressEventSubscriber) {
subscriberList.remove(expressEventSubscriber);
}
public void notifySubscribersArrive(Express express) {
subscriberList.forEach(expressEventSubscriber -> expressEventSubscriber.arrive(express));
}
}
|
2.2.3 订阅者
快递事件订阅者接口
1
2
3
4
5
6
7
8
9
10
11
12
13
|
public interface ExpressEventSubscriber {
void arrive(Express express);
}
|
App-快递事件订阅者
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
|
@Slf4j
public class AppExpressEventListener implements ExpressEventSubscriber {
@Override
public void arrive(Express express) {
log.info("App 通知：您的包裹{}已达到蜂站！", express.getId());
}
}
|
短信-快递事件订阅者
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
|
@Slf4j
public class SmsExpressEventSubscriber implements ExpressEventSubscriber {
@Override
public void arrive(Express express) {
log.info("短信通知：您的包裹{}已达到蜂站！", express.getId());
}
}
|
2.2.4 服务类
快递服务接口
1
2
3
4
5
6
7
8
9
10
11
12
|
public interface ExpressService {
void arrive(Express express);
}
|
快递服务实现类
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
|
@Slf4j
public class ExpressServiceImpl implements ExpressService {
private final ExpressEventPublisher expressEventPublisher;
public ExpressServiceImpl(ExpressEventPublisher expressEventPublisher) {
this.expressEventPublisher = expressEventPublisher;
}
@Override
public void arrive(Express express) {
log.info("{}的快递已到达蜂站！", express.getRecipientName());
expressEventPublisher.notifySubscribersArrive(express);
}
}
|
2.3 测试验证
2.3.1 测试验证类
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
|
public class ExpressEventTest {
@Test
public void test() {
Express express = new Express("1", "yiyufxst", "13245678910", "xx路");
ExpressEventSubscriber appExpressEventListener = new AppExpressEventListener();
ExpressEventSubscriber smsExpressEventSubscriber = new SmsExpressEventSubscriber();
ExpressEventPublisher expressEventPublisher = new ExpressEventPublisher();
expressEventPublisher.subscribe(appExpressEventListener);
expressEventPublisher.subscribe(smsExpressEventSubscriber);
ExpressService expressService = new ExpressServiceImpl(expressEventPublisher);
expressService.arrive(express);
expressEventPublisher.unsubscribe(appExpressEventListener);
express.setId("2");
expressService.arrive(express);
}
}
|
2.3.2 测试结果
1
2
3
4
5
6
7
| 14:50:01.090 [main] INFO o.d.p.o.s.impl.ExpressServiceImpl - yiyufxst的快递已到达蜂站！
14:50:01.093 [main] INFO o.d.p.o.s.i.AppExpressEventListener - App 通知：您的包裹1已达到蜂站！
14:50:01.093 [main] INFO o.d.p.o.s.i.SmsExpressEventSubscriber - 短信通知：您的包裹1已达到蜂站！
14:50:01.093 [main] INFO o.d.p.o.s.impl.ExpressServiceImpl - yiyufxst的快递已到达蜂站！
14:50:01.093 [main] INFO o.d.p.o.s.i.SmsExpressEventSubscriber - 短信通知：您的包裹2已达到蜂站！
Process finished with exit code 0
|
四、观察者模式结构
发布者（Publisher）会对其他对象发送值得关注的事件。事件会在发布者自身状态改变或执行特定行为后发生。发布者中包含一个允许新订阅者加入或当前订阅者离开列表的订阅架构。
当新事件发生时，发送者会便利订阅者列表并调用每个订阅者对象的通知方法。
订阅者（Subscriber）接口声明了通知接口。在绝大多数情况下，该接口仅包含一个更新方法。该方法可以拥有多个参数，以便发布者能在更新时传递时间的详细信息。
具体订阅者（Concrete Subscribers）可以执行一些操作来回应发布者的通知。所有订阅者类实现了同样的接口，因此发布者无需与具体类耦合。
订阅者通常需要一些上下文信息来正确地处理更新消息。因此发布者会将一些上下文数据作为通知方法的参数进行传递。发布者也可将自身作为参数传递，使订阅者直接获取所需的数据。
客户端（Client）会分别创建发布者和订阅者对象，然后为订阅者注册发布者更新。
设计模式并不难学，其本身就是多年经验提炼出的开发指导思想，关键在于多加练习，带着使用设计模式的思想去优化代码，就能构建出更合理的代码。
源码地址：https://github.com/yiyufxst/design-pattern-java
参考资料：
小博哥重学设计模式：https://github.com/fuzhengwei/itstack-demo-design
深入设计模式：https://refactoringguru.cn/design-patterns/catalog