KubeMQ

KubeMQ 发布订阅组件的详细文档

组件格式

要设置 KubeMQ 发布订阅，需创建类型为 pubsub.kubemq 的组件。参阅发布订阅代理组件文件以了解如何自动生成 ConsumerID。阅读操作指南：发布与订阅以了解如何创建和应用发布订阅配置。

apiVersion: dapr.io/v1alpha1
kind: Component
metadata:
  name: kubemq-pubsub
spec:
  type: pubsub.kubemq
  version: v1
  metadata:
    - name: address
      value: localhost:50000
    - name: store
      value: false
    - name: consumerID
      value: channel1

规范元数据字段

字段	必填	详情	示例
address	Y	KubeMQ 服务器的地址	`"localhost:50000"`
store	N	发布订阅类型，true：发布订阅持久化（EventsStore），false：发布订阅内存（Events）	`true` 或 `false`（默认为 `false`）
consumerID	N	消费者 ID（消费者标签）将一个或多个消费者组织成一个组。具有相同消费者 ID 的消费者作为一个虚拟消费者工作；例如，一条消息仅由该组中的一个消费者处理一次。如果未提供 `consumerID`，Dapr 运行时将其设置为 Dapr 应用程序 ID（`appID`）值。	可设置为字符串值（例如上面示例中的 `"channel1"`）或字符串格式值（例如 `"{podName}"` 等）。查看您可在组件元数据中使用的所有模板标签。
clientID	N	客户端 ID 连接的名称	`sub-client-12345`
authToken	N	用于连接的身份验证 JWT 令牌查看 KubeMQ Authentication	`ew...`
group	N	用于负载均衡的订阅者组	`g1`
disableReDelivery	N	设置在来自应用程序发生错误的情况下是否应重新传递消息	`true` 或 `false`（默认为 `false`）

创建 KubeMQ 代理

获取 KubeMQ 密钥。
等待带有您的密钥的电子邮件确认

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

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

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

获取 KubeMQ 密钥。
等待带有您的密钥的电子邮件确认

然后运行以下 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 后，运行 port-forward 命令：

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

KubeMQ 文档

访问 KubeMQ 文档以获取更多信息。