观察者模式Java实战-写法1：手动注册

简介

本文介绍观察者模式最基础的写法：手动注册。

本写法的优缺点

优点

1. 纯手写，有利于理解观察者模式的原理。

缺点

1. 需要手动注册观察者，不能自动处理。

实例

本处使用一个贴近真实场景的案例：订单取消时，要有一系列操作，比如：账户业务需要给用户退钱、库存业务需要给商品退回数量。

在这个场景中，取消订单就是被观察者，账户业务和库存业务是观察者。

项目结构

源码地址

业务数据类

取消订单时，主题会将这个数据给到感兴趣的观察者。

package com.knife.designPattern.bo;

import lombok.Data;

@Data
public class CancelOrderBO {
    private String orderNo;
}

主题（取消订单）

本处只使用到了被观察者的具体类，无需抽象被观察者。

package com.knife.designPattern.subject;
 

import com.knife.designPattern.bo.CancelOrderBO;
import com.knife.designPattern.observer.CancelOrderObserver;

import java.util.ArrayList;
import java.util.List;

/**
 * 具体被观察者（主题）: 订单取消
 */
public class CancelOrderSubject {
    private final List<CancelOrderObserver> list = new ArrayList<>();

    public void addObserver(CancelOrderObserver cancelOrderObserver) {
        list.add(cancelOrderObserver);
    }
 
    public void removeObserver(CancelOrderObserver cancelOrderObserver) {
        list.remove(cancelOrderObserver);
    }
 
    public void process(CancelOrderBO cancelOrderBO) {
        System.out.println("订单取消的相关数据：" + cancelOrderBO);
        for (CancelOrderObserver cancelOrderObserver : list) {
            cancelOrderObserver.process(cancelOrderBO);
        }
    }
}

观察者

抽象观察者

package com.knife.designPattern.observer;

import com.knife.designPattern.bo.CancelOrderBO;

/**
 * 抽象观察者：业务
 */
 public interface CancelOrderObserver {
    /**
     * 业务收到订单取消数据后的操作
     */
    void process(CancelOrderBO cancelOrderBO);
}

具体观察者（账户业务） 

package com.knife.designPattern.observer.impl;

import com.knife.designPattern.bo.CancelOrderBO;
import com.knife.designPattern.observer.CancelOrderObserver;

/**
 * 具体观察者: 账户业务
 */
public class AccountCancelOrderObserverImpl implements CancelOrderObserver {
    @Override
    public void process(CancelOrderBO cancelOrderBO) {
        System.out.println("账户业务开始处理订单取消。接收到的消息：" + cancelOrderBO);
    }
}

具体观察者（库存业务）

package com.knife.designPattern.observer.impl;

import com.knife.designPattern.bo.CancelOrderBO;
import com.knife.designPattern.observer.CancelOrderObserver;

/**
 * 具体观察者: 库存业务
 */
public class StorageCancelOrderObserverImpl implements CancelOrderObserver {
    @Override
    public void process(CancelOrderBO cancelOrderBO) {
        System.out.println("库存业务开始处理订单取消。接收到的消息：" + cancelOrderBO);
    }
}

主题持有者

只有主题还不行，需要有一个地方去调用它，添加一个主题持有者

package com.knife.designPattern.subject;

import com.knife.designPattern.bo.CancelOrderBO;
import com.knife.designPattern.observer.CancelOrderObserver;
import com.knife.designPattern.observer.impl.AccountCancelOrderObserverImpl;
import com.knife.designPattern.observer.impl.StorageCancelOrderObserverImpl;

public class SubjectHolder {
    private static final CancelOrderSubject instance = init();

    private SubjectHolder() {
    }

    private static CancelOrderSubject init() {
        // 创建被观察者
        CancelOrderSubject orderCancelSubject = new CancelOrderSubject();

        // 创建观察者
        CancelOrderObserver accountCancelOrderObserver =
                new AccountCancelOrderObserverImpl();
        CancelOrderObserver storageCancelOrderObserver =
                new StorageCancelOrderObserverImpl();

        // 添加观察者
        orderCancelSubject.addObserver(accountCancelOrderObserver);
        orderCancelSubject.addObserver(storageCancelOrderObserver);
        return orderCancelSubject;
    }

    public static void process(CancelOrderBO cancelOrderBO) {
        instance.process(cancelOrderBO);
    }
}

测试

测试类

package com.knife.designPattern.controller;

import com.knife.designPattern.bo.CancelOrderBO;
import com.knife.designPattern.subject.SubjectHolder;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@Api(tags = "订单")
@RestController
@RequestMapping("order")
public class OrderController {
    @ApiOperation("取消订单")
    @PostMapping("cancel")
    public String cancel(@RequestBody CancelOrderBO cancelOrderBO) {
        SubjectHolder.process(cancelOrderBO);
        return "success";
    }
}

访问接口

启动项目后，访问Knife4j（接口文档）的地址：http://localhost:8080/doc.html

（当然，你用postman也完全可以）

结果

订单取消的相关数据：CancelOrderBO(orderNo=1234)
账户业务开始处理订单取消。接收到的消息：CancelOrderBO(orderNo=1234)
库存业务开始处理订单取消。接收到的消息：CancelOrderBO(orderNo=1234)