6627 是什么
6627 是 Apache Storm 的 Nimbus(主节点)Thrift RPC 端口。Storm 用 Nimbus 与 Supervisor 结构做流式计算:Nimbus 负责拓扑的提交、调度与监控,Supervisor 在 worker 节点上启动 JVM 执行任务,UI 默认在 8080 展示拓扑状态,集群元数据依赖 ZooKeeper。Nimbus 的 Thrift 接口能提交任意拓扑,拓扑里可以打包代码,因此在安全评审里它与代码执行入口等价,必须做网络隔离。
基本信息
| 服务 | Storm Nimbus(默认 6627) |
|---|---|
| 协议 | TCP(Thrift RPC) |
| 用途 | 流计算拓扑提交与调度 |
| 配套端口 | 8080(UI)、2181(ZooKeeper) |
| 客户端工具 | storm CLI |
| 安全等级 | 仅大数据网段 |
典型使用场景
- 拓扑提交排障:确认 Nimbus 可达且 ZooKeeper 状态正常
- 集群巡检:查看拓扑运行状态与 worker 分布
- 安全核查:确认 6627 未暴露到业务网或公网
- 迁移评估:向 Flink 等新引擎迁移时的依赖梳理
- 资源调优:worker 数与 JVM 内存配置对吞吐的影响
- 版本升级:Storm 与 ZooKeeper 版本配套验证
Storm 体系端口
| 端口 | 组件 | 说明 |
|---|---|---|
| 6627 | Nimbus | Thrift RPC:拓扑提交与调度 |
| 8080 | Storm UI | 拓扑与 worker 状态展示 |
| 2181 | ZooKeeper | 集群元数据与协调 |
| 6700+ | Supervisor 工作进程 | worker 通信(按配置) |
探测与状态核对
探测与状态核对
nc -zv storm01 6627 # Nimbus 连通性
curl -s http://storm01:8080/api/v1/cluster/summary | head -c 200 # UI API
ss -lntp | grep -E '6627|8080' # 监听核对
storm list # 已提交拓扑清单
# 日志: Nimbus 与 Supervisor 日志是拓扑卡住的第一现场Nimbus 的 Thrift 接口默认没有认证:能连上就能提交拓扑,而拓扑里可以打包任意代码,因此在安全评审中必须按远程执行对待,靠网络隔离而不是靠配置。
Storm 拓扑的调度依赖 ZooKeeper 元数据:集群异常时先看 ZooKeeper 会话与 Nimbus 日志,再怀疑业务代码,顺序反了会浪费大量时间。
流计算作业的故障往往表现为数据延迟而不是报错:监控要覆盖处理延迟与队列积压,只看进程存活无法发现这类问题。
Nimbus 与 Supervisor 的版本必须一致:混版本时拓扑能提交但任务反复重启,日志里通常只有零星的序列化错误。