jetstream是nats的持久层，不仅提供高可靠的消息服务，还对外提供了一套分布式K/V存储系统。

Bucket Key Value

提供put、get、delete、purge、create、update、keys基础操作。

TTL

其他增强功能

Watch

Watch all

History

golang sdk的使用

func main() {
  nc, _ := nats.Connect("localhost:4222")
  defer nc.Close()
  js, _ := nc.JetStream()

  // 创建bucket
  kv, err := js.CreateKeyValue(&nats.KeyValueConfig{
    Bucket: "mybkt",
  })

  if err != nil {
    log.Println(err)
    return
  }

  // 读写数据
  kv.Put("orderNo", []byte("1000101"))

  enty, _ := kv.Get("orderNo")
  fmt.Println(string(enty.Value()))
}

上一篇 « 下一篇 »