KubeMQ 绑定规范

关于 KubeMQ 绑定组件的详细文档

组件格式

要设置 KubeMQ 绑定，需创建一个类型为 bindings.kubemq 的组件。请参阅本指南了解如何创建和应用绑定配置。

apiVersion: dapr.io/v1alpha1
kind: Component
metadata:
  name: binding-topic
spec:
  type: bindings.kubemq
  version: v1
  metadata:
    - name: address
      value: "localhost:50000"
    - name: channel
      value: "queue1"
    - name: direction
      value: "input, output"

规范元数据字段

字段必需详情示例
addressYKubeMQ 服务器的地址"localhost:50000"
channelY队列通道名称"queue1"
authTokenN连接的 Auth JWT 令牌。请参阅 KubeMQ 认证"ew..."
autoAcknowledgedN设置是否自动确认接收到的队列消息"true" 或 "false" (默认是 "false")
pollMaxItemsN设置每次连接轮询的消息数量"1"
pollTimeoutSecondsN设置每个轮询间隔的时间（秒）"3600"
directionN绑定的方向"input", "output", "input, output"

绑定支持

该组件支持 输入和输出 绑定接口。

创建 KubeMQ 代理

  1. 获取 KubeMQ 密钥。
  2. 等待电子邮件确认您的密钥

您可以使用 Docker 运行 KubeMQ 代理：

docker run -d -p 8080:8080 -p 50000:50000 -p 9090:9090 -e KUBEMQ_TOKEN=<your-key> kubemq/kubemq

然后，您可以通过客户端端口与服务器交互：localhost:50000

  1. 获取 KubeMQ 密钥。
  2. 等待电子邮件确认您的密钥

然后运行以下 kubectl 命令：

kubectl apply -f https://deploy.kubemq.io/init

kubectl apply -f https://deploy.kubemq.io/key/<your-key>

安装 KubeMQ CLI

请访问 KubeMQ CLI 并下载最新版本的 CLI。

浏览 KubeMQ 仪表板

打开浏览器并导航到 http://localhost:8080

安装 KubeMQCTL 后，运行以下命令：

kubemqctl get dashboard

或者，安装 kubectl 后，运行端口转发命令：

kubectl port-forward svc/kubemq-cluster-api -n kubemq 8080:8080

KubeMQ 文档

访问 KubeMQ 文档 了解更多信息。

相关链接