数据交换平台

概述

本数据交换平台用于满足多系统间数据交互需求，支持定义 API、K8S 服务部署、网关配置及插件限流等操作，助力高效数据交换与微服务管理。

仪表板

点击左侧导航 “仪表板”，进入平台概览页面，可查看平台整体运行状态、关键数据统计（如微服务数量、交互流量等 ），快速掌握平台概况。

路由

功能描述：路由配置是数据交换平台实现多系统数据交互的核心环节，通过 “设置路由信息”“设置上游服务”“插件配置” 三个步骤，精准定义请求匹配规则、转发目标及功能扩展（如限流、鉴权 ），保障数据高效、安全流转。

操作流程：点击 “路由” 进入配置界面，可新增路由（定义匹配条件、转发目标等 ）、编辑已有路由（调整规则 ）、删除无用路由，实现精准流量调度。

步骤 1：设置路由信息

界面展示

操作说明

1. 基本信息

• 名称：输入路由名称（如 order-service-route ），用于标识路由，便于管理。
• 标签：选填，可设置业务标签（如 订单系统 ），辅助分类检索。
• 路由版本：输入版本号（如 v1.0 ），用于版本迭代管理。
• 描述：选填，补充路由功能说明（如 订单查询接口路由 ）。
• 重定向：在此配置 redirect 插件，通过配置该插件，可实现数据请求的重定向功能。根据业务需求，设置源地址与目标地址映射关系，当满足特定条件的请求到达时，插件会自动将请求转发至目标地址，确保数据交换的灵活路由与高效流转 。
• 绑定服务：通过将服务（Service）对象进行绑定操作，可实现其内部配置的高效复用。这种方式能有效减少重复性配置工作，提升数据交换平台路由配置的效率与一致性，在面对相似业务场景需求时，只需绑定对应服务对象，即可快速应用已配置好的参数与规则 。
• websocket：按需开启（若涉及 websocket 协议交互，开启此开关 ）。

2. 匹配条件

• 域名：填写匹配的请求域名（如 api.example.com ），支持多域名配置（点击 “+ 新增” 添加 ）。
• 路径：输入请求路径规则（如 /order/query ），支持通配符（/order/* 匹配订单模块所有路径 ）。
• 客户端地址：限定请求来源 IP（如 192.168.1.0/24 ），增强安全性，支持多 IP 段配置（点击 “+ 新增” ）。
• HTTP 方法：勾选支持的请求方法（如 GET POST ），限定请求类型。
• 优先级：设置路由优先级（数值越大越优先 ），解决多路由匹配冲突。

3. 请求改写

• 协议：选择请求转发协议（HTTP/HTTPS/保持原样 ），适配上游服务协议。
• 路径改写：按需改写请求路径（如将 /v1/order 改写为 /order ），支持 “保持原样”“静态改写”“正则改写”。
• 域名改写：类似路径改写，调整请求域名，适配上游服务。
• HTTP 头改写：选择改写策略（不变更/新增/删除 ），编辑请求头（如添加 X-Request-From: data-platform ）。
• 请求参数：配置参数改写规则（新增、删除、修改 ），点击 “+ 新增” 设置参数名、操作类型、值。

4. 高级匹配条件

• 针对复杂场景（如请求头、Cookie 匹配 ），点击 “+ 新增”，选择匹配字段（如 Header ）、操作符（如 等于 ）、值（如 token ），精准筛选请求。

填写完信息后，点击 “下一步”，进入 “设置上游服务” 环节。

步骤 2：设置上游服务

界面展示

操作说明

1. 基础配置

• 选择上游服务：下拉选择已创建的上游服务（若未创建，需提前在 “上游” 模块配置 ），或新建上游。
• 负载均衡算法：选择算法（如 Round Robin轮询、Least Connections最小连接数 ），合理分配请求到上游节点。

2. 上游服务详情

• 上游类型：选择 服务发现或 静态节点（若为 K8S 环境，常用 服务发现 ）。
• 服务发现类型：若选 服务发现，下拉选择类型（如 Kubernetes ），适配部署环境。
• 服务名称：填写上游服务在注册中心的名称（如 dejjanyjanalnding-api:8080 ），用于服务发现。
• Host 请求头：选择处理策略（如 保持与客户端请求一致的主机名 ），保障上游服务识别请求来源。
• 重试次数：设置请求失败后的重试次数（如 3 ），增强服务可用性。
• 重试超时时间：设置重试的超时阈值（如 5000毫秒 ），避免无限重试。

3. 连接配置

• 协议：选择上游服务协议（HTTP/HTTPS ），需与上游实际协议一致。
• 连接超时：设置建立连接的超时时间（如 6秒 ），超时则判定请求失败。
• 发送超时：设置请求数据发送的超时时间（如 6秒 ）。
• 接收超时：设置等待响应的超时时间（如 6秒 ）。

4. 连接池

• 连接池容量：设置最大连接数（如 320 ），控制并发连接，避免资源过载。
• 空闲超时时间：设置连接空闲回收时间（如 60秒 ），释放闲置连接。
• 请求数量：设置连接池单个连接可处理的最大请求数（如 1000 ），防止连接长期占用。

5. 健康检查

• 主动检查：开启后，平台定时发送健康探测请求（如 GET /health ），检测上游节点状态，失效节点会被暂时剔除。
• 被动检查：开启后，根据请求失败情况（如连续失败次数 ），动态标记节点状态，辅助负载均衡决策。

配置完成后，点击 “下一步”，进入 “插件配置” 环节。

步骤 3：插件配置

界面展示

操作说明

1. 插件模板选择

• 选择插件模板（如 手动配置或预设模板 ），模板可快速加载常用插件组合（如 “限流 + 鉴权” 模板 ）。

2. 插件分类配置

• 身份验证：按需启用插件（如 basic-auth基本认证 ），点击 “启用” 后配置参数（如用户名、密码 ），实现请求身份校验。
• 安全防护：启用 waf（Web 应用防火墙 ）等插件，配置拦截规则（如 SQL 注入特征 ），防护恶意请求。
• 流量控制：启用 limit-req（请求限流 ）插件，设置阈值（如 100请求 / 分钟 ），控制流量峰值。
• 服务治理：启用 circuit-breaker（熔断 ）插件，配置熔断条件（如连续失败率达 50% ），避免雪崩效应。
• 可观测性：启用 prometheus插件，暴露监控指标，对接观测平台（如 Grafana ），分析路由性能。
• 插件执行顺序部分平台支持调整插件执行顺序（拖拽排序 ），需注意：鉴权类插件建议前置执行，优先校验请求合法性；限流类插件紧跟鉴权，控制合法请求流量；日志、监控插件后置，完整记录请求过程。

配置完插件后，点击 “下一步” 进入 “预览” 环节，核对路由信息、上游服务、插件配置是否正确，确认无误后提交，完成路由创建。

常见问题与解决

（一）路由匹配失效

现象：请求未按预期匹配路由。排查：

1. 检查 “匹配条件”（路径、域名、HTTP 方法 ）是否与请求一致，注意通配符规则。
2. 核对路由优先级，是否有更高优先级路由拦截请求。

（二）上游服务不可达

现象：请求转发超时或报错 “上游服务无响应”。排查：

1. 检查 “上游服务” 配置（服务名称、协议、连接超时 ）是否与实际一致。
2. 验证上游服务自身是否可访问（直接调用上游接口测试 ）。

（三）插件不生效

现象：启用插件后，未实现预期功能（如限流未生效 ）。排查：

1. 检查插件是否 “启用”，参数配置是否正确（如限流阈值、鉴权密码 ）。
2. 确认插件执行顺序，是否因顺序问题导致功能未触发（如鉴权未通过，后续插件未执行 ）。

上游

功能描述：上游服务配置是数据交换平台实现请求转发的关键环节，用于定义一组提供相同功能的服务节点集合，通过设置负载均衡算法、节点信息、连接超时等参数，保障请求高效、稳定地转发至后端服务，支撑多系统间数据交互。

操作流程：进入 “上游” 模块，可添加上游服务（填写服务地址、权重等参数 ）、维护服务列表（更新服务信息、移除失效服务 ），保障数据转发的目标服务可用。

步骤 1：基础信息填写

界面展示

操作说明

1. 名称：输入上游服务的唯一标识名称（如 order-service-upstream ），用于路由配置中关联上游，需清晰体现业务归属，方便管理识别。
2. 描述：选填，补充上游服务的功能说明（如 订单系统后端服务节点集合 ），辅助后续运维人员理解用途。
3. 负载均衡算法：下拉选择算法，默认提供 Round Robin（轮询），也可能支持 Least Connections（最小连接数）等（依平台实际）。轮询算法会按顺序将请求依次分配到各节点，实现简单的负载分发；若选最小连接数，优先转发到当前连接数最少的节点，适用于请求处理时长差异较大的场景。
4. 上游类型：选择 节点（若平台有其他类型如 “服务发现” 等，按需切换，此处以 “节点” 为例 ），表示直接配置具体服务节点信息。
5. 目标节点：

• 主机名 / IP：填写服务节点的主机名或 IP 地址（如 192.168.1.100 ），若为域名需确保平台可解析。
• 端口：填写节点提供服务的端口（如 8080 ）。
• 权重：设置该节点的权重（默认 1 ），权重越高，分配到的请求比例越大。例如，节点 A 权重 2、节点 B 权重 1，则轮询时，每 3 个请求，2 个发往 A，1 个发往 B 。点击 “+ 新建” 可添加多个目标节点，构建上游服务节点池。

6. Host 请求头：下拉选择 保持与客户端请求一致的主机名（或其他策略，依需求选 ），决定转发请求时 Host 头的处理方式，确保上游服务能正确识别请求来源。
7. 重试次数：选填，设置请求失败后重试的次数（如 3 ），需结合上游服务稳定性配置，避免因频繁重试加重服务压力。
8. 重试超时时间：选填，设置重试请求的超时阈值（如 5000毫秒 ），超时则停止重试，判定请求失败。
9. 协议：选择上游服务使用的协议，默认 HTTP，若为 HTTPS需确保平台支持并配置对应证书等。
10. 连接超时：设置建立与上游节点连接的超时时间（默认 6秒 ），超时则判定连接失败，触发重试或返回错误。
11. 发送超时：设置向上游节点发送请求数据的超时时间（默认 6秒 ），超时则终止请求，保障系统不长期阻塞。
12. 接收超时：设置等待上游节点返回响应的超时时间（默认 6秒 ），超时则判定响应失败，执行重试或报错。
13. 连接池：

• 连接池容量：设置连接池最大连接数（默认 320 ），控制并发连接数，避免资源耗尽。
• 空闲超时时间：设置连接池中空闲连接的回收时间（默认 60秒 ），释放闲置连接，提升资源利用率。
• 请求数量：设置单个连接可处理的最大请求数（默认 1000 ），防止连接长期占用，影响后续请求。

14. 健康检查：

• 主动检查：开启开关后，平台定时发送健康探测请求（如 GET /health ）到上游节点，检测节点状态，若失败则暂时剔除节点，保障请求转发到健康节点；关闭则不主动探测。
• 被动检查：开启后，根据请求实际执行结果（如连续失败次数 ），动态标记节点健康状态，辅助负载均衡决策；关闭则仅依赖主动检查或无健康检查。

填写完基础信息后，点击 “下一步”，进入 “预览” 环节，核对上游配置信息，确认无误后提交，完成上游创建。

常见问题与解决

（一）节点无法连接

现象：请求转发时报错 “无法连接上游节点”。排查：

1. 检查 “目标节点” 的主机名 / IP、端口是否正确，确保网络可达（可在平台服务器上通过 ping、telnet等命令测试 ）。
2. 核对 “协议” 是否与上游服务实际协议一致（如上游是 HTTPS，配置成 HTTP会导致连接失败 ）。
3. 查看 “连接超时” 等时间设置，若网络延迟高，可适当增大超时时间。

（二）负载均衡未按预期分配请求

现象：请求分配比例与节点权重设置不符。排查：

1. 确认 “负载均衡算法” 选择是否正确，不同算法分配逻辑不同（如轮询按顺序，最小连接数按当前连接数 ）。
2. 检查各节点 “权重” 设置，确保数值准确，且节点状态均为健康（若有节点被健康检查剔除，会影响分配 ）。

（三）健康检查失效

现象：上游节点异常，但仍有请求转发过去，导致报错。排查：

1. 确认 “主动检查” 或 “被动检查” 是否开启，若未开启，平台无法自动识别节点状态。
2. 检查健康检查的探测路径（如 /health ）是否正确，上游服务需提供对应的健康检查接口，返回预期状态码（如 200 ）。

数据微服务

功能描述：数据微服务模块用于管理微服务全生命周期，支持微服务的创建、查询、编排（配置业务逻辑 ）、发布（部署为 K8S 服务 ）及状态维护，助力实现 API 编排与 K8S 化部署，满足多系统数据交互需求。

操作流程：进入 “数据微服务” 模块，可添加微服务、维护微服务列表（更新服务信息、移除失效服务 ）。

微服务列表查看与筛选

操作说明

1. 查询微服务：在 “微服务名称”“状态”“所属项目” 输入框，填写对应筛选条件（如名称填 node2、状态选 未发布 ），点击 “查询”，列表将显示符合条件的微服务；点击 “重置” 可清空条件，恢复默认列表。
2. 列表信息解读：

• ID：微服务唯一标识，用于精准定位。
• 微服务名称：如 登录服务 等，体现服务业务含义。
• 状态：含 未发布（服务未部署到 K8S ）、已发布（已部署为 K8S 服务 ），直观反映服务生命周期阶段。
• 所属项目：如 用户管理、消息管理 等，关联服务归属项目，便于按项目管理。
• 对应 K8S 服务：已发布服务显示关联的 K8S 服务标识，未发布则为空。
• 最近发布时间：记录服务最后一次发布的时间点，追溯版本变更。
• 操作：提供 编排（进入业务逻辑编辑器 ）、发布/更新（部署或更新 K8S 服务 ）、更多（扩展操作，如删除、查看日志等，依平台实际 ）功能。

创建微服务

操作入口

点击列表右上角 “+ 创建” 按钮，进入微服务创建流程。

操作说明

1. 填写基本信息：输入微服务名称（如 new-service ）、所属项目（选择已有项目或新建 ）、描述（选填，补充服务说明 ）等。
2. 提交创建：确认信息无误后，提交完成微服务创建，新服务会以 未发布 状态显示在列表。

编排微服务

操作入口

在微服务列表 “操作” 列，点击对应微服务的 “编排” 按钮，进入业务逻辑编辑器界面。

操作说明

1. 功能概述：通过拖拽、配置节点，编排微服务的业务逻辑，如 API 调用顺序、数据转换、条件判断等，构建完整的数据交互流程。
2. 核心操作：

• 添加节点：从节点库（如 API 调用节点、数据处理节点、分支判断节点 ）拖拽节点到编辑区，构建逻辑链路。
• 配置节点：点击节点，设置参数（如 API 节点配置请求地址、方法、参数；数据处理节点配置转换规则 ）。
• 连接节点：通过连线设定节点执行顺序，定义数据流转路径。
• 保存编排：完成逻辑编排后，保存配置，为发布微服务到 K8S 做准备。
• 发布编排：编排完成后需点击编辑器右上角发布。在编辑器中发布后，数据微服务才可发布到 K8S。

发布 / 更新微服务（部署为 K8S 服务 ）

操作入口

在微服务列表 “操作” 列，未发布 状态的服务显示 “发布” 按钮，已发布 状态的显示 “更新” 按钮，点击对应按钮执行操作。

发布前置条件

在业务逻辑编辑器中已经点击了发布。

操作说明

1. 发布（未发布 → 已发布 ）：

• 点击 “发布”，平台将编排并在编辑器中发布好的微服务逻辑，打包并部署为 K8S 服务。
• 部署完成后，“状态” 更新为 已发布，“对应 K8S 服务” 显示关联标识，“最近发布时间” 记录发布时刻。

2. 更新（已发布服务迭代 ）：

• 对已发布服务，若修改了编排逻辑或配置，点击 “更新”。注意：修改了编排需要在编辑器中重新发布。
• 平台会重新打包并滚动更新 K8S 服务，保障服务无感知升级，更新后 “最近发布时间” 同步更新。

服务

1. 功能：管理平台关联的各类服务资源，查看服务详情、依赖关系等。
2. 操作：进入 “服务” 模块，浏览服务列表，点击服务条目可查看详情（如服务接口、调用统计 ），支持对服务进行启停、依赖配置等操作（依实际功能 ）。

消费者

1. 功能：管理数据服务的消费者信息，控制服务调用权限、配额。
2. 操作：在 “消费者” 页面，可添加消费者（配置调用权限、分配配额 ）、编辑消费者信息（调整权限、配额 ）、删除消费者，保障服务安全有序被调用。

Protocol Buffers

1. 功能：用于定义数据交互的结构化协议，实现高效数据序列化与反序列化。
2. 操作：进入模块后，可上传、编辑 Protocol Buffers 协议文件（.proto ），定义数据结构、服务接口；支持查看协议关联的微服务使用情况，保障数据交互格式统一。

插件

1. 功能：提供丰富插件（如限流、鉴权 ），扩展平台功能，满足个性化需求。
2. 操作：点击 “插件” 进入管理页，可安装新插件（选择插件类型，配置参数 ）、启用 / 禁用插件（控制插件生效状态 ）、配置插件规则（如限流插件设置阈值 ），灵活增强平台能力。

证书

1. 功能：管理数据交互的安全证书，保障数据传输加密、身份认证。
2. 操作：在 “证书” 模块，可上传证书（填写证书内容、有效期等 ）、更新证书（替换过期证书 ）、绑定证书到服务（指定服务使用证书加密传输 ），确保数据交互安全。

系统信息

1. 功能：查看平台系统参数、版本信息、运行日志等，用于系统运维与问题排查。
2. 操作：进入 “系统信息”，浏览系统基础信息（版本、部署环境 ），查询运行日志（按时间、类型筛选 ），辅助管理员了解系统状态、定位故障。