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用于连接的身份验证 JWT 令牌。查看 KubeMQ Authentication"ew..."
autoAcknowledgedN设置接收到的队列消息是否自动确认"true" 或 "false"（默认为 "false"）
pollMaxItemsN设置每次连接时轮询的消息数量"1"
pollTimeoutSecondsN设置每次轮询间隔的时间（秒）"3600"
directionN绑定的方向"input"、"output"、"input, output"

绑定支持

此组件同时支持 输入和输出 绑定接口。

创建 KubeMQ broker

  1. 获取 KubeMQ Key。
  2. 等待包含您的密钥的邮件确认

您可以使用 Docker 运行 KubeMQ broker：

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

然后您可以使用客户端端口与服务器交互：localhost:50000

  1. 获取 KubeMQ Key。
  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 Dashboard

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

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

kubemqctl get dashboard

或者，安装了 kubectl 后，运行 port-forward 命令：

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

KubeMQ 文档

访问 KubeMQ Documentation 获取更多信息。

相关链接