Java怎么实现监听者模式

这篇文章主要介绍了Java怎么实现监听者模式，具有一定借鉴价值，感兴趣的朋友可以参考下，希望大家阅读完这篇文章之后大有收获，下面让小编带着大家一起了解一下。

代码展示

Main：测试类

ObServer：每个被监听的对象实现该接口，重写该方法，完成自己的业务

public interface ObServer {     /**     * 当某一个被监控的对象发生变化时     * 所有实现该方法处理方法     */    void exceptionHandler(); }

Subject：监听者容器

public interface Subject {      /**     * 添加被观察对象     */    void add(ObServer obServer);     /**     * 通知所有被观察者完成自己的 exceptionHandler 方法     */    void notifyAllSubject(); }

SubjectHandler：监听者容器的实现类

public class SubjectHandler implements Subject {     /**     * 存放被监听对象     */    private static final List SUBJECTS = Collections.synchronizedList(new LinkedList<>());     @Override    public void add(ObServer subject) {        SUBJECTS.add(subject);    }     @Override    public void notifyAllSubject() {        SUBJECTS.forEach(ObServer::exceptionHandler);    }}

Thread1、Thread2 测试对象

模拟两个线程对数据库操作，若Threa1执行时出异常了，那么终止所有线程并对其回滚。

Threa1:

public class Thread1 implements ObServer, Runnable {     @SneakyThrows    @Override    public void run() {        System.out.println("thread1 run");        Thread.sleep(1000);        System.out.println("t1 end");    }     @SneakyThrows    @Override    public void exceptionHandler() {        System.out.println("thread1 rollback.....");    }}

Thread2:

public class Thread2 implements ObServer, Runnable {     private static Thread CURRENT_THREAD;     private static volatile boolean FLAG = false;     @SneakyThrows    @Override    public void run() {        CURRENT_THREAD = Thread.currentThread();        System.out.println("thread2 running");        int count = 0;        while (!FLAG) {            System.out.println(count);            count++;        }        System.out.println("thread2 end");    }      @SneakyThrows    @Override    public void exceptionHandler() {        FLAG = true;        CURRENT_THREAD.interrupt();        System.out.println("thread2 rollback.....");    }}

测试Demo

public static void main(String[] args) throws InterruptedException {         // 创建监听容器        Subject subject = new SubjectHandler();        Thread1 thread1 = new Thread1();        Thread2 thread2 = new Thread2();        subject.add(thread1);        subject.add(thread2);                CompletableFuture.supplyAsync(() -> {            new Thread(thread1).start();            try {                Thread.sleep(10);                int a = 1 / 0; // 模拟线程1报错            } catch (InterruptedException e) {                e.printStackTrace();            }            return true;        }).exceptionally((error) -> {            subject.notifyAllSubject();            return false;        });         CompletableFuture.supplyAsync(() -> {            new Thread(thread2).start();            return true;        }).exceptionally((error) -> {            subject.notifyAllSubject();            return false;        });         // main thread await        Thread.sleep(60 * 1000);    }

测试结果

在 java.util 包下提供了Observable（监听容器）和 Observer接口（被监听者），用法跟我们完全一致，只需实现Observer的update方法，把每个Observer子类添加到监听容器中。

注意：在调用监听容器的通知所有servers时首先调用一下其setChanged方法

将changed变为true（默认flase）

感谢你能够认真阅读完这篇文章，希望小编分享的"Java怎么实现监听者模式"这篇文章对大家有帮助，同时也希望大家多多支持，关注行业资讯频道，更多相关知识等着你来学习!