The documentation you are viewing is for Dapr v1.6 which is an older version of Dapr. For up-to-date documentation, see the latest version.

JetStream

Detailed documentation on the NATS JetStream component

配置

要设置 JetStream pubsub，请创建一个类型为 pubsub.jetstream 的组件。 请参阅本指南，了解如何创建和应用 pubsub 配置。

apiVersion: dapr.io/v1alpha1
kind: Component
metadata:
  name: jetstream-pubsub
  namespace: default
spec:
  type: pubsub.jetstream
  version: v1
  metadata:
  - name: natsURL
    value: "nats://localhost:4222"
  - name: name
    value: "connection name"
  - name: durableName
    value: "consumer durable name"
  - name: queueGroupName
    value: "queue group name"
  - name: startSequence
    value: 1
  - name: startTime # in Unix format
    value: 1630349391
  - name: deliverAll
    value: false
  - name: flowControl
    value: false

元数据字段规范

字段 必填 详情 示例
natsURL 是 NATS 服务器地址 URL “nats://localhost:4222”
name 否 NATS 连接名称 "my-conn-name"
durableName 否 Durable name "my-durable"
queueGroupName 否 队列组名称 "my-queue"
startSequence 否 起始编号 1
startTime 否 Unix 时间戳格式的开始时间 1630349391
deliverAll 否 将全部交付设置为 重播策略 true
flowControl 否 流量控制 true

创建NATS服务器


您可以使用 Docker 在本地启用 JetStream 运行 NATS 服务器：

docker run -d -p 4222:4222 nats:latest -js

然后，您可以使用 localhost:4222 与服务器进行交互。


使用 [helm](https://github. com/nats-io/k8s/tree/main/helm/charts/nats#jetstream)在 Kubernetes 上安装 NATS JetStream：

helm repo add nats https://nats-io.github.io/k8s/helm/charts/
helm install my-nats nats/nats

在default 命名空间安装单进程NATS服务。 要与NATS进行交互，请使用以下方法找到服务：kubectl get svc my-nats.

创建 JetStream

为特定主题创建 NATS JetStream 至关重要。 例如，对于本地运行的 NATS 服务器，请使用：

nats -s localhost:4222 stream add myStream --subjects mySubject

相关链接