java中的工作流要怎样实现_java工作流开发要怎么实现？

大家好，又见面了，我是你们的朋友全栈君。

Java工作流的应用在目前十分广泛，能够熟练的实现工作流也是一种本事，本篇文章就让小编带你了解下其中的实现关键。

我们知道，工作流的实现主要依靠反射机制，想要实现它，首先我们先来创建一张工作流表

创建一张工作流表

如：主键 | 工作流Code | 工作流内容

其中工作流内容为Json格式

工作流内容{

“procCode”: “OPS”

, “procName”: “c端补齐(乘客信息补全)”

, “taskControlVoList”: [

{

“sortNo”: “10”

, “taskCode”: “OPC”

, “taskName”: “检查对应的订单信息是否存在”

, “tasklassName”: “com.xf.flow.service.impl.OrderPeople10ServImpl”

}

, {

“sortNo”: “20”

, “taskCode”: “OPD”

, “taskName”: “乘客数据库落库”

, “tasklassName”: “com.xf.flow.service.impl.OrderPeople20ServImpl”

}

, {

“sortNo”: “90”

, “taskCode”: “RSP”

, “taskName”: “响应消息”

, “tasklassName”: “com.xf.flow.service.impl.ApiResponseServImpl”

}

]

}

aava代码现根据工作流的Code 获取当前的工作流

jsonStr ————>JsonObject————>获取taskControlVoList

java的工作流代码@Override

public ApiResponse deal(String itemNo, Object objVo, String skey, InnerVo innerVo)

{

ApiResponse apiResponse = new ApiResponse();

//查询itemNo获取流程实例

ProcControlVo procControlVo = codeLibraryDao.queryProcConfig(itemNo);

if (procControlVo == null)

{

return new ApiResponse(ResponseCodeEnums.stream_no_exist);

}

List taskControlVoList = procControlVo.getTaskControlVoList();

taskControlVoList.sort((TaskControlVo h1, TaskControlVo h2) – > h1.getSortNo()

.compareTo(h2.getSortNo()));

Iterator itTask = taskControlVoList.iterator();

//初始化内部数据表

String dataNo = taskManagerServ.initData(itemNo, skey, innerVo);

//循环依次执行流程任务

String taskNo = null;

while (itTask.hasNext())

{

TaskControlVo taskControlVo = itTask.next();

String taskClassName = taskControlVo.getTasklassName();

String taskItemNo = taskControlVo.getTaskCode();

String taskName = taskControlVo.getTaskName();

try

{

//初始化任务

taskNo = taskManagerServ.initTask(taskItemNo, dataNo, innerVo);

//执行任务

TaskServ taskServ = (TaskServ) SpringFactory.getBean(Class.forName(taskClassName));

taskServ.init(taskNo, objVo);

TaskAnswerVo taskAnwserVo = taskServ.deal(taskNo, objVo);

//判断任务执行结果

apiResponse = taskAnwserVo.getApiResponse();

if (StringUtils.equals(ResponseCodeEnums.success.getStatus(), apiResponse.getStatus()))

{

//完成任务

logger.info(“==========>>>>> task execute success !!! taskCode={}, taskName={}, status={}, msg={}, nextTask={}”

, taskItemNo, taskName, apiResponse.getStatus(), apiResponse.getMessage(), taskAnwserVo.isNextTask());

taskManagerServ.finTask(taskNo, apiResponse.getMessage());

}

else

{

//异常任务

logger.info(“==========>>>>> task execute error !!! taskCode={}, taskName={}, status={}, msg={}, nextTask={}”

, taskItemNo, taskName, apiResponse.getStatus(), apiResponse.getMessage(), taskAnwserVo.isNextTask());

taskManagerServ.errTask(taskNo, apiResponse.getMessage());

}

//判断流程是否继续

if (!taskAnwserVo.isNextTask())

{

break;

}

}

catch (Exception e)

{

//异常任务

String errorMsg = getStackTrace(e);

taskManagerServ.errTask(taskNo, errorMsg);

logger.error(“==========>>>>> Execute Task Error!!! skey={}, taskControlVo={}, errorMsg={}”, skey, taskControlVo, errorMsg);

//响应异常

return new ApiResponse(ResponseCodeEnums.flow_error);

}

}

if (StringUtils.equals(ResponseCodeEnums.success.getStatus(), apiResponse.getStatus()))

{

//归档完成流程

taskManagerServ.finData(dataNo);

}

return apiResponse;

}

SpringFactory实现类/**

* Created by

*/

@Component

public class SpringFactory implements ApplicationContextAware

{

private static ApplicationContext applicationContext;

@Override

public void setApplicationContext(ApplicationContext applicationContext) throws BeansException

{

if (SpringFactory.applicationContext == null)

{

SpringFactory.applicationContext = applicationContext;

}

}

//获取applicationContext

public static ApplicationContext getApplicationContext()

{

return applicationContext;

}

//通过name获取 Bean.

public static Object getBean(String name)

{

return getApplicationContext()

.getBean(name);

}

//通过class获取Bean.

public static T getBean(Class clazz)

{

return getApplicationContext()

.getBean(clazz);

}

//通过name,以及Clazz返回指定的Bean

public static T getBean(String name, Class clazz)

{

return getApplicationContext()

.getBean(name, clazz);

}

}

以上就是本篇文章的所有内容，需要了解其他java常见问题及解决方法的小伙伴们请持续关注本网站吧。

推荐阅读：

发布者：全栈程序员栈长，转载请注明出处：https://javaforall.cn/156526.html原文链接：https://javaforall.cn