备案控制台
开发者社区 金融级分布式架构 文章 正文

基于 SOFAArk 和 SOFADashboard 实现动态模块管控 | Meetup#2 回顾

2019-05-30 1127
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
本文涉及的产品
服务治理 MSE Sentinel/OpenSergo，Agent数量 不受限
简介： 本文根据 5月26日 SOFA Meetup#2上海站 《使用 SOFAStack 快速构建微服务》主题分享整理，着重分享如何使用 SOFADashboard 来管控 SOFAArk ，对于 SOFAArk 中的一些基础概念和知识不过多涉及；建议大家在阅读之前，先了解下 SOFAArk 的相关基本知识。

作者：卫恒（宋国磊），SOFATracer 以及 SOFADashboard 开源负责人。

本文根据 5月26日 SOFA Meetup#2上海站 《使用 SOFAStack 快速构建微服务》主题分享整理，着重分享如何使用 SOFADashboard 来管控 SOFAArk ，对于 SOFAArk 中的一些基础概念和知识不过多涉及；建议大家在阅读之前，先了解下 SOFAArk 的相关基本知识。

现场回顾视频以及 PPT 见文末链接。

46.jpg

前言

SOFAArk 是一款基于 Java 实现的轻量级类隔离容器，主要提供类隔离和应用（模块）合并部署能力，由蚂蚁金服开源贡献。SOFAArk 在 0.6.0 版本 提供了非常丰富的功能特性，其中最核心的当属多应用（模块）合并部署这个能力。SOFAArk 本身提供了多种方式来支持多应用（模块）合并部署 ，包括基于命令行的管控，基于 API 的管控等。本篇将结合 SOFA 开源的管控端组件 SOFADashboard，来实现 SOFAArk 提供的合并部署和动态模块推送的功能。

案例工程地址：https://github.com/sofastack-guides/sofa-dashbaord-samples-parent

背景

复杂项目通常需要跨团队协作开发，各自负责不同的组件，而众所周知，协调跨团队合作开发会遇到不少问题；比如各自技术栈不统一导致的依赖冲突，又比如往同一个 Git 仓库提交代码常常导致 merge 冲突。因此，如果能让每个团队将负责的功能组件当成一个个单独的应用开发，运行时合并部署，通过统一的编程界面交互，那么将极大的提升开发效率及应用可扩展性。SOFAArk 提出了一种特殊的包结构 -- Ark Biz，用户可以使用 Maven 插件将应用打包成 Biz，允许多 Biz 在 SOFAArk 容器之上合并部署，并通过统一的编程界面交互。

image.png

案例模型

本篇所演示案例是上图的一个简化版，从整体上可以体现 SOFAArk多应用合并部署的能力。主要包括已经几个工程：

  • sofa-dashboard-ark-hostapp : 宿主应用
  • sofa-dashboard-ark-facade   : 提供接口 API
  • sofa-dashboard-ark-provider ：提供接口 API 的具体实现，将发布一个 JVM 服务

sofa-dashboard-ark-hostapp 和 sofa-dashboard-ark-provider 均作为 SOFAArk 中的 ark-biz 存在；sofa-dashboard-ark-hostapp 作为宿主应用对外提供服务。
image.png

上图的模型中，在宿主应用不重启的情况下，实现  provider 模块的动态替换，从而实现版本升级。

在宿主应用启动时，provider 1.0.0 以静态合并部署方式“寄宿”到宿主应用中，这部分实际上与 SOFADashboard 管控是没有什么关系的，为了案例效果，在下面的案例中，关于静态合并部署的操作也会涉及到。

最终的工程结构图如下：

image.png

环境准备

本文需要启动 SOFADashboard 服务端，具体请参考 : Quick Start ；其他基础设施环境如 Zookeeper 、Mysql 等需提前准备。

工程构建

本篇将通过 step by step 的方式来构建整个工程，为大家在实际的应用过程中提供一种简单的思路，同时也帮助大家更好的理解 SOFAArk 中的一些点。

sofa-dashboard-ark-facade

基础 API 提供模块，不需要依赖任何其他二方或者三方 JAR，这里仅提供一个接口。

public interface SofaJvmService {
    String test();
}

sofa-dashboard-ark-provider

这个模块是 JVM 服务的提供方，也是后面需要在宿主应用中进行替换演示的模块包，这个模块本身也是一个 Web 应用。这里就来一步步分解下，如何将一个普通的 SpringBoot 工程改造成一个 ark-biz 工程。

1、新建一个 SpringBoot 工程

新建 SpringBoot 工程推荐的方式有两种，一种是在 https://start.spring.io/  进行下载，另外一种是基于 IDEA 的 Spring 插件来生成；此处不在过多描述过程。

2、工程基本能力实现

  • 引入 sofa-dashboard-ark-facade 依赖，先将需要提供的 JVM 服务实现：
@SofaService
@Service
public class SofaJvmServiceImpl implements SofaJvmService {
    @Override
    public String test() {
        return "first version biz";
    }
}

NOTE: SofaService 的作用是将一个 Bean 发布成一个 JVM 服务， 所以这里需要加上 Spring 提供的 @Service 注解将 SofaJvmServiceImpl 标注为一个 Bean。

  • 配置文件：
spring.application.name=biz-ark-test
server.port=8800
logging.path=./logs

3、配置打包插件，将应用打包成 ark-biz

根据官方文档，可以使用 sofa-ark-maven-plugin 插件将一个普通的工程打包成一个 ark biz 包。这里直接给出本篇中工程的配置：

 <plugin>
   <groupId>com.alipay.sofa</groupId>
   <artifactId>sofa-ark-maven-plugin</artifactId>
   <version>0.6.0</version>
   <executions>
     <execution>
       <!--goal executed to generate executable-ark-jar -->
       <goals>
         <goal>repackage</goal>
       </goals>
             <!--ark-biz 包的打包配置  -->
       <configuration>
         <!--是否打包、安装和发布 ark biz，详细参考 Ark Biz 文档，默认为false-->
         <attach>true</attach>
         <!--ark 包和 ark biz 的打包存放目录，默认为工程 build 目录-->
         <outputDirectory>target</outputDirectory>
         <!--default none-->
         <arkClassifier>executable-ark</arkClassifier>
         <!-- ark-biz 包的启动优先级，值越小，优先级越高-->
         <priority>200</priority>
         <!--设置应用的根目录，用于读取 ${base.dir}/conf/ark/bootstrap.application 配置文件，默认为 ${project.basedir}-->
         <baseDir>../</baseDir>
       </configuration>
     </execution>
   </executions>
</plugin>

4、工程依赖

从前面背景介绍中的设计理念图中可以看出，动态合并部署需要依赖的插件核心有两个，一个是 runtime plugin，一个是 config plugin（没有涉及到 RPC 服务相关）；由于 provider 并不是作为宿主应用，其本身不需要具备动态配置的能力，因此这里仅需要引入 runtime plugin 来为当前 ark-biz 工程提供运行时环境即可。

<!-- runtime plugin -->
<dependency>
         <groupId>com.alipay.sofa</groupId>
         <artifactId>runtime-sofa-boot-plugin</artifactId>
</dependency>

<!-- 其他依赖 -->
<dependency>
      <groupId>com.alipay.sofa</groupId>
      <artifactId>healthcheck-sofa-boot-starter</artifactId>
</dependency>

<dependency>
         <groupId>com.glmapper.bridge.boot</groupId>
         <artifactId>sofa-dashboard-ark-facade</artifactId>
</dependency>

5、编译打包

执行 mvn clean package ，之后会在当前模块的 target 目录下生成 xxx-ark-biz.jar 的包。

image.png

sofa-dashboard-ark-host

前面已经构建好了所需要的一些基础工程，sofa-dashboard-ark-host 作为宿主应用，期望其具备的能力有以下几个：

  • 提供可以直观的 check 模块变更后的结果
  • 提供能够给 provider 1.0.0 版本 ark-biz 包运行的宿主环境
  • 能够通过 SOFAArk 提供的状态 endpoint 查看插件状态
  • 能够支持 Zookeeper 下发指令，控制 Biz 的生命周期

基于以上几点功能，下面来分步骤实现。

1、提供一个简单的 Rest 接口来 check 结果

sofa-dashboard-ark-host 本身也是一个 Web 应用，所以在这个提供一个 Rest 接口，具体实现是通过@SofaReference 调用 provider ark-biz 包中发布的 JVM 服务。

@RestController
public class TestController {

    @SofaReference
    SofaJvmService sofaJvmService;

    @RequestMapping("test")
    public String test(){
        return sofaJvmService.test();
    }
}

2、作为宿主应用

  • ARK 容器配置

这部分可以先参考阅读 SOFAArk 配置。本案例中简单配置了一份 ARK 容器的配置文件。

# log 日志目录
logging.path=./logs
# 指定zookeeper 服务地址
com.alipay.sofa.ark.config.address=zookeeper://localhost:2181
# 指定宿主应用名
com.alipay.sofa.ark.master.biz=host-app

com.alipay.sofa.ark.master.biz 默认情况下是宿主应用的 artifactId。如果这里指定了名字，则在宿主应用的插件配置里面需要使用此名字。

  • 依赖引入

引入 sofa-ark-springboot-starter 、web-ark-plugin 以及 provider ark biz 包。

<!-- 引用ark starter-->
<dependency>
    <groupId>com.alipay.sofa</groupId>
    <artifactId>sofa-ark-springboot-starter</artifactId>
</dependency>
<!-- 引用ark web插件-->
<dependency>
    <groupId>com.alipay.sofa</groupId>
    <artifactId>web-ark-plugin</artifactId>
</dependency>
<!-- 引入 sofa-dashboard-ark-provider ark-biz ，这里属于静态合并部署情况-->
<dependency>
    <groupId>com.glmapper.bridge.boot</groupId>
    <artifactId>sofa-dashboard-ark-provider</artifactId>
    <version>1.0.0</version>
    <classifier>ark-biz</classifier>
</dependency>
  • 插件配置
<plugin>
  <groupId>com.alipay.sofa</groupId>
  <artifactId>sofa-ark-maven-plugin</artifactId>
  <version>0.6.0</version>
  <executions>
    <execution>
      <id>default-cli</id>
      <goals>
          <goal>repackage</goal>
      </goals>
    </execution>
  </executions>
  <configuration>
    <!--指定优先级-->
    <priority>100</priority>
    <!--指定baseDir-->
    <baseDir>../</baseDir>
    <!--bizName,这里需要和 bootstrap 中指定的master.biz 配置保持一致，默认为 artifactId-->
    <bizName>host-app</bizName>
  </configuration>
</plugin>

3、状态查看

SOFAArk 提供了 /bizState 这样一个 endpoint 用来获取当前插件的版本及状态信息。这里就在宿主应用中引入actuator 依赖并进行相关配置。

 <!-- 引用 actuator -->
 <dependency>
         <groupId>org.springframework.boot</groupId>
         <artifactId>spring-boot-starter-actuator</artifactId>
 </dependency>

application.properties 中配置暴露所有端点。

management.endpoints.web.exposure.include=*

4、提供动态配置插件能力

SOFAArk 提供了 config-ark-plugin 对接 Zookeeper 配置中心，用于运行时接受配置，达到控制 Biz 生命周期，引入如下依赖：

<!-- 引用ark 配置推送扩展插件-->
<dependency>
        <groupId>com.alipay.sofa</groupId>
        <artifactId>config-ark-plugin</artifactId>
</dependency>

参考 SOFAArk 配置，在 SOFAArk 配置文件 conf/ark/bootstrap.properties 增加如下配置：

com.alipay.sofa.ark.config.address=zookeeper://localhost:2181

静态合并部署演示

基于上述所有的配置，将 host-app 打包，然后运行。

  • mvn clean install 
  • java -jar sofa-dashboard-ark-hostapp-1.0.0.jar

下面可以通过 SOFAArk 提供的 endpoint 来查看下当前应用的 biz state 信息：

image.png

这里只有宿主应用自身的 ark biz 状态信息，实际上我们使用了静态合并部署。但是貌似 ark-biz 合并部署的包插件没有在 bizState 中体现出来。访问下 http://localhost:8085/test 我们的 check  rest 服务：

image.png

提示出来没有可用的 JVM 服务。

这里有个点是并不会去激活里面的 ark biz 包，需要通过通过 终端或者 API 的方式来进行激活，实际上只是激活了宿主应用本身的 ark-biz。

通过 SOFADashboard 进行动态推送

SOFADashboard 进行推送的原理可以参考前面背景介绍中的描述。下面主要来介绍如何使用 SOFADashboard 进行动态模块切换。

注册插件

将 sofa-dashboard-ark-provider 这个 ark-biz 插件注册到 SOFADashboard：

image.png

填写插件的基本信息：

image.png

注册成功之后，模块列表如下：

image.png

增加版本

点击添加版本，弹出新增版本表单，输入版本信息及当前版本对应的 ark biz 包文件地址；支持从文件服务器（http 协议）上拉取，也支持从本地文件（File 协议）系统获取。下面为了方便，使用从文件系统中获取，配置如下：

image.png

添加成功之后，插件列表如下：

image.png

关联应用

image.png

点击插件列表后面的 关联应用案例，将插件与应用进行关联，如下：

image.png

详情查看

点击插件列表后面的详情按钮，可以查看当前插件下所有应用信息和应用实例信息。

image.png

命令推送

SOFADashboard 提供两种维度的命令推送：

  • 基于应用维度，当前应用所有的实例都会监听到此命令变更；
  • 基于 IP 维度，分组维度的单 IP 场景。

下面演示基于 IP 维度的推送：

1、安装

点击安装，安装过程中，插件状态会发生变化， RESOLVED 状态为正在解析。

image.png

延迟 1~3s 之后，状态变为  ACTIVATED 状态:

image.png

再次访问下 http://localhost:8085/test 我们的 check rest 服务：

image.png

实现了在不重启宿主应用的情况下，实现了内部业务逻辑的变更。

2、版本切换

模块版本 1 运行一段时间之后，出现新的需求，希望更改下模块版本 1 中的一些逻辑。在未使用动态模块的情况下，一般就需要新拉一个迭代，然后将原有的逻辑修改，然后发布上线。可能是一个非常小的功能点，但是却需要走复杂的发布流程。

这个就可以借助动态模块的方式来实现版本的动态切换。修改 sofa-dashboard-ark-provider  模块逻辑实现，升级版本，重新打包 sofa-dashboard-ark-provider 。

在 SOFADashboard ，新增 2.0.0 版本，并且配置指定的版本 ark-biz 包的文件地址。添加成功之后如下：

image.png

进入详情界面，切换版本到 2.0.0：

image.png

执行安装，此时版本 2.0.0 状态将会变为非激活状态：

image.png

执行点击激活按钮进行激活，延迟 1~3s 之后，状态变更为激活状态：

image.png

再次访问下 http://localhost:8085/test 我们的 check  rest 服务：

image.png

可以看到，版本 2.0.0 中的逻辑已经生效了；切回到 1.0.0 ，此时 1.0.0 的状态变成了非激活状态：

image.png

小结

本文分享了基于 SOFAArk 和 SOFADashboard 实现动态模块管控的能力。动态模块在实际业务中有非常丰富的场景，对主应用不发版，不重启的情况下实现具体模块的功能变更；在此基础上也可以实现版本灰度的能力。

本案例中，provider 也是一个独立的应用，其作为一个子模块在宿主应用 hostapp 中启动，因此也可以基于 SOFABoot 这种能力来实现多 Web 应用的合并部署的能力。

以上就是本次分享的全部内容。

SOFA Meetup 上海站回顾资料

现场回顾视频以及 PPT 地址：http://t.cn/AiKlmCmE

文章标签：
微服务引擎
相关实践学习
基于MSE实现微服务的全链路灰度
通过本场景的实验操作，您将了解并实现在线业务的微服务全链路灰度能力。
s潘潘
目录
相关文章
瓴羊Dataphin
|
2天前
|
数据采集 运维 Java
有了 Dataphin v4.0，跨系统调度依赖再也不是难题
Dataphin v4.0引入了新的触发式节点，用于解决多数据平台间的调度问题。当上游系统（如Unix的crontab）完成数据采集后，可通过触发式节点通知Dataphin开始拉取数据，避免传统轮询方式的效率低和资源占用。触发式节点需满足Dataphin OpenAPI开通和网络连通条件，并通过SDK进行外部触发。示例展示了如何创建和使用触发式节点，以及使用Java SDK模拟触发请求。
瓴羊Dataphin
61 0
羿莉（萧羿）
|
7月前
|
运维 安全 API
统一接入API赋能开发者：自动高效、灵活编排的云产品日志采集方案
随着企业对网络安全和数据安全防护水平要求的逐步提升，企业管理对企业生产运维过程中所产生的日志数据，在留存处理、权限隔离、跨境合规、数据汇总等方面提出了更高阶的需求。为了满足大客户及一些国际化客户安全合规、简单快速地接入日志、使用日志、操作日志，我们提出了一种新的解决方案——“云产品统一接入API”。统一接入API主要针对阿里云云产品日志类型，以API的方式提供企业或组织用户快速上手，编排灵活的日志采集方案。
羿莉（萧羿）
1360 0
瓴羊Dataphin
|
2天前
|
数据采集 运维 监控
DataphinV4.0来啦：自定义全局角色 ，实时研发覆盖全部署场景，个性化企业配置看本期
本次V4.0版本升级，Dataphin支持自定义全局角色、自定义逻辑表命名规范、Flink on K8s的部署模式，提升企业级适配能力，灵活匹配企业特色；将集成任务快速从组件模式切换为脚本模式、支持外部触发类型节点等，提升研发平台易用性，助力高效开发便捷运维。
瓴羊Dataphin
91038 1
阿甘兄
|
7月前
|
SQL JSON JavaScript
16分布式电商项目 - 模板管理功能（一）
16分布式电商项目 - 模板管理功能（一）
阿甘兄
52 0
阿甘兄
|
7月前
|
JSON 数据库 数据格式
17分布式电商项目 - 模板管理功能（二）
17分布式电商项目 - 模板管理功能（二）
阿甘兄
41 0
码农小凡
|
7月前
|
BI Sentinel
最新发布！阿里巴巴内部实战AlibabaSentinel高并发流量治理手册
为什么要使用Sentinel？ Sentinel使用简单、配置灵活，可将Sentinel的动态数据源接口与配置中心结合使用，动态地改变流量规则。Sentinel提供的流量控制功能有限流、熔断、系统自适应、授权等。笔者当时使用了熔断和系统自适应功能应对突增流量导致服务雪崩的问题，同时使用限流功能并结合信号量隔离、匀速限流效果控制器，应对内部定时任务瞬时高并发调用某服务接口的问题。
码农小凡
65 0
最新发布！阿里巴巴内部实战AlibabaSentinel高并发流量治理手册
瓴羊Dataphin
|
10月前
|
SQL JSON 运维
数据服务最佳实践（1）：支持注册外部API，打造企业数据服务中心【Dataphin V3.11】
在DataphinV3.11版本中，我们支持了注册外部API的能力，用于支持客户统一管理企业所有的API，打造企业的数据服务中心。API注册到Dataphin之后，可以由Dataphin统一纳管，和其他方式创建的API共用相同的服务市场、权限管控、运维监控能力。 同时我们支持了Json文本解析能力，支持编写类似正则表达式的语法定义注册API返回参数的取值路径，满足企业自定义取数的场景。
瓴羊Dataphin
681 0
开发V|TG_ch3nguang
|
10月前
|
数据挖掘 API
（跨品种/跨市场）套利策略API对接开发源码规则解析
（跨品种/跨市场）套利策略API对接开发源码规则解析
开发V|TG_ch3nguang
131 0
源码星辰
|
12月前
|
JavaScript 前端开发 Java
云HIS住院业务模块常见问题及解决方案
系统技术特点：采用前后端分离架构，前端由Angular语言、JavaScript开发；后端使用Java语言开发。 系统遵循服务化、模块化原则开发，具有强大的可扩展性，二次开发方便快捷。 全套开发文档和产品文档，助力快速熟悉和掌握源码，提供售后服务。
源码星辰
127 0
泮圣伟（十眠）
|
2天前
|
Java 测试技术 Nacos
一站式动态多环境建设案例
本文介绍了致景科技使用MSE全链路灰度的最佳实践。
泮圣伟（十眠）
42 0
一站式动态多环境建设案例

金融级分布式架构

热门文章

最新文章

  • 1
    MySQL数据库重命名的方法
  • 2
    CVE-2017-9805:Struts2 REST插件远程执行命令漏洞(S2-052) 分析报告
  • 3
    阿里云播放器SDK的正确打开方式 | 功能、架构与应用（一）
  • 4
    流言终结者- Flutter和RN谁才是更好的跨端开发方案？
  • 5
    Linux 多核下绑定硬件中断到不同 CPU（IRQ Affinity）
  • 6
    PostgreSQL 聚合函数讲解 - 3 总体|样本 方差, 标准方差
  • 7
    利用Serverless Kubernetes和Kaniko快速自动化构建容器镜像
  • 8
    袋鼠云数据中台专栏（五）：数栈，企业级一站式数据中台PaaS
  • 9
    企业微信开发（二）：API对接及Demo程序
  • 10
    一篇文章深入浅出带你了解mybatis
  • 1
    如果使用已经到达 End of life 的 Angular 版本会遇到什么问题
    21
  • 2
    印刷文字识别产品使用合集之部署失败如何解决
    23
  • 3
    印刷文字识别产品使用合集之API接口无法调用如何解决
    24
  • 4
    什么是计算机图形领域的 color saturation
    26
  • 5
    mvp架构
    22
  • 6
    dex、vdex、.odex与.oat
    26
  • 7
    java调用kotlin代码编译报错“找不到符号”的问题
    16
  • 8
    印刷文字识别产品使用合集之身份证识别接口有哪些
    20
  • 9
    Build was configured to prefer settings repositories over project repositories but repository
    16
  • 10
    Java注解之编译时注解
    16

    • 相关课程

    更多
  • 大数据分析之企业级网站流量运营分析系统开发实战（第二阶段）
  • 应用编排与管理核心原理
  • 大数据分析之企业级网站流量运营分析系统开发实战（第四阶段）
  • 业务全链路追踪最佳实践
  • 大数据分析之企业级网站流量运营分析系统开发实战（第三阶段）
  • 可观测能力升级系列课程

    • 相关电子书

    更多
  • 阿里专家天樵：复杂业务系统下的规则引擎开发实践
  • 阿里高级开发工程师紫思：闲鱼多业务隔离框架SWAK
  • VISE3D云引擎+一键部署动态调配

    • 相关实验场景

    更多
  • 配置流程编排实现根据天气情况播放歌曲
  • 基于DTS构建一站式实时数据服务
  • 基于OpenTelemetry构建全链路追踪与监控
  • 基于数据湖架构的网站访问行为分析
  • 企业级云上网络构建
  • 容器DevSecOps全链路体验
    • 下一篇
    2024年阿里云免费云服务器及学生云服务器申请教程参考