- 使用 Spring Initializr 创建 Spring Boot 应用程序
- 在Spring Boot中配置Cassandra
- 在 Spring Boot 上配置 Tomcat 连接池
- 将Camel消息路由到嵌入WildFly的Artemis上
状态模式(State Pattern)指允许一个对象在其内部状态改变时改变它的行为,对象看起来似乎修改了它的类。
一般用来实现状态机,而状态机常用在游戏、工作流引擎等系统的开发中:
有限状态机(Finite State Machine,FSM),状态机有三个组成部分:状态(State)、事件(Event)和动作(Action)。其中事件也叫作转移条件(Transition Condition),事件主要用于触发状态的转移及动作的执行,动作不是必须的,也可能只转移状态,不执行任何动作。
状态模式又名状态对象(Objects for States),它是一种对象行为型模式。它的解决思想是当控制一个对象状态转换的条件表达式过于复杂时,把相关“判断逻辑”提取出来,用各个不同的类进行表示,系统处于哪种情况、直接使用相应的状态类对象进行处理。
在状态模式的结构中,通过实现抽象状态类的具体状态类来定义多个状态,每个状态类仅实现自己的逻辑,上下文类负责切换状态。其结构类图如下所示:
State
:抽象状态类,提供一个方法封装上下文对象的状态ConcreteState1、ConcreteState2
:具体状态类,继承抽象状态类,实现状态下的行为Context
:上下文类,负责对具体状态进行切换Client
:客户端,调用具体状态和上下文首先是抽象状态类,具体代码如下:
public abstract class State {
/**抽象业务方法,不同的具体状态可以有不同的实现*/
public abstract void handle();
}
其次是实现抽象状态类的具体状态类:
public class ConcreteState1 extends State{
@Override
public void handle(Context context) {
System.out.println("进入ConcreteState1中~");
context.setState(this);
}
@Override
public String toString() {
return "concreteState1";
}
}
public class ConcreteState2 extends State{
@Override
public void handle(Context context) {
System.out.println("进入ConcreteState2中~");
context.setState(this);
}
@Override
public String toString() {
return "ConcreteState2";
}
}
接下来是上下文类,维护当前状态,并负责具体状态的切换
public class Context {
private State state;
//设置初始状态为null
public Context() {
state = null;
}
//实现状态转换
public void setState(State state) {
this.state = state;
}
public State getState() {
return state;
}
}
客户端测试类
public class Client {
public static void main(String[] args) {
Context context = new Context();
System.out.println("现在的状态是:" + context.getState());
System.out.println("---------------------------------");
State concreteState1 = new ConcreteState1();
concreteState1.handle(context);
System.out.println("现在的状态是:" + context.getState());
System.out.println("---------------------------------");
State concreteState2 = new ConcreteState2();
concreteState2.handle(context);
System.out.println("现在的状态是:" + context.getState());
}
}
测试结果:
现在的状态是:null
---------------------------------
进入ConcreteState1中~
现在的状态是:concreteState1
---------------------------------
进入ConcreteState2中~
现在的状态是:ConcreteState2
状态模式的应用比较广泛,比如游戏中角色状态的转换、公文审批中的流转等等。
以下情况可以考虑使用状态模式:
本案例中模拟营销活动审核状态流转场景,在一个活动的上线中是需要多个层级进行审核才能上线的(案例来源于《重学Java设计模式》)。如下图中可以看到流程节点中包括各个状态到下一个状态扭转的关联条件:
因此在审批过程中就难免会包含很多条件语句的判断,长此以往,随着状态数量的增加,会增加代码的可维护性和可读性。下面就利用状态模式来实现多状态的审批过程,先来看看状态模式模型的结构:
State
:状态抽象类,定义所有状态的操作接口CheckState、CloseState、DoingState...
:具体状态类,各种状态的具体逻辑实现StateHandler
:状态处理类,相当于之前结构中提到的上下文类,负责对状态流程进行统一处理public class ActivityInfo {
private String activityId;
private String activityName;
private Enum<Status> status;
private Date beginTime;
private Date endTime;
//get\set\Constructor
}
public enum Status {
Editing,
Check,
Pass,
Refuse,
Doing,
Close,
Open
}
public class ActivityService {
private static Map<String, Enum<Status>> statusMap = new ConcurrentHashMap<>();
public static void init(String activityId, Enum<Status> initStatus) {
ActivityInfo activityInfo = new ActivityInfo();
activityInfo.setActivityId(activityId);
activityInfo.setActivityName("测试活动");
activityInfo.setStatus(initStatus);
activityInfo.setBeginTime(new Date());
activityInfo.setEndTime(new Date());
statusMap.put(activityId, initStatus);
}
/**
* 查询活动信息
* @param activityId 活动ID
* @return 查询后的活动信息
*/
public static ActivityInfo queryActivityInfo(String activityId) {
ActivityInfo activityInfo = new ActivityInfo();
activityInfo.setActivityId(activityId);
activityInfo.setActivityName("测试活动");
activityInfo.setStatus(statusMap.get(activityId));
activityInfo.setBeginTime(new Date());
activityInfo.setEndTime(new Date());
return activityInfo;
}
/**
* 查询活动状态
* @param activityId 活动ID
* @return 查询后的活动状态
*/
public static Enum<Status> queryActivityStatus(String activityId) {
return statusMap.get(activityId);
}
public static synchronized void execStatus(String activityId, Enum<Status> beforeStatus, Enum<Status> afterStatus) {
/*如果前后两个状态相同,直接返回*/
if (!beforeStatus.equals(statusMap.get(activityId))) {
return;
}
/*反之更新statusMap*/
statusMap.put(activityId, afterStatus);
}
}
2.活动返回格式
public class Result {
private String code;
private String info;
//get/set
}
public abstract class State {
/**提审*/
public abstract Result arraignment(String activityId, Enum<Status> currentStatus);
/**撤审*/
public abstract Result checkRevoke(String activityId, Enum<Status> currentStatus);
/**审核通过*/
public abstract Result checkPass(String activityId, Enum<Status> currentStatus);
/**拒审*/
public abstract Result checkRefuse(String activityId, Enum<Status> currentStatus);
/**关闭*/
public abstract Result close(String activityId, Enum<Status> currentStatus);
/**开启活动*/
public abstract Result open(String activityId, Enum<Status> currentStatus);
/**活动中*/
public abstract Result doing(String activityId, Enum<Status> currentStatus);
}
public class CheckState extends State {
@Override
public Result arraignment(String activityId, Enum<Status> currentStatus) {
return new Result("0001", "提审后不能重复提审");
}
@Override
public Result checkRevoke(String activityId, Enum<Status> currentStatus) {
ActivityService.execStatus(activityId, Status.Check, Status.Editing);
return new Result("0000", "活动审核撤销回编辑");
}
@Override
public Result checkPass(String activityId, Enum<Status> currentStatus) {
ActivityService.execStatus(activityId, Status.Check, Status.Pass);
return new Result("0000", "活动审核通过");
}
@Override
public Result checkRefuse(String activityId, Enum<Status> currentStatus) {
ActivityService.execStatus(activityId, Status.Check, Status.Refuse);
return new Result("0000", "活动审核被拒绝");
}
@Override
public Result close(String activityId, Enum<Status> currentStatus) {
return new Result("0001", "活动审核后不能直接关闭");
}
@Override
public Result open(String activityId, Enum<Status> currentStatus) {
return new Result("0001", "活动审核后不能再开启");
}
@Override
public Result doing(String activityId, Enum<Status> currentStatus) {
return new Result("0001", "活动审核不通过无法进入活动中");
}
}
//下面依次是其他几个状态,较多省略
public class StateHandler {
private Map<Enum<Status>, State> stateMap = new ConcurrentHashMap<>();
public StateHandler() {
stateMap.put(Status.Check, new CheckState());
stateMap.put(Status.Close, new CloseState());
stateMap.put(Status.Doing, new DoingState());
stateMap.put(Status.Refuse, new RefuseState());
stateMap.put(Status.Pass, new PassState());
stateMap.put(Status.Open, new OpenState());
stateMap.put(Status.Editing, new EditingState());
}
public Result arraignment(String activityId, Enum<Status> currentStatus) {
return stateMap.get(currentStatus).arraignment(activityId, currentStatus);
}
public Result checkPass(String activityId, Enum<Status> currentStatus) {
return stateMap.get(currentStatus).checkPass(activityId, currentStatus);
}
public Result checkRefuse(String activityId, Enum<Status> currentStatus) {
return stateMap.get(currentStatus).checkRefuse(activityId, currentStatus);
}
public Result checkRevoke(String activityId, Enum<Status> currentStatus) {
return stateMap.get(currentStatus).checkRevoke(activityId, currentStatus);
}
public Result close(String activityId, Enum<Status> currentStatus) {
return stateMap.get(currentStatus).close(activityId, currentStatus);
}
public Result open(String activityId, Enum<Status> currentStatus) {
return stateMap.get(currentStatus).open(activityId, currentStatus);
}
public Result doing(String activityId, Enum<Status> currentStatus) {
return stateMap.get(currentStatus).doing(activityId, currentStatus);
}
}
5.测试类
public class ApiTest {
private Logger logger = LoggerFactory.getLogger(ApiTest.class);
@Test
public void test_Check2Close() {
String activityId = "100001";
ActivityService.init(activityId, Status.Check);
StateHandler stateHandler = new StateHandler();
Result result = stateHandler.close(activityId, Status.Check);
logger.info("测试结果(提审到关闭):{}", JSON.toJSONString(result));
logger.info("活动信息:{} 状态:{}", JSON.toJSONString(ActivityService.queryActivityInfo(activityId)), JSON.toJSONString(ActivityService.queryActivityStatus(activityId)));
}
@Test
public void test_Refuse2Revoke() {
String activityId = "100001";
ActivityService.init(activityId, Status.Refuse);
StateHandler stateHandler = new StateHandler();
Result result = stateHandler.checkRevoke(activityId, Status.Refuse);
logger.info("测试结果(拒绝To撤审):{}", JSON.toJSONString(result));
logger.info("活动信息:{} 状态:{}", JSON.toJSONString(ActivityService.queryActivityInfo(activityId)), JSON.toJSONString(ActivityService.queryActivityInfo(activityId).getStatus()));
}
}
测试结果:
19:49:48.755 [main] INFO ApiTest - 测试结果(拒绝To撤审):{"code":"0000","info":"拒绝后返回编辑状态"}
19:49:48.768 [main] INFO ApiTest - 活动信息:{"activityId":"100001","activityName":"测试活动","beginTime":1649591388759,"endTime":1649591388759,"status":"Editing"} 状态:"Editing"
《重学Java设计模式》
《设计模式》
关闭。这个问题需要更多focused .它目前不接受答案。 想改善这个问题吗?更新问题,使其仅关注一个问题 editing this post . 4年前关闭。 Improve this questi
.NET 框架:4.5.1 我在 Blend for visual studio 2015 中遇到一个奇怪的错误,我找不到它的来源。 如果我在 VS 中打开我的 WPF 解决方案,它会加载并运行良好。
我经常遇到这样的问题,与 Hierarchical RESTful URL design 非常相似 假设该服务仅提供用户上传文档。 POST, GET /accounts PUT, DELETE /a
在 Rails 应用程序中,我使用 devise 来管理我的用户,而我用来销毁 session 的链接不再有效。它正在工作,现在我添加了事件管理员,但没有。 我的链接是 :delete, :clas
我已经坚持了超过 24 小时,试图按照此处发布的其他解决方案进行操作,但我无法使其正常工作。我是 Rails 新手,需要帮助! 我想让我的/users/edit 页面正常工作,以便我可以简单地更改用户
Devise 在以下情况下不会使用户超时: 用户登录,关闭选项卡,然后在超时 + X 分钟内重新访问该 URL。用户仍处于登录状态。 如果选项卡已打开并且稍后刷新/单击,则超时可以正常工作。这意味着
我想使用这样的 slider 我希望该 slider 根据提供给它的值进行相应调整。到目前为止,我只能应用具有渐变效果的背景,但无法获得这种效果。请通过提供样式代码来帮助我。
您应该为每种方法创建一个请求/响应对象,还是应该为每个服务创建一个? 如果我在所有方法中使用它,我的服务请求对象中将只有 5 个不同的东西,因为我对几乎所有方法使用相同的输入。 响应对象将只有一个字典
我正在尝试在 REST 中对实体的附件进行建模。假设一个缺陷实体可以附加多个附件。每个附件都有描述和一些其他属性(上次修改时间、文件大小...)。附件本身是任何格式的文件(jpeg、doc ...)
我有以下表格: Blogs { BlogName } BlogPosts { BlogName, PostTitle } 博客文章同时建模一个实体和一个关系,根据 6nf(根据第三个宣言)这是无效的。
如果 A 类与 B、C 和 D 类中的每一个都有唯一的交互,那么交互的代码应该在 A 中还是在 B、C 和 D 中? 我正在编写一个小游戏,其中许多对象可以与其他对象进行独特的交互。例如,EMP点击
关于如何记住我与 Omniauth 一起工作似乎有些困惑。 根据这个wiki ,您需要在 OmniauthCallbacksController 中包含以下内容: remember_me(user)
设计问题: 使用 非线程安全 组件(集合,API,...)在/带有 多线程成分 ... 例子 : 组件 1 :多线程套接字服务器谁向消息处理程序发送消息... 组件 2 :非线程安全 消息处理程序 谁
我们目前正在设计一个 RESTful 应用程序。我们决定使用 XML 作为我们的基本表示。 我有以下关于在 XML 中设计/建模应用程序数据的问题。 在 XML 中进行数据建模的方法有哪些?从头开始然
我正在设计一个新的 XSD 来从业务合作伙伴那里获取积分信息。对于每笔交易,合作伙伴必须提供至少一种积分类型的积分值。我有以下几点:
设计支持多个版本的 API 的最佳方法是什么。我如何确保即使我的数据架构发生更改(微小更改),我的 api 的使用者也不会受到影响?任何引用架构、指南都非常有用。 最佳答案 Mark Nottingh
关闭。这个问题是opinion-based 。目前不接受答案。 想要改进这个问题吗?更新问题,以便 editing this post 可以用事实和引文来回答它。 . 已关闭 4 年前。 Improv
我想用 php 创建一个网站,其工作方式与 https://www.bitcoins.lc/ 相同。确实,就每个页面上具有相同布局但内容会随着您更改链接/页面而改变而言,我如何在 php 中使用lay
我有一个关于编写 Swing UI 的问题。如果我想制作一个带有某些选项的软件,例如在第一个框架上,我有三个按钮(新建、选项、退出)。 现在,如果用户单击新按钮,我想将框架中的整个内容更改为其他内容。
我正在尝试找出并学习将应用程序拥有的一堆Docker容器移至Kubernetes的模式和最佳实践。诸如Pod设计,服务,部署之类的东西。例如,我可以创建一个其中包含单个Web和应用程序容器的Pod,但
我是一名优秀的程序员,十分优秀!