这篇文章主要介绍了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<ObServer> 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怎么实现监听者模式”这篇文章对大家有帮助，同时也希望大家多多支持亿速云，关注亿速云行业资讯频道，更多相关知识等着你来学习!
亿速云「云服务器」，即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘，价格低至29元/月。点击查看>>
免责声明：本站发布的内容（图片、视频和文字）以原创、转载和分享为主，文章观点不代表本网站立场，如果涉及侵权请联系站长邮箱：is@yisu.com进行举报，并提供相关证据，一经查实，将立刻删除涉嫌侵权内容。
