当前位置: 首页 > news >正文

行为型模式 - 观察者模式 (Publish/Subscribe)

行为型模式 - 观察者模式 (Publish/Subscribe)

又称作为订阅发布模式(Publish-Subscribe Pattern)是一种消息传递模式,在该模式中,发送者(发布者)不会直接将消息发送给特定的接收者(订阅者),而是将消息发布到一个中间的消息代理(如主题或频道),订阅了该主题的订阅者可以接收到这些消息。以下是几个订阅发布模式的经典案例。


import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

// 主题接口
interface Subject {
    void registerObserver(Observer observer, String newsType);
    void removeObserver(Observer observer, String newsType);
    void notifyObservers(String newsType, String news);
}

// 观察者接口
interface Observer {
    void update(String news);
}

// 新闻机构类,实现主题接口
class NewsAgency implements Subject {
    private Map<String, List<Observer>> observers = new HashMap<>();

    @Override
    public void registerObserver(Observer observer, String newsType) {
        observers.computeIfAbsent(newsType, k -> new ArrayList<>()).add(observer);
    }

    @Override
    public void removeObserver(Observer observer, String newsType) {
        List<Observer> observerList = observers.get(newsType);
        if (observerList != null) {
            observerList.remove(observer);
        }
    }

    @Override
    public void notifyObservers(String newsType, String news) {
        List<Observer> observerList = observers.get(newsType);
        if (observerList != null) {
            for (Observer observer : observerList) {
                observer.update(news);
            }
        }
    }

    public void publishNews(String newsType, String news) {
        System.out.println("发布 " + newsType + " 新闻: " + news);
        notifyObservers(newsType, news);
    }
}

// 用户类,实现观察者接口
class User implements Observer {
    private String name;

    public User(String name) {
        this.name = name;
    }

    @Override
    public void update(String news) {
        System.out.println(name + " 收到新闻: " + news);
    }
}

// 客户端代码
public class NewsSystem {
    public static void main(String[] args) {
        NewsAgency newsAgency = new NewsAgency();

        User user1 = new User("张三");
        User user2 = new User("李四");

        // 用户订阅体育新闻
        newsAgency.registerObserver(user1, "体育");
        newsAgency.registerObserver(user2, "体育");

        // 用户订阅财经新闻
        newsAgency.registerObserver(user1, "财经");

        // 发布体育新闻
        newsAgency.publishNews("体育", "篮球比赛结果公布");

        // 发布财经新闻
        newsAgency.publishNews("财经", "股市行情上涨");
    }
}
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.dtcms.com/a/45521.html

相关文章:

  • 【华三】从零开始掌握SR技术:原理、架构与应用全解析
  • golang介绍,特点,项目结构,基本变量类型与声明介绍(数组,切片,映射),控制流语句介绍(条件,循环,switch case)
  • 开发一个o2o(线上到线下)商城需要具备以下条件
  • 快速入手-搭建Flask框架封装mysql并结合业务实际情况使用
  • 【MySQL】MySQL用户管理
  • Flask笔记
  • 在 Element Plus 的 <el-select> 组件中,如果需要将 <el-option> 的默认值设置为 null。 用于枚举传值
  • JavaScript 注释
  • LeetCode 解题思路 6(Hot 100)
  • Nginx 配置与常用命令速查手册
  • 神经网络|(十一)|神经元和神经网络
  • Hive-01之数仓、架构、数据类型、DDL、内外部表
  • 纯c#字体处理库(FontParser) -- 轻量、极速、跨平台、具有字体子集化功能
  • 开源程序wordpress在海外品牌推广中的重要作用
  • Qt空项目代码解释
  • Redis SCAN 命令详解:安全遍历海量键的利器
  • SOA(面向服务架构)全面解析
  • 【wiki知识库】07.用户管理后端SpringBoot部分
  • 左值引用与右值引用
  • NO.22十六届蓝桥杯备战|一维数组|七道练习|冒泡排序(C++)
  • 对seacmsv9进行sql注入,orderby,过滤information_schema
  • 构建神经网络之常用pandas(补充中 )
  • leetcode459 重复的子字符串 周期性字符串问题 KMP算法
  • 解析AI工具库中三款 AI 图片转页面工具
  • Vidma Ver.2.14.0 高级版
  • OpenSSL 基础使用流程
  • 2025年山东省职业院校技能大赛(高职组)“云计算应用”赛项赛卷1
  • 洛谷 P1067 [NOIP 2009 普及组] 多项式输出(详解)c++
  • HTML AI 编程助手
  • 用大白话解释 持久框架Mybatis-Plus——像“瑞士军刀”一样简单