博主 默语带您 Go to New World.
✍ 个人主页—— 默语 的博客👦🏻
《java 面试题大全》
《java 专栏》
🍩惟余辈才疏学浅,临摹之作或有不妥之处,还请读者海涵指正。☕🍭
《MYSQL从入门到精通》数据库是开发者必会基础之一~
🪁 吾期望此文有资助于尔,即使粗浅难及深广,亦备添少许微薄之助。苟未尽善尽美,敬请批评指正,以资改进。!💻⌨
Java设计模式:使用责任链模式和状态模式优化审批流程
在现代软件开发过程中,动态审核流程是确保数据质量和流程合规性的关键环节。本文将深入探讨一种链式处理模式,通过详实的代码示例和理论分析,展示如何高效构建一个灵活的审核流程。关键词:动态审核流程,链式处理模式,Java实现。
在多用户环境下,如何高效且安全地管理和审核流程成为一个常见挑战。链式处理模式提供了一种优雅的解决方案,使得每个审核环节可以独立处理,同时保持整体流程的连贯性和扩展性。
目前项目开发中遇到这样一个处理流程;
比如a发布–>b用户审核(审核过下一步不过打回)–>c用户审核(审核过下一步不过打回)–>发布成功(大家都能看到这个)
下面是简易的业务流程图
链式处理模式(Chain of Responsibility)是一种常用的设计模式,通过将请求的发送者和接收者解耦,让多个对象都有机会处理这个请求。在本案例中,我们将使用Java语言演示一个简单的发布审核流程,其中包含多个审核阶段。
该功能有多种实现方式,下面给出3个简单的示例
下面这段Java代码实现了一个简单的责任链模式(Chain of Responsibility Pattern)。责任链模式是一种行为设计模式,允许多个对象处理一个请求,或者将这些对象连成一条链。请求在这条链上传递,直到一个对象处理它为止。下面是对这段代码使用的设计模式、方法及其好处的详细解析:
处理器接口(Handler):
processRequest
方法,用于处理请求并返回响应。所有的具体处理器都需要实现这个接口。具体处理器(HandlerA 和 HandlerB):
nextHandler
成员,它指向链中的下一个处理器。请求(Request)和响应(Response)类:
请求和响应的创建与管理:
处理请求:
HandlerA
和 HandlerB
的 processRequest
方法中,请求被检查和处理。处理器根据用户的输入(“approve” 或 “reject”)来决定是自己完成处理还是传递给下一个处理器。链的建立:
main
方法中,创建处理器对象并通过 setNextHandler
方法设置它们的顺序。这种方式构建了处理器的责任链。低耦合性:
增强了灵活性:
简化了对象之间的连接:
分散了请求处理:
此设计模式非常适合于处理那些可能由多个不同对象处理的请求,每个对象处理它能处理的部分,不能处理的部分传递给链中的下一个对象。这在很多需要多级审批的系统中非常实用。
package com.example.sjms;
import java.util.Scanner; // 导入需要使用的Scanner类
public class celms {
// 定义请求类
static class Request {
private String content; // 请求内容
// 请求类构造函数
public Request(String content) {
this.content = content; // 初始化请求内容
}
// 获取请求内容的方法
public String getContent() {
return content;
}
}
// 定义响应类
static class Response {
private String content; // 响应内容
// 响应类构造函数
public Response(String content) {
this.content = content; // 初始化响应内容
}
// 获取响应内容的方法
public String getContent() {
return content;
}
// 设置响应内容的方法
public void setContent(String content) {
this.content = content;
}
}
// 定义处理器接口
interface Handler {
Response processRequest(Request request); // 处理请求的方法
}
// 具体处理器A
static class HandlerA implements Handler {
private Handler nextHandler; // 下一个处理器对象
// 实现处理请求的方法
@Override
public Response processRequest(Request request) {
System.out.println("正在处理请求,处理器A: " + request.getContent());
try (Scanner scanner = new Scanner(System.in)) {
System.out.println("用户审核(输入 'approve' 或 'reject'):");
String input = scanner.nextLine().trim();
// 判断用户输入,决定是否通过或者传递给下一个处理器
if (input.equalsIgnoreCase("approve")) {
return (nextHandler != null) ? nextHandler.processRequest(request) : new Response("发布成功");
} else {
return new Response("被驳回");
}
} catch (Exception ex) {
// 捕捉异常并返回处理中出现错误
return new Response("处理中出现错误");
}
}
// 设置下一个处理器的方法
public void setNextHandler(Handler nextHandler) {
this.nextHandler = nextHandler;
}
}
// 具体处理器B
static class HandlerB implements Handler {
private Handler nextHandler; // 下一个处理器对象
// 实现处理请求的方法
@Override
public Response processRequest(Request request) {
try (Scanner scanner = new Scanner(System.in)) {
System.out.println("用户审核(输入 'approve' 或 'reject'):");
String input = scanner.nextLine().trim();
// 判断用户输入,决定是否通过或者传递给下一个处理器
if (input.equalsIgnoreCase("approve")) {
return (nextHandler != null) ? nextHandler.processRequest(request) : new Response("发布成功");
} else {
return new Response("被驳回");
}
} catch (Exception ex) {
// 捕捉异常并返回处理中出现错误
return new Response("处理中出现错误");
}
}
// 设置下一个处理器的方法
public void setNextHandler(Handler nextHandler) {
this.nextHandler = nextHandler;
}
}
public static void main(String[] args) {
// 创建处理器A和B对象
HandlerA handlerA = new HandlerA();
HandlerB handlerB = new HandlerB();
// 设置处理器A的下一个处理器为处理器B
handlerA.setNextHandler(handlerB);
// 创建一个请求对象
Request request = new Request("待发布内容");
// 处理请求并获取响应
Response response = handlerA.processRequest(request);
/**
* 创建请求对象:
* Request request = new Request("待发布内容"); 这行代码创建了一个请求对象,传入的参数是待发布的内容字符串 "待发布内容"。这个请求对象将在处理过程中被传递给处理器,并沿着责任链向下传递。
* 处理请求并获取响应:
* Response response = handlerA.processRequest(request); 这行代码调用了处理器A的 processRequest 方法,并将之前创建的请求对象 request 作为参数传递进去。处理器A将根据请求内容执行相应的操作,并可能将请求传递给下一个处理器。最终,这个方法返回一个响应对象,表示处理的结果。在这里,我们将得到的响应对象赋值给 response 变量,以便后续使用。
*/
// 输出最终结果
System.out.println("最终结果: " + response.getContent());
}
}
这段代码也是一个实现了责任链模式(Chain of Responsibility Pattern)的示例,不过它更加简化并集中了一些功能。这里的处理器(HandlerA 和 HandlerB)被设计为按顺序处理一个请求对象,根据用户的输入决定是否批准请求或将其拒绝。每个处理器在用户输入批准后可以将请求传递给下一个处理器,如果没有下一个处理器或用户输入拒绝,则结束请求的处理。下面是对这段代码的具体分析:
处理器接口(Handler):
processRequest
方法,这是责任链中每个节点共有的处理请求的接口。具体处理器(HandlerA 和 HandlerB):
Handler
接口,每个处理器根据输入决定是否处理请求或将其传递给链中的下一个处理器。请求(Request)和响应(Response)类:
构建责任链:
main
方法中,处理器对象被创建并通过 setNextHandler
方法相互链接,形成责任链。处理请求:
动态决策和处理:
灵活性:
解耦:
扩展性:
维护性:
这种模式适用于处理那些可能需要多个对象共同参与的请求,如不同级别的权限审批。在实际应用中,这种模式可以用于工作流管理、事件处理系统等场景。
package com.example.sjms;
import java.util.Scanner;
/**
* Chain of Responsibility 模式演示
* 客户端类包含所有代码,采用责任链模式实现审核流程控制
*/
public class celms2 {
/**
* 请求类
*/
static class Request {
private String content;
public Request(String content) {
this.content = content;
}
public String getContent() {
return content;
}
}
/**
* 响应类
*/
static class Response {
private String content;
public Response(String content) {
this.content = content;
}
public String getContent() {
return content;
}
public void setContent(String content) {
this.content = content;
}
}
// 定义处理器接口
interface Handler {
Response processRequest(Request request);
}
// 具体处理器A
static class HandlerA implements Handler {
private Handler nextHandler;
@Override
public Response processRequest(Request request) {
System.out.println("处理器A正在处理请求:" + request.getContent());
// 模拟B用户审核
Scanner scanner = new Scanner(System.in);
System.out.println("B用户审核(输入 'approve' 或 'reject'):");
String input = scanner.nextLine().trim();
if (input.equalsIgnoreCase("approve")) {
return (nextHandler != null) ? nextHandler.processRequest(request) : new Response("发布成功");
} else {
return new Response("被驳回");
}
}
public void setNextHandler(Handler nextHandler) {
this.nextHandler = nextHandler;
}
}
// 具体处理器B
static class HandlerB implements Handler {
private Handler nextHandler;
@Override
public Response processRequest(Request request) {
System.out.println("处理器B正在处理请求:" + request.getContent());
// 模拟C用户审核
Scanner scanner = new Scanner(System.in);
System.out.println("C用户审核(输入 'approve' 或 'reject'):");
String input = scanner.nextLine().trim();
if (input.equalsIgnoreCase("approve")) {
return (nextHandler != null) ? nextHandler.processRequest(request) : new Response("发布成功");
} else {
return new Response("被驳回");
}
}
public void setNextHandler(Handler nextHandler) {
this.nextHandler = nextHandler;
}
}
// 客户端类
public static void main(String[] args) {
// 创建处理器A和B对象
HandlerA handlerA = new HandlerA();
HandlerB handlerB = new HandlerB();
// 设置处理器A的下一个处理器为处理器B
handlerA.setNextHandler(handlerB);
// 创建一个请求对象
Request request = new Request("待审核内容");
// 处理请求并获取响应
Response response = handlerA.processRequest(request);
// 输出最终结果
System.out.println("最终结果: " + response.getContent());
}
}
这段代码是一个典型的状态模式(State Pattern)的应用。状态模式是一种行为设计模式,允许一个对象在其内部状态改变时改变它的行为。这是通过将每个状态逻辑封装到对应的类中来实现的。在这段代码中,每个状态类都实现了一个共同的接口 ApprovalState
,这样不同的状态可以以不同的方式处理相同的行为。
processApproval
方法,该方法接受一个请求对象和审批流程上下文作为参数。ApprovalState
接口,提供了处理审批请求的具体实现。根据用户输入,这些状态类可以改变审批流程的当前状态。setCurrentState
方法来改变当前状态,以及 processApproval
方法来开始或继续审批流程。PendingState
中,根据用户输入,状态可能转换为 ApprovedState
或 RejectedState
。如果输入错误,将递归调用自身直到获得有效输入。这种模式特别适合用于那些对象的行为依赖于其状态的场景,且状态的改变需要引起行为的改变。在这个例子中,它帮助管理了复杂的审批流程,每个状态都有明确的行为和转换逻辑。这使得维护和理解审批流程变得更容易,尤其是在涉及多个审批阶段和条件时。
package com.example.sjms;
import java.util.Scanner;
public class celms3 {
/**
* 审批状态接口
*/
interface ApprovalState {
void processApproval(Request request, ApprovalProcess process);
}
/**
* 待审批状态
*/
static class PendingState implements ApprovalState {
@Override
public void processApproval(Request request, ApprovalProcess process) {
System.out.println("当前状态:待审批");
System.out.println("内容:" + request.getContent());
System.out.println("等待审批中...");
// 模拟审批人员操作
Scanner scanner = new Scanner(System.in);
System.out.println("请输入审批结果(通过/拒绝):");
String input = scanner.nextLine().trim();
if (input.equalsIgnoreCase("通过")) {
process.setCurrentState(new ApprovedState());
} else if (input.equalsIgnoreCase("拒绝")) {
process.setCurrentState(new RejectedState());
} else {
System.out.println("输入错误,请重新输入!");
processApproval(request, process); // 递归调用,直到输入正确为止
}
}
}
/**
* 通过状态
*/
static class ApprovedState implements ApprovalState {
@Override
public void processApproval(Request request, ApprovalProcess process) {
System.out.println("当前状态:已通过");
System.out.println("内容:" + request.getContent());
System.out.println("审批已通过,流程结束。");
// 在审批通过后输出结果
System.out.println("审批结果:" + request.getContent() + " 已通过。");
}
}
/**
* 拒绝状态
*/
static class RejectedState implements ApprovalState {
@Override
public void processApproval(Request request, ApprovalProcess process) {
System.out.println("当前状态:已拒绝");
System.out.println("内容:" + request.getContent());
System.out.println("审批已拒绝,流程结束。");
// 在审批拒绝后输出结果
System.out.println("审批结果:" + request.getContent() + " 已拒绝。");
}
}
/**
* 审批流程上下文
*/
static class ApprovalProcess {
private ApprovalState currentState;
public ApprovalProcess() {
this.currentState = new PendingState(); // 初始状态为待审批
}
public void setCurrentState(ApprovalState currentState) {
this.currentState = currentState;
}
public void processApproval(Request request) {
currentState.processApproval(request, this); // 委托给当前状态处理审批流程
}
}
/**
* 请求类
*/
static class Request {
private String content;
public Request(String content) {
this.content = content;
}
public String getContent() {
return content;
}
}
/**
* 客户端类
*/
public static void main(String[] args) {
ApprovalProcess process = new ApprovalProcess(); // 创建审批流程对象
Request request = new Request("待审核内容"); // 创建请求对象
// 处理请求,初始状态为待审批
process.processApproval(request);
// 输出结果
System.out.println("审批流程结束。");
}
}
本文中,我们分析了三个不同的Java代码示例,每个示例都实现了一种设计模式:责任链模式和状态模式。以下是对这些代码的详细分析和各自的总结:
在前两个示例中,责任链模式被用来处理一个请求的审批流程。在这种模式中,多个对象(处理器)按顺序接收并处理请求,直到其中一个能处理该请求为止。每个处理器决定它是否能处理该请求或者是否将其传递给链中的下一个处理器。
关键特点包括:
第三个示例展示了状态模式,其中审批流程的不同状态被封装在不同的状态对象中。状态模式允许对象在其内部状态改变时改变它的行为,这是通过将每个状态逻辑封装到对应的类中来实现的。
关键特点包括:
这些设计模式各有其优势和适用场景。责任链模式适用于处理那些可能由多个不同对象处理的请求,特别是在处理流程中需要多级审批的系统中非常实用。而状态模式则适合于管理那些对象行为依赖于其状态的场景,它通过对状态的封装,简化了状态管理和行为变更,提高了系统的灵活性和可维护性。在实际应用中,根据系统的需求选择合适的设计模式,可以有效提升代码的可管理性和扩展性。
🪁🍁 希望本文能够给您带来一定的帮助🌸文章粗浅,敬请批评指正!🍁🐥
如对本文内容有任何疑问、建议或意见,请联系作者,作者将尽力回复并改进📓;(联系微信:Solitudemind )
点击下方名片,加入IT技术核心学习团队。一起探索科技的未来,共同成长。