Java 设计模式之责任链模式及异步责任链详解
作者:普通人zzz~ 时间:2021-08-08 19:14:23
一、定义
责任链模式(Chain of Responsibility Pattern):避免将一个请求的发送者与接受者耦合在一起,让多个对象都有机会处理请求。将接受请求的对象连接成一条链,并且沿着这条链传递请求,直到有一个对象能够处理它为止。
在很多源码都有涉及,如Mybatis * 、Filter…
责任链模式属于行为型模式。
二、普通责任链模式
抽象处理类:AbstractProcessor
/**
* 抽象处理类
*/
public abstract class AbstractProcessor {
// 责任链
private AbstractProcessor nextProcessor;
public void setNextProcessor(AbstractProcessor nextProcessor){
this.nextProcessor = nextProcessor;
}
/**
* 链路调用
* @param obj
*/
public void execute(Object obj) {
this.processor(obj);
if (this.nextProcessor != null){
this.nextProcessor.execute(obj);
}
}
public abstract void processor(Object obj);
}
具体类:ParamsProcessor、CheckProcessor、FinalProcessor
public class ParamsProcessor extends AbstractProcessor{
@Override
public void processor(Object obj) {
System.out.println("paramsProcessor>>>>>>>>>>" + obj.toString());
}
}
public class CheckProcessor extends AbstractProcessor{
@Override
public void processor(Object obj) {
System.out.println("checkProcessor>>>>>>>>>>" + obj.toString());
}
}
public class FinalProcessor extends AbstractProcessor{
@Override
public void processor(Object obj) {
System.out.println("finalProcessor>>>>>>>>>>" + obj.toString());
}
}
测试类:ProcessorMainTest
public class ProcessorMainTest {
public static void main(String[] args) {
/**
* 构建一个链路
* paramsProcessor -> checkProcessor -> finalProcessor
*/
AbstractProcessor paramsProcessor = new ParamsProcessor();
AbstractProcessor checkProcessor = new CheckProcessor();
AbstractProcessor finalProcessor = new FinalProcessor();
paramsProcessor.setNextProcessor(checkProcessor);
checkProcessor.setNextProcessor(finalProcessor);
paramsProcessor.execute("Java责任链模式");
}
}
执行结果
paramsProcessor>>>>>>>>>>Java责任链模式
checkProcessor>>>>>>>>>>Java责任链模式
finalProcessor>>>>>>>>>>Java责任链模式
三、异步责任链模式
异步责任链模式采用责任链模式、生产者消费者模式组合。
抽象处理类:AbstractAsynProcessor
/**
* 异步责任链:采用线程、生产者消费者模式实现
*/
public abstract class AbstractAsynProcessor extends Thread {
// 用于存放当前责任链需要处理的对象
protected BlockingQueue<Object> queue;
// 链路对象
private AbstractAsynProcessor nextProcessor;
/**
* 执行
*
* @param obj
*/
public void execute(Object obj) throws InterruptedException {
this.processor(obj);
if (this.nextProcessor != null) {
this.nextProcessor.getQueue().put(obj);
}
}
@Override
public void run() {
// 执行
try {
while (true) {
// 生产者消费者
Object obj = this.queue.take();
execute(obj);
}
} catch (InterruptedException e) {
e.printStackTrace();
}
}
public abstract void processor(Object obj);
public BlockingQueue<Object> getQueue() {
return queue;
}
public void setNextProcessor(AbstractAsynProcessor nextProcessor) {
this.nextProcessor = nextProcessor;
}
}
具体类:AsynParamsProcessor、AsynCheckProcessor、AsynFinalProcessor
public class AsynParamsProcessor extends AbstractAsynProcessor {
public AsynParamsProcessor() {
// 初始化队列
this.queue = new LinkedBlockingQueue<>();
}
@Override
public void processor(Object obj) {
System.out.println("asynParamsProcessor>>>>>>>>>>" + obj.toString());
}
}
public class AsynCheckProcessor extends AbstractAsynProcessor {
public AsynCheckProcessor(){
this.queue = new LinkedBlockingQueue<>();
}
@Override
public void processor(Object obj) {
System.out.println("asynCheckProcessor>>>>>>>>>>" + obj.toString());
}
}
public class AsynFinalProcessor extends AbstractAsynProcessor {
public AsynFinalProcessor() {
this.queue = new LinkedBlockingQueue<>();
}
@Override
public void processor(Object obj) {
System.out.println("asynFinalProcessor>>>>>>>>>>" + obj.toString());
}
}
测试类:AsynProcessorMainTest
public class AsynProcessorMainTest {
public static void main(String[] args) throws InterruptedException {
/**
* 构建一个链路
* asynParamsProcessor -> asynCheckProcessor -> asynFinalProcessor
*/
AbstractAsynProcessor asynParamsProcessor = new AsynParamsProcessor();
asynParamsProcessor.start();
AbstractAsynProcessor asynCheckProcessor = new AsynCheckProcessor();
asynCheckProcessor.start();
AbstractAsynProcessor asynFinalProcessor = new AsynFinalProcessor();
asynFinalProcessor.start();
asynParamsProcessor.setNextProcessor(asynCheckProcessor);
asynCheckProcessor.setNextProcessor(asynFinalProcessor);
Scanner input = new Scanner(System.in);
while (true) {
Thread.sleep(1000);
System.out.print("请输入:");
asynParamsProcessor.getQueue().put(input.next());
}
}
}
执行结果
请输入:Java异步责任链
asynParamsProcessor>>>>>>>>>>Java异步责任链
asynCheckProcessor>>>>>>>>>>Java异步责任链
asynFinalProcessor>>>>>>>>>>Java异步责任链
来源:https://blog.csdn.net/qq_33375499/article/details/121186261
标签:Java,责任链模式,异步责任链
![](/images/zang.png)
![](/images/jiucuo.png)
猜你喜欢
什么是Java自旋锁
2022-09-22 22:10:55
![](https://img.aspxhome.com/file/2023/1/72301_0s.png)
详解Java高级特性之反射
2021-06-09 14:01:06
Spring+SpringMVC+MyBatis深入学习及搭建(一)之MyBatis的基础知识
2021-09-27 15:12:59
![](https://img.aspxhome.com/file/2023/3/66503_0s.png)
obix协议在java中的配置和使用详解
2023-11-25 20:59:42
![](https://img.aspxhome.com/file/2023/5/60275_0s.jpg)
spring mvc4的日期/数字格式化、枚举转换示例
2021-11-07 09:49:11
![](https://img.aspxhome.com/file/2023/0/60840_0s.jpg)
Spring Retry 重试实例详解
2021-07-15 22:43:26
![](https://img.aspxhome.com/file/2023/5/63495_0s.png)
一文教会你使用jmap和MAT进行堆内存溢出分析
2023-11-06 08:01:57
![](https://img.aspxhome.com/file/2023/3/58763_0s.png)
Java Bean与xml互相转换的方法分析
2021-08-12 13:34:00
Springmvc ResponseBody响应json数据实现过程
2022-06-12 15:22:30
Java8 CompletableFuture runAsync学习总结submit() execute()等
2023-05-25 04:13:43
![](https://img.aspxhome.com/file/2023/3/71943_0s.png)
Java8 用Lambda表达式给List集合排序的实现
2023-02-05 17:27:09
MyBatis根据条件批量修改字段的方式
2023-12-16 03:24:01
使用mongoTemplate实现多条件加分组查询方式
2022-05-21 01:41:51
Mybatis实现插入数据后返回主键过程解析
2022-07-14 18:43:15
Spring实现动态切换多数据源的解决方案
2023-05-21 13:07:15
Java数据结构之优先级队列(堆)图文详解
2021-06-25 13:47:58
![](https://img.aspxhome.com/file/2023/2/68022_0s.png)
java实现微信红包 拼手气红包
2023-09-28 10:31:45
![](https://img.aspxhome.com/file/2023/3/67113_0s.jpg)
详谈java 堆区、方法区和栈区
2023-11-23 18:35:22
浅谈SpringMVC的执行流程
2023-09-30 17:59:59
![](https://img.aspxhome.com/file/2023/8/62358_0s.png)
MyBatis-Plus多表联查(动态查询)的项目实践
2023-11-19 21:43:17
![](https://img.aspxhome.com/file/2023/3/59663_0s.png)