零代码平台中的服务编排思路

先打个广告,我们的第三场零代码实践的直播在本周五( 11 月 5 日 )晚8点准时开始,扫描下面二维码,直接预约直播,到时间微信会自动提醒。

2013d546c53e2865c8d37c43967916a3.png


随着企业数字化转型的进程加快,零代码平台的的应用越来越广泛,逐渐被企业级的客户认可和接受。

零代码顾名思义就是在不写代码的情况下可以搭建应用和功能来满足客户的需求,但事实是残酷的,真实的客户需求永远比我们想象的要复杂,传统的零代码产品需要提供各种扩展能力,比如可以让开发人员编写复杂的业务逻辑代码,并对接到平台中。

这样虽然能够满足需求,但会有两个问题:

1、客户的需求随时可能发生变化,需求一变就需要进行代码的修改;

2、一线业务人员无法直接在平台中进行调整,一些小的改动都需要进行开发、测试、发布的流程。

这时就需要服务编排了,服务编排是什么,下面举两个例子:

1、仓储物流出库先进先出更新库存量

在仓储物流系统中,商品的入库有时间的先后顺序,出库时需要遵循先入库的先进行出库,如下图所示:

30fccaf06a8a18eabc872205ac48f4de.png

在不具备服务编排的系统中,搭建好功能后,还需要编写处理出库逻辑的 API 接口方法和系统中的某个方法对接起来。这个工作只能由开发人员来完成。

使用服务器编排工具,就能轻松地可视化拖拽就能实现了,如下图:

5a72d52a00392012700061d1ef73bfa7.png

2、人员离职后需要处理一系列的操作,比如:

  • 修改 HR 系统中对应用户的状态;

  • 删除企业微信中的账号;

  • 禁用邮箱;

  • 发送通知。

使用服务编排可以很轻松就能实现,前提是要有丰富的业务组件:

671c3b36c22452b83d2f1c2134f3b19d.png

服务编排其实就是一系列单个的业务组件通过流程的方式进行组合起来,最终达到业务的目的,流程中可以控制分支逻辑或循环逻辑。

提到流程,我们印象里都是 OA、CRM 等系统中的各种请假审批流、合同审批流等。事实上,广义上的工作流是对工作流程及其各操作步骤之间业务规则的抽象、概括、描述。

简单的说,为了实现某个业务目标,抽象拆解出来的一系列步骤及这些步骤之间的协作关系,就是工作流。也就是上面所说的业务服务的编排流程。

服务编排引擎的总体架构图如下: 

1865dacbfef3b64c5aaca0e1f6dcd802.png

在近些年比较火的微服务中也存在着服务的编排,常见的有三种模式:

  • Orchestration(编制):通过一个可执行的流程来协同内部及外部的服务交互,通过流程来控制总体的目标、涉及的操作、服务调用顺序。这种模式必须有一个流程控制服务,用来接收请求,组织服务间的调用,并最终完成业务逻辑。这种方案中大多是同步调用,虽然在某个时刻能够很清晰的知道服务的执行情况,但当业务复杂,服务很多的情况下,在控制服务中会存在大量的耦合,难以维护;

  • Choreography(编排):通过消息的交互序列来控制各个部分资源的交互,参与交互的资源都是对等的,没有集中的控制。可以看作一种消息驱动模式,或者说是订阅发布模式,不同的服务之间通过消息机制串联起来,这种方式大多都是异步的。好处就是耦合度低,但也会带来一些问题,比如:业务流程是通过订阅的方式来体现的,很难直接监控每笔业务的处理,因此难于调试;由于没有预定义流程,所以很难在事前保证流程正确性,基本靠事后分析数据来判断等;

  • API网关:API网关是一种简单的接口聚合/拆分的方式:业务组件的请求后先到达网关,网关调用各微服务,并最终聚合/拆分需反馈的结果。API网关其实就是一个适配网关,比如对于 Web端,可以一个页面同时发起几十个请求,而对于移动端,最好是一个页面就几个请求。而采用API 网关,后面的微服务可以是相同的。但只能应对一些逻辑简单的场景。

结合上面方式各自的优点,服务编排引擎的实现思路如下:

1、一个服务的编排由一个或多个业务服务组件组成;

2、一个业务服务组件可以拆解为一个或多个原子服务;

3、每个原子服务可以抽象成一个通用模型;

4、每个原子服务提供 API 接口和事件监听机制;

5、每个原子服务根据持久化适配器将数据更新到订阅的持久化组件中。

整体过程如下图:

5df1b6e6d270b117aa6e8c4cab4ae666.png

服务组件的调用是同步还异步,我们把这个决定权交给用户,可以通过设置的方式来进行,并提供重试机制,确保数据的最终一致性。

182c31cb0c188ce8f8bde019b0c2d741.png

每个服务组件都有自己的入参和出参,在一个服务编排的请求上下文中会随着执行的阶段不同,动态组织参数,参数适配器会根据名称、类型等进行自动适配,当然也能根据在设置界面中的手动绑定进行适配。

原子服务只做一件事情,通过一个原子服务或多个原子服务,可以组装出来各种不同功能的业务组件,通过事件监听机制让服务之间、组件之间可以彻底解耦,以便能够灵活组装。

随着服务和组件的增多,调用链会变得越来越复杂,当一个服务编排整个处理完后,调用链会形成一个复杂网络,这对排查问题造成很大的麻烦。我们采用全链路跟踪来解决这个问题,在一个完整的业务调用开始时,会生成一个唯一 ID,这个 ID 会一直存储在调用上下文中。

上面说到原子服务会有两种方式被执行,API 和事件监听的方式,如果是 API ,ID 可以放在请求头中传递到下一层,如果是事件监听,ID 会做为消息体的一部分进行传递。

假设现在用户已编排了一个复杂的业务,服务组件之间的调用有同步也有异步,当某个环节出现问题时候,我们需要保证数据的最终一致性。常用的一种方式就是提供补偿机制。

补偿模式核心思想是:针对每个操作,都要注册一个与其对应的补偿(撤销)操作,一般来说操作本身和其补偿操作会在一个事务里完成,当其后续操作失败后,需要按相反顺序完成前面注册的所有撤销操作。

我们的补偿机制分为两种:

1、特定服务组件上的独立设置;

2、全局控制调用补偿,所有被调用服务会记录到一个列表中,如果出现需要重试或者回滚的操作,再从列表中获取出来进行相应的操作。

在补偿模式中,要求能够提供补偿的服务的操作必须支持幂等,否则当多次执行的时候就会出现数据错误。正常情况下,所有的补偿都是自动触发的,但有些特殊的场景还是需要人工干预,在调用失败的日志列表中管理员可以进行手动重试。

如果您有什么意见或建议,欢迎私信我。


本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/296068.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

webservice发布

一朋友问我webservice怎么发布在iis上。我之前也不知道,今天自己亲自试了一把竟然发布成功了。现在这个分享给大家。希望给大家带来一点点方便。 其实和发布普通网站一样,在iis上选择 默认网站--->新建虚拟目录--->取别名(随便取&#…

自己平时长期积累的java资料可供大家学习

java 中数据转换 1、如何将字符串String转化为整数int int i Integer.parseInt(str); int i Integer.valueOf(my_str).intValue(); 注: 字串转成Double, Float, Long的方法大同小异。 2、如何将字符串String转化为Integer Integer integerInteger.valueOf(i) 3、…

日本原装进口雪平锅,1台顶4台,有它谁还点外卖?

▲ 点击查看小爆我虽然热爱烹饪,但不得不说「下厨房」,也是个坑。光是锅,我就要买好几个。为了蒸包子馒头买蒸锅,为了炒菜买炒锅,偶尔想精致喝热牛奶又买了小奶锅,为了煲汤、做点卤味解解馋,买炖…

NSPredicate 谓词

比较运算符/**比较运算符 * >:大于 * <:小于 * >:大于等于 * <:小于等于 * ,:等于 * !,<>:不等于 * between:左边的表达式等于右边的表达式的值或者介于它们之间。右边是一个有两个指定上限和下限的数值的数…

如何评价一个开源项目——价值流网络

本文由X-lab开放实验室博士生赵生宇原创出品该篇博客继续之前关于活跃度和协作影响力的介绍继续展开&#xff0c;希望可以在解决协作影响力无法容纳更多数据&#xff0c;从而可以更全面衡量开源生态的同时&#xff0c;也引入一种高可扩展的数学模型&#xff0c;可以在任意时间快…

linux7为nginx添加服务,CentOS7添加Nginx为系统服务

1.编辑系统服务vim /usr/lib/systemd/system/nginx.service[unit]DescriptionWeb ServiceAfternetwork.target[Service]PIDFile/var/run/nginx.pidExecStart/usr/local/nginx/sbin/nginxExecStop/usr/local/nginx/sbin/nginx -s stopExecReload/usr/local/nginx/sbin/nginx -s …

Linux内核升级,从2.6.18升级到3.2.14

今日在centos上安装jsp环境&#xff0c;即&#xff08;Nginxjdkmysqltomcat&#xff09;发现nginx启动后无法访问&#xff0c;于是查看日志&#xff0c;log如下 [rootAY12122501352213a7156 ~]# cat /var/log/nginx/error.log 2013/01/12 16:29:43 [emerg] 32055#0: eventfd() …

【翻译】C#编程语言和JAVA编程语言的比较(下)

原文地址&#xff1a;http://www.25hoursaday.com/CsharpVsJava.html 6、集合 许多有名的编程语言都会包含一个集合框架&#xff0c;框架一般由各种用于保存数据的数据结构和配套的操作对象的算法构成。集合框架的优势是让开发者可以不用写数据结构和排序算法&#xff0c;把精力…

数据库平时错误和使用经验的总结

jdbc里面的操作 jdbc&#xff0c;使用PreparedStatement view sourceprint?001 package com.iflytek.test; 002 003 import java.sql.Connection; 004 import java.sql.DriverManager; 005 import java.sql.PreparedStatement; 006 import java.sql.ResultSet; …

Haproxy 让后端RS记录真实IP

#让RS记录客户端的真实IP#1.先在haproxy.cfg中加入下面参数。listen www ... option forwardfor #如果后端服务器需要获得客户端真实ip需要配置的参数&#xff0c;必须要放在listen模块下#2.如果是apache&#xff0c;则加入下面参数LogFormat “\”%{X-Forward…

物理太难?这些虚拟动图,让你看懂物理

全世界只有3.14 % 的人关注了爆炸吧知识&#xff08;刻度尺的使用&#xff09;&#xff08;测量平均速度实验&#xff09;&#xff08;声音的产生&#xff09;&#xff08;温度计的使用&#xff09;&#xff08;晶体和非晶体的熔化&#xff09;&#xff08;光的反射&#xff09…

linux http 分析工具,技术|httpstat:一个检查网站性能的 curl 统计分析工具

httpstat 是一个 Python 脚本&#xff0c;它以美妙妥善的方式反映了 curl 统计分析&#xff0c;它是一个单一脚本&#xff0c;兼容 Python 3 &#xff0c;在用户的系统上不需要安装额外的软件(依赖)。从本质上来说它是一个 cURL 工具的封装&#xff0c;意味着你可以在 URL 后使…

微软 Ignite 大会 PowerBI 划重点

2021 年 11 月 2 日&#xff0c;微软举办 Ignite 大会&#xff0c;其中关于 Power BI 有哪些重点&#xff0c;带给你了解。摘要Power BI 和 Power Point 将原生整合。Power BI 和 Teams 将更深入整合。Power BI 云端数据集推出自动聚合。Power BI 数据模型推出混合表。Power BI…

周报_2013第03周(2013/01/13-2013/01/19)

2013.01.14 Winform .Net FrameWork 3.5 支持 Client Application Service&#xff08;ASP.NET service: login authentication、roles、profile settings&#xff09;&#xff0c;.Net FrameWork 4.0 不支持。转载于:https://www.cnblogs.com/DancingFish/archive/2013/01/14/…

java序列化的机制和原理

Java序列化的机制和原理有关Java对象的序列化和反序列化也算是Java基础的一部分&#xff0c;下面对Java序列化的机制和原理进行一些介绍。Java序列化算法透析 Serialization&#xff08;序列化&#xff09;是一种将对象以一连串的字节描述的过程&#xff1b;反序列化deserializ…

DirectSound 混音的实现

啥叫混音呢&#xff0c;其实很简单&#xff0c;如果两个人同时说话 &#xff0c;他们俩发出的声波在空气中进行了波的叠加&#xff0c;这其实就是个混音。计算机的混音&#xff0c;其实是一个虚拟的混音操作&#xff0c;因为计算机其实是只有一个声源&#xff08;现在的计算机通…

Codeforces Round #330 (Div. 2) B. Pasha and Phone 容斥定理

B. Pasha and Phone Time Limit: 20 Sec Memory Limit: 256 MB 题目连接 http://codeforces.com/contest/595/problem/B Description Pasha has recently bought a new phone jPager and started adding his friends phone numbers there. Each phone number consists of exact…

美女晕倒怎么办?二哈:这不是一滋就醒......

1 永远不要质疑二哈▼2 睡觉也不耽误练功▼3 谁还没为数学考试受过伤呢&#xff1f;▼4 可能我的嘴巴安装了笑话过滤器吧▼5 我书读得少&#xff0c;你别吓唬我▼6 希望狗没事儿▼7 海王的微信壁纸事实证明&#xff0c;会计确实不赚钱▼你点的每个赞&#xff0c;我都认真…

linux at java,Linux-Tutorial/Java-bin.md at master · linsanityHuang/Linux-Tutorial · GitHub

Java bin 目录下的工具JVM 内存结构运行时数据区(JVM 规范)VM 栈(JVM 虚拟机栈)是线程私有的&#xff0c;它的生命周期和线程相同。它描述的是 Java 方法执行的内存模式。Java 堆区(Heap)是 Java 虚拟机所管理的内存中最大的一块。是被所有线程共享的一块内存区域&#xff0c;在…

如何在 C# 中使用 FTP 上传文件

咨询区 webvision&#xff1a;我尝试用 C# 上传一个文件到 FTP-Server 上&#xff0c;文件已显示上传成功但显示 0Byte&#xff0c;我的代码大概是这样的。private void button2_Click(object sender, EventArgs e) {var dirPath "C:/Documents and Settings/sander.GD/B…