tg-flow简介

tg-flow是一个专注于在线高并发场景的无状态的工作流引擎，它可以在保证高性能的前提下，为在线高并发系统提供复杂的的工作流调度能力，目前tg-flow已经广泛运用于滴滴内部多个日流量数十亿的核心在线系统。 tg-flow包括三个主要模块:

• tg-core: tg-flow的工作流引擎核心模块，提供了对工作流的的调度执行能力。
• tg-web: tg-flow的工作流配置管理前端页面，为用户提供工作流的创建、编辑、保存、删除、导入、导出等功能。
• tg-service：tg-flow的工作流配置管理后台服务，为tg-web的后台API接口，同时也提供工作流配置分发的能力，可将配置分发到redis、zookeeper、文件系统（导出为文件）中。

我们的目标

受限于在线高并发场景的高性能要求，传统工作流引擎很难支持在线高并发系统。 我们的目标是实现一个既能够满足在线高并发场景的性能要求，又具备传统工作流引擎各种复杂功能的工作流引擎。

产品特色

性能特色：

• tg-flow综合使用了多种高效的算法，可以在单机环境下轻松支持100多个串并行节点组成的复杂工作流的调度，除去业务逻辑之外的引擎本身的耗时仅0.1ms左右。

功能特色：

• 适用面广：可适用于所有在线高并发场景，典型的如搜索引擎、广告引擎、推荐引擎等。目前已经在滴滴内部多个日流量数十亿的核心在线系统中使用。
• 功能强大：
  1. 支持不限层次嵌套的串、并行混合的工作流。
  2. 支持条件分支，支持多（N>2）条件枚举分支，支持分支节点中带动态（工作流执行过程中动态赋值的）参数。
  3. 支持不限层级的父子工作流嵌套。
  4. 支持对工作流内部节点和分支进行各种超时控制，如：节点内部超时控制、节点间的超时控制、子工作流节点的超时控制，支持节点超时回调。
  5. 提供基于工作流引擎的在线问题诊断能力，可以通过在用户界面点击工作流节点显示节点中间输出结果。
• 集成灵活：
  1. 如果只想使用tg-flow的调度功能，这种情况下只需要自己按工作流DSL语法完成工作流配置文件的编写，然后放入自己在线系统的目录中，在线系统进行工作流引擎初始化时加载上述配置文件即可。
  2. 进一步地，如果你想使用tg-flow的工作流配置管理功能，可以照着用户手册搭建web服务，在web界面上以拖拽方式构建工作流，然后在系统管理页导出工作流配置文件压缩包，解压后放入自己的在线系统的目录中。
  3. 再进一步，如果需要使用tg-flow所有功能，可以在第二步的基础上，自行部署redis或zookeeper，然后在线系统中可以使用tg-core中的核心模块定期从redis或zookeeper中检测工作流新版本，并及时更新到在线系统。

用户手册

参见： user_manual

欢迎加入

请联系：张云锋, 周子纯， 唐桂尧