MBS Connector 配置

ConnectorType 概览

MBS ConnectorType 基于 HTTP 类型，负责配置 MBS 服务的连接信息。创建 Connector 实例后，所有 MBS Action 都会复用此连接配置进行 API 调用。

字段	值
名称	MBS
Base	HTTP
Description	MBS (Message Broker Service) 统一消息代理服务连接器

Parameters（连接参数）

Name	Label	Data Type	Control Type	必填	说明
`baseUrl`	Base URL	string	text	是	MBS 服务地址，如 `http://mbs-host:8080`
`token`	Token	string	password	是	MBS API 认证 Token

baseUrl

MBS 服务的根地址，后续所有 Action 的 HTTP 请求都会以此为基础路径。

格式示例：

http://10.0.1.50:8080
http://mbs.internal.company.com:8080
https://mbs.prod.company.com

caution

地址末尾不要加 /，直接填写到端口即可。

token

MBS API 的认证令牌。需要从 MBS 管理后台获取，Token 决定了你对哪些 Broker/Queue 具有读写权限。

Token 的认证方式：

MBS 支持通过 HTTP Header 传递 Token：Authorization: Bearer your-token
也支持通过 Query Parameter 传递：?token=your-token
在 Connector 中配置后，会自动以 Header 方式附加到所有请求中

Config Script（连接脚本）

return [
  "baseUrl": inputs.baseUrl,
  "headers": ["Authorization": "Bearer " + inputs.token],
  "ignoreSSL": true,
  "printRequest": true
]

脚本返回字段说明：

Key	类型	说明
`baseUrl`	string	Action 请求的基础域名，透传用户填写的 MBS 地址
`headers`	map	自动附加到所有 Action 请求的 HTTP Header，这里设置了 Bearer Token 认证
`ignoreSSL`	bool	是否忽略 SSL 证书校验，内网部署时通常设为 `true`
`printRequest`	bool	是否打印请求日志，方便调试时查看请求详情

创建 Connector 实例步骤

前置条件

MBS 服务已部署并正常运行
已从 MBS 管理后台获取到 API Token
Token 具有目标 Broker/Queue 的相应读写权限

操作步骤

在 Connector 类型的 PBC 中，点击新建 Connector
选择 ConnectorType 为 MBS
填写参数：
- Base URL - MBS 服务地址（如 http://10.0.1.50:8080）
- Token - 从 MBS 管理后台获取的 API Token
保存

Token 权限说明

Token 的权限决定了你能操作哪些 Broker 和 Queue：

write 权限 - 允许向队列推送消息（Enqueue）
read 权限 - 允许订阅队列（Subscribe）和确认消息（ACK）

权限格式为 {brokerName}/{queueName}，支持通配符 *：

{
  "builtin/orders": {"read": true, "write": true},
  "kafka-prod/*": {"read": true, "write": false},
  "*": {"read": true, "write": false}
}

匹配规则（精确度优先）：

精确匹配：builtin/orders
Queue 通配：builtin/*
全局通配：*

tip

建议每个业务模块使用独立的 Token，按最小权限原则分配。例如，订单服务只需要 builtin/order-events 的 write 权限。

ConnectorType 概览​

Parameters（连接参数）​

baseUrl​

token​

Config Script（连接脚本）​

创建 Connector 实例步骤​

前置条件​

操作步骤​

Token 权限说明​