服务拓扑
CoSky 的服务拓扑模块自动构建微服务生态系统的依赖关系图。当一个服务调用另一个服务时，调用方身份（消费者）和目标方身份（生产者）会被记录在 Redis 中。这使您能够可视化哪些服务依赖于哪些服务、跟踪跨命名空间依赖关系以及监控服务级别的实例统计——所有这些都无需任何手动配置。
| 方面 | 详情 |
|---|---|
| 接口 | ServiceTopology |
| Redis 实现 | RedisServiceTopology |
| 存储引擎 | Redis Hash（topology_idx + topology:{consumer}） |
| 消费者身份 | 来自 ServiceInstanceContext.serviceInstance |
| 并发模型 | 响应式（Mono<Map<String, Set<String>>>） |
ServiceTopology 接口
ServiceTopology 接口定义了两个操作：
| 方法 | 返回类型 | 描述 | 源码 |
|---|---|---|---|
addTopology | Mono<Void> | 记录当前服务依赖某个生产者服务 | ServiceTopology.kt:23 |
getTopology | Mono<Map<String, Set<String>>> | 获取命名空间的完整拓扑图 | ServiceTopology.kt:24 |
该接口还提供：
- 一个不执行任何操作的
NO_OP单例，在禁用拓扑跟踪时使用 (ServiceTopology.kt:27)。 consumerName派生自ServiceInstanceContext.serviceInstance.serviceId，如果未注册实例则回退到"_Client_"(ServiceTopology.kt:39)。getProducerName，如果生产者位于不同命名空间，则添加命名空间前缀（例如"otherNs.order-service"）(ServiceTopology.kt:48)。
RedisServiceTopology
RedisServiceTopology 将拓扑数据存储在两个 Redis 哈希结构中：
addTopology
addTopology 方法 (RedisServiceTopology.kt:11) 执行 service_topology_add.lua，该脚本：
- 将消费者名称记录到拓扑索引中：
HSETNX {namespace}:topology_idx {consumerName} {timestamp} - 记录生产者依赖：
HSETNX {namespace}:topology:{consumerName} {producerName} {timestamp}
自依赖（消费者 == 生产者）会被跳过 (RedisServiceTopology.kt:15)。
getTopology
getTopology 方法 (RedisServiceTopology.kt:26) 执行 service_topology_get.lua，该脚本：
- 通过
HKEYS从{namespace}:topology_idx读取所有消费者名称 - 对每个消费者，通过
HKEYS从{namespace}:topology:{consumerName}读取其依赖集合 - 返回
Map<String, Set<String>>结果——将每个消费者映射到其生产者集合
拓扑构建过程
mermaid
flowchart TD
A[服务 A 调用服务 B] --> B{ServiceInstanceContext<br>有 serviceInstance？}
B -->|是| C[consumerName = serviceInstance.serviceId]
B -->|否| D["consumerName = '_Client_'"]
C --> E[producerName = producerServiceId]
D --> E
E --> F{consumerName == producerName？}
F -->|是| G[跳过 - 自依赖]
F -->|否| H[EVAL service_topology_add.lua]
H --> I[HSETNX topology_idx<br>consumer -> timestamp]
H --> J[HSETNX topology:consumer<br>producer -> timestamp]
style A fill:#2d333b,stroke:#6d5dfc,color:#e6edf3
style B fill:#2d333b,stroke:#6d5dfc,color:#e6edf3
style F fill:#2d333b,stroke:#6d5dfc,color:#e6edf3
style G fill:#161b22,stroke:#30363d,color:#e6edf3
style H fill:#161b22,stroke:#30363d,color:#e6edf3
style I fill:#161b22,stroke:#30363d,color:#e6edf3
style J fill:#161b22,stroke:#30363d,color:#e6edf3时序图：拓扑查询流程
mermaid
sequenceDiagram
autonumber
participant Client as 仪表盘 / API
participant RST as RedisServiceTopology
participant Redis as Redis (Lua 脚本)
Client->>RST: getTopology("production")
RST->>Redis: EVAL service_topology_get.lua KEYS=["production"]
Redis->>Redis: HKEYS production:topology_idx
Redis-->>Redis: [gateway-svc, order-svc, user-svc]
loop 对每个消费者
Redis->>Redis: HKEYS production:topology:{consumer}
Redis-->>Redis: 生产者名称列表
end
Redis-->>RST: [consumer1, [producers1], consumer2, [producers2], ...]
RST->>RST: 解析为 Map~String, Set~String~~
RST-->>Client: consumer 到 producer 集合的映射时序图：拓扑记录流程
mermaid
sequenceDiagram
autonumber
participant SvcA as 服务 A（网关）
participant SC as ServiceInstanceContext
participant RST as RedisServiceTopology
participant Redis as Redis (Lua 脚本)
participant Sub as PubSub
SvcA->>SvcA: 准备调用服务 B
SvcA->>SC: 获取当前 serviceInstance
SC-->>SvcA: serviceInstance.serviceId = "gateway-svc"
SvcA->>RST: addTopology(producerNs="production", producerServiceId="order-svc")
RST->>RST: consumerName = "gateway-svc"
RST->>RST: producerName = "order-svc"
RST->>RST: 检查自依赖（相同则跳过）
RST->>Redis: EVAL service_topology_add.lua KEYS=["production"]
Redis->>Redis: HSETNX production:topology_idx gateway-svc {timestamp}
Redis->>Redis: HSETNX production:topology:gateway-svc order-svc {timestamp}
Redis-->>RST: (void)
RST-->>SvcA: Mono~Void~Redis 键模式
| Redis 键 | 类型 | 用途 | Lua 脚本 |
|---|---|---|---|
{namespace}:topology_idx | HASH | 消费者服务名称到首次出现时间戳的映射 | service_topology_add.lua |
{namespace}:topology:{consumer} | HASH | 指定消费者的生产者服务名称到首次出现时间戳的映射 | service_topology_add.lua |
跨命名空间的生产者名称格式为 {producerNamespace}.{producerServiceId}，由 ServiceTopology.getProducerName 生成。这使得拓扑图能够区分不同命名空间中的同名服务。
服务统计集成
ServiceStat 数据类与拓扑视图配合，显示每个服务的实例数量。RedisServiceStatistic 维护一个 {namespace}:svc_stat 哈希，其中每个条目将 serviceId 映射到其 instanceCount。
当实例事件发生时（不包括续约），统计会通过 Lua service_stat.lua 脚本自动重新计算。这种集成使仪表盘能够同时显示依赖图和拓扑中每个节点的健康/负载状态。
mermaid
flowchart TD
subgraph ProdNS["生产环境命名空间"]
GW["gateway-svc<br>实例数: 3"]
OS["order-svc<br>实例数: 5"]
US["user-svc<br>实例数: 2"]
PS["payment-svc<br>实例数: 4"]
end
GW -->|"依赖"| OS
GW -->|"依赖"| US
OS -->|"依赖"| PS
OS -->|"依赖"| US
style GW fill:#2d333b,stroke:#6d5dfc,color:#e6edf3
style OS fill:#2d333b,stroke:#6d5dfc,color:#e6edf3
style US fill:#2d333b,stroke:#6d5dfc,color:#e6edf3
style PS fill:#2d333b,stroke:#6d5dfc,color:#e6edf3
style ProdNS fill:#161b22,stroke:#30363d,color:#e6edf3仪表盘集成
拓扑数据驱动 CoSky 仪表盘的服务拓扑可视化。仪表盘调用 getTopology(namespace) 获取完整依赖图，调用 getServiceStats(namespace) 显示每个服务的实例数量。这两者共同生成交互式图谱，显示：
- 带有实例数量的服务节点
- 表示调用依赖关系的有向边
- 跨命名空间关系（显示为
{namespace}.{serviceId}）
类图
mermaid
classDiagram
class ServiceTopology {
<<interface>>
+addTopology(producerNamespace, producerServiceId) Mono~Void~
+getTopology(namespace) Mono~Map~
+consumerName$ String
+getProducerName$(ns, serviceId) String
+NO_OP$ ServiceTopology
}
class RedisServiceTopology {
-redisTemplate: ReactiveStringRedisTemplate
+addTopology(producerNamespace, producerServiceId) Mono~Void~
+getTopology(namespace) Mono~Map~
}
class ServiceInstanceContext {
<<object>>
+serviceInstance: ServiceInstance
+namespace: String
}
class ServiceStat {
+serviceId: String
+instanceCount: Int
}
class ServiceStatistic {
<<interface>>
+statService(namespace) Mono~Void~
+statService(namespace, serviceId) Mono~Void~
+getServiceStats(namespace) Flux~ServiceStat~
+getInstanceCount(namespace) Mono~Long~
}
class RedisServiceStatistic {
-redisTemplate: ReactiveStringRedisTemplate
-instanceEventListenerContainer
+statService(namespace) Mono~Void~
+getServiceStats(namespace) Flux~ServiceStat~
+getInstanceCount(namespace) Mono~Long~
}
ServiceTopology <|.. RedisServiceTopology : 实现
ServiceStatistic <|.. RedisServiceStatistic : 实现
RedisServiceTopology --> ServiceInstanceContext : 读取 consumerName
RedisServiceStatistic --> ServiceStat : 生成