观察者模式-526互联

观察者模式

1: 定义

观察者模式是一种行为设计模式，允许你定义一种订阅机制，可在对象事件发生时通知多个 “观察” 该对象的其他对象是一种行为设计模式，允许你定义一种订阅机制，可在对象事件发生时通知多个 “观察” 该对象的其他对象

2: 示例

我们模拟下订单和支付的的动作，通过观察者模式实现。

/**
 * 事件处理抽象类
 * @author wei1.zhang
 * @date 2023/12/7 14:36
 */
public interface EventListener {

    /**
     * 事件处理抽象类
     */
    void doEvent(EventContext eventContext);
}

/**
 * 订单监听器
 * @author zhangwei09
 * @date 2023/12/7 14:37
 */
public class OrderListener implements EventListener{

    @Override
    public void doEvent(EventContext eventContext) {
        System.out.println("[用户]:"+ eventContext.getUserId()+"--[订单事件]:" + eventContext.getEventType()+"---[发生时间]:" + eventContext.getLocalDateTime());
    }
}

/**
 * 支付监听器
 * @author zhangwei09
 * @date 2023/12/7 14:37
 */
public class PayListener implements EventListener{

    @Override
    public void doEvent(EventContext eventContext) {
        System.out.println("[用户]:"+ eventContext.getUserId()+"--[支付事件]:" + eventContext.getEventType()+"---[发生时间]:" + eventContext.getLocalDateTime());
    }
}

/**
 * 事件监听器管理
 * @author zhangwei09
 * @date 2023/12/7 14:36
 */
public class EventManager {

    Map<String, List<EventListener>> listeners = new HashMap<>();

    /**
     *  事件监听器管理构造
     *
     * @param eventTypes
     */
    public EventManager(String... eventTypes) {
        for (String eventType : eventTypes) {
            this.listeners.put(eventType, new ArrayList<>());
        }
    }

    /**
     * 事件发布
     */
    public void subscribe(String eventType, EventListener listener) {
        List<EventListener> users = listeners.get(eventType);
        users.add(listener);
    }

    /**
     * 事件通知
     */
    public void notify(EventContext eventContext) {
        List<EventListener> eventListeners = listeners.get(eventContext.getEventType());
        for (EventListener listener : eventListeners) {
            listener.doEvent(eventContext);
        }
    }
}

/**
 *  事件上下文
 * @author zhangwei09
 * @date 2023/12/7 15:25
 */
public class EventContext {

    private String eventType;
    private String userId;
    private LocalDateTime localDateTime;


    public String getEventType() {
        return eventType;
    }

    public void setEventType(String eventType) {
        this.eventType = eventType;
    }

    public String getUserId() {
        return userId;
    }

    public void setUserId(String userId) {
        this.userId = userId;
    }

    public LocalDateTime getLocalDateTime() {
        return localDateTime;
    }

    public void setLocalDateTime(LocalDateTime localDateTime) {
        this.localDateTime = localDateTime;
    }
}

测试类

public class TestMain {
    public static void main(String[] args) {
        String userId = "wei1.zhang";
        Customer customer = new Customer(userId);
        customer.events.subscribe("order", new PayListener());
        customer.events.subscribe("pay", new OrderListener());

        try {
            EventContext eventContext = new EventContext();
            eventContext.setUserId(userId);
            eventContext.setEventType("order");
            eventContext.setLocalDateTime(LocalDateTime.now());
            customer.order(eventContext);

            eventContext.setEventType("pay");
            eventContext.setLocalDateTime(LocalDateTime.now());
            customer.payOrder(eventContext);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

以上是通过观察者模式模拟下订单，支付的场景。在生产环境，我们肯定不会这么写。主要是想通过代码让读者体会一下观察者模式。