Skip to main content Link Search Menu Expand Document (external link)

样例(Nacos)

整体架构

appactive_landscape

本 demo 整体架构如图。

注：

  • 应用共同依赖的注册中心 nacos 和 数据库 mysql 未在图中展示出来。
  • 本 demo 的命令通道依赖于 nacos，依赖 file 的 demo 参见此处

共有 2 个单元：

  • center: 中心单元
  • unit: 普通单元

共有 4 个应用，按照距离（调用链路）终端用户由近及远分别为：

  • gateway: 多活网关，分发用户流量
  • frontend: 前端应用，接受用户请求，请求到实际数据后返回
  • product: 产品应用，提供三个服务：
    • 产品列表: 普通服务
    • 产品详情: 单元服务
    • 产品下单: 中心服务，依赖库存应用
  • storage: 库存应用，供下单服务扣减库存

为简化起见，gateway 仅部署在 center，其余应用在 center 和 unit 各部署一套。

图中绿色格子代表了本次请求的调用链路。

快速启动

前提

要求安装如下软件

  • docker && docker-compose
  • curl

注：本 demo 包含较多应用，请调大 docker 内存，避免闪退；仅支持x86

步骤

  1. 在 appactive-demo 模块中运行 sh run-nacos-quick.sh ，启动所有应用
  2. 绑定本地 host: 127.0.0.1 demo.appactive.io，浏览器访问 http://demo.appactive.io/buyProduct?r_id=2000 查看效果
  3. 在appactive-portal 模块中运行 sh cut.sh NACOS appactiveDemoNamespaceId 进行切流 。需要注意的是，本 demo 的禁写规则是写死的，用户若要更换切流范围则需自行计算禁写规则和下次路由规则，然后执行切流。

如果你打算停止体验，可进行：cd appactive-demo -> sh quit.sh

若想直接体验，请见官方demo站点

源码构建

前提

  • 如上

步骤

  1. 进入 appactive-gateway/nginx-plugin 目录，将其打成镜像：docker build --build-arg UNITFLAG=center -t app-active/gateway:0.2.1 .
  2. 在项目根目录，maven build 获得 jar 包
  3. 在 appactive-demo 模块中运行 sh run-nacos.sh 1，然后访问127.0.0.1:8848/nacos 创建命名通道专用空间，如 appactiveDemoNamespaceId
  4. 在 appactive-portal 模块中运行 sh baseline.sh 2 NACOS appactiveDemoNamespaceId，推送应用基线
  5. 在 appactive-demo 模块中运行 sh run-nacos.sh 2 appactiveDemoNamespaceId ，启动所有应用和网关
  6. 在 appactive-portal 模块中运行 sh baseline.sh 3，推送网关基线
  7. 绑定本地 host: 127.0.0.1 demo.appactive.io，浏览器访问 http://demo.appactive.io/buyProduct?r_id=2000 查看效果
  8. 在 appactive-portal 模块中运行 sh cut.sh NACOS appactiveDemoNamespaceId 进行切流。需要注意的是，本 demo 的禁写规则是写死的，用户若要更换切流范围则需自行计算禁写规则和下次路由规则，然后执行切流。

分模块体验

前提

  1. 在 appactive-demo中 运行 nacos

     cd dependency/nacos && sh run.sh
 # 然后在 nacos 中创建命令通道专属空间，如`appactiveDemoNamespaceId`
  2. 在 appactive-portal 中运行 
     sh baseline.sh 2 NACOS appactiveDemoNamespaceId

  3. 在 appactive-demo中 运行 mysql

     cd dependency/mysql && sh run.sh

Filter

步骤

  1. 构建相关 jar 包

  2. 运行

     java -Dappactive.channelTypeEnum=NACOS \
        -Dappactive.namespaceId=appactiveDemoNamespaceId \
        -Dappactive.unit=unit \
        -Dappactive.app=frontend \
        -Dio.appactive.demo.unitlist=center,unit \
        -Dio.appactive.demo.applist=frontend,product,storage \
        -Dserver.port=8886 \
 -jar frontend-0.2.1.jar

  3. 测试

     curl 127.0.0.1:8886/show?r_id=1 -H "r_id:2" -b "r_id=3"
 routerId: 1
 curl 127.0.0.1:8886/show -H "r_id:2" -b "r_id=3"
 routerId: 2
 curl 127.0.0.1:8886/show  -b "r_id=3"
 routerId: 3
 curl 127.0.0.1:8886/show  
 routerId: null

MySQL

步骤

  1. 初始化数据

     # 进入容器
 docker exec -ti appactive-mysql bash
 # 导入数据
 mysql -uroot -pdemo_appactiive_pw product < /root/init.sql
 # 退出
 exit

  2. 构建所有 jar 包并运行

     java -Dappactive.channelTypeEnum=NACOS \
      -Dappactive.namespaceId=appactiveDemoNamespaceId \
      -Dappactive.unit=unit \
      -Dappactive.app=storage \
      -Dspring.datasource.url="jdbc:mysql://127.0.0.1:3306/product?characterEncoding=utf8&useSSL=false&serverTimezone=GMT&activeInstanceId=mysql&activeDbName=product" \
      -Dserver.port=8882 \
 -jar storage-0.2.1.jar

  3. 测试

     curl 127.0.0.1:8882/buy\?r_id=1 
 # 报错 403 FORBIDDEN "this is not center machine:unit"
 # 被微服务的单元保护拦截了

     # 绕过微服务保护，直接测试数据库保护功能
 curl 127.0.0.1:8882/buy1\?r_id=1 
 {"result":"routerId 1 bought 1 of item 12, result: success","chain":[{"app":"storage","unitFlag":"center"}]}%
    
 curl 127.0.0.1:8882/buy1\?r_id=4657 
 {"result":"routerId 4657 bought 1 of item 12, result: machine:unit,traffic:CENTER,not equals","chain":[{"app":"storage","unitFlag":"unit"}]}

Gateway

请见 nginx-plugin

Dubbo

构建 Dubbo 的 demo 过于复杂，建议使用 quick start 中启用的demo，直接进行体验。

SpringCloud

构建 SpringCloud 的 demo 过于复杂，建议使用 quick start 中启用的demo，直接进行体验，特别地，单元保护功能测试步骤如下：

  1. 发起测试

     curl 127.0.0.1:8884/detail -H "Host:demo.appactive.io" -H "appactive-router-id:2499"
 # 注意到报错会有这样一段
 403 FORBIDDEN "routerId 2499 does not belong in unit:unit"

因为我们直接将 路由id为 2499 的 请求路由到了单元，但实际上，这个请求应该路由到中心，所以被单元的provider拒绝请求了。

规则说明

基线

在运行所有应用后，我们运行了 baseline.sh，实际上做了如下几件事：

  • 通过 nacos 通道给 其他应用 推送规则
  • 通过 http 通道给 gateway 推送规则

规则包括

  • appactive.dataId.idSourceRulePath: 描述如何从 http 流量中提取路由标
  • appactive.dataId.transformerRulePath: 描述如何解析路由标
  • appactive.dataId.trafficRouteRulePath: 描述路由标和单元的映射关系
  • appactive.dataId.dataScopeRuleDirectoryPath_mysql-product: 描述数据库的属性

切流

切流时主要做了如下几件事：

  • 构建新的映射关系规则和禁写规则（手动）
  • 将新的映射关系规则推送给gateway
  • 将禁写规则推送给其他应用
  • 等待数据追平后将新的映射关系规则推送给其他应用

注意，新的映射关系是你想达到的目标状态，而禁写规则是根据目标状态和现状计算出来的差值。当前，这两者都需要你手动设置并更新到 appactive-portal/rule 下对应的json文件中去，然后运行 sh cut.sh NACOS appactiveDemoNamespaceId