使用Go语言操作Redis Stream时,如何解决写入int类型数据却读取到string类型的问题?

使用go语言操作redis stream时,如何解决写入int类型数据却读取到string类型的问题?

redis写入数据类型转换问题

对于使用go语言与redis交互时,在使用stream作为消息队列时,可能会遇到问题:写入int类型的user_id,在读取时却变成string类型。

原因分析

redis中,存储的数据通常都是字符串类型的,即使写入的是数字类型。因此,当你写入int类型的user_id时,redis会将其自动转换为字符串。

立即学习“go语言免费学习笔记(深入)”;

解决方案

为了保留数据的类型,可以使用以下方法:

  • 写入时序列化: 在写入之前,将int类型的值序列化为字符串,例如使用json.marshal。
  • 读取时反序列化: 在读取时,将字符串值反序列化为int类型,例如使用json.unmarshal。

以下示例展示了如何序列化和反序列化数据:

import (
    "encoding/json"
    "fmt"
)

func main() {
    // 序列化int类型为字符串
    id := 1234
    jsonStr, err := json.Marshal(id)
    if err != nil {
        fmt.Println(err)
        return
    }

    // 存储数据到Redis
    err = client.XAdd("my-stream", "my-key", jsonStr)
    if err != nil {
        fmt.Println(err)
        return
    }

    // 从Redis中读取数据
    resp, err := client.XRange("my-stream", "-", "+", 1)
    if err != nil {
        fmt.Println(err)
        return
    }

    // 反序列化字符串为int类型
    var decodedId int
    err = json.Unmarshal(resp[0].Values["user_id"].(string), &decodedId)
    if err != nil {
        fmt.Println(err)
        return
    }

    fmt.Println("Decoded user_id:", decodedId)
}

以上就是使用Go语言操作Redis Stream时,如何解决写入int类型数据却读取到string类型的问题?的详细内容,更多请关注其它相关文章!