JetStream KV

JetStream KV 状态存储组件的详细介绍

组件格式

要设置 JetStream KV 状态存储，请创建一个类型为 state.jetstream 的组件。有关如何创建和应用状态存储配置的详细步骤，请参阅本指南。

apiVersion: dapr.io/v1alpha1
kind: Component
metadata:
  name: <NAME>
spec:
  type: state.jetstream
  version: v1
  metadata:
  - name: natsURL
    value: "nats://localhost:4222"
  - name: jwt
    value: "eyJhbGciOiJ...6yJV_adQssw5c" # 可选。用于分布式 JWT 认证
  - name: seedKey
    value: "SUACS34K232O...5Z3POU7BNIL4Y" # 可选。用于分布式 JWT 认证
  - name: bucket
    value: "<bucketName>"

规格元数据字段说明

字段 必需 详情 示例
natsURL 是 NATS 服务器地址 URL “nats://localhost:4222”
jwt 否 用于分布式认证的 NATS JWT “eyJhbGciOiJ...6yJV_adQssw5c”
seedKey 否 用于分布式认证的 NATS 种子密钥 “SUACS34K232O...5Z3POU7BNIL4Y”
bucket 是 JetStream KV 桶名称 "<bucketName>"

创建 NATS 服务器


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

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

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


通过使用 helm 在 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 KV 桶

需要创建一个键值桶，这可以通过 NATS CLI 轻松完成。

nats kv add <bucketName>

相关链接