Go 使用 Redis Stream 实现消息队列时，为什么写入的 int 类型 user_id 在读取后变成了 string 类型？-Golang-PHP中文网

Go 使用 Redis Stream 实现消息队列时，为什么写入的 int 类型 user_id 在读取后变成了 string 类型？

心靈之曲

发布： 2024-11-09 20:24:23

原创

1142人浏览过

go 使用 redis stream 实现消息队列时，为什么写入的 int 类型 user_id 在读取后变成了 string 类型？

关于 go 中使用 redis 的问题

在使用 redis 的 stream 来实现消息队列时，遇到了一个问题，希望有经验的大佬指点一下。

问题：

在插入数据时，user_id 是 int 类型，而在从队列中读取数据时，user_id 却变成了 string 类型。为什么会出现这种情况呢？

解答：

天谱乐

唱鸭旗下AI音乐创作平台，为您提供个性化音乐创作体验！

514

查看详情

redis 中存储的数据实际上都是字符串类型的，即使写入的是数字类型。为了保留数据的类型，可以在写入时对其进行序列化，读取时再反序列化。

解决方案：

最简单的办法是在写入数据时对其进行序列化，例如使用 json 或 msgpack 等格式：

import (
    "encoding/json"

    "github.com/go-redis/redis/v8"
)

func writedata(client *redis.client, key string, userid int) error {
    // 将 userid 序列化为 json 字符串
    data, err := json.marshal(userid)
    if err != nil {
        return err
    }

    return client.xadd(ctx, key, "mystream", data)
}

登录后复制

在读取数据时，可以再将数据反序列化为 int 类型：

import (
    "encoding/json"

    "github.com/go-redis/redis/v8"
)

func ReadData(client *redis.Client, key string) (int, error) {
    // 从队列中读取消息
    messages, err := client.XRead(ctx, &redis.XReadArgs{Streams: []string{key}})
    if err != nil {
        return 0, err
    }

    // 解析消息中的数据
    if len(messages) == 0 || len(messages[0].Messages) == 0 {
        return 0, redis.Nil
    }

    message := messages[0].Messages[0]

    // 将数据反序列化为 int 类型
    var userId int
    if err := json.Unmarshal(message.Values["data"], &userId); err != nil {
        return 0, err
    }

    return userId, nil
}

登录后复制

以上就是Go 使用 Redis Stream 实现消息队列时，为什么写入的 int 类型 user_id 在读取后变成了 string 类型？的详细内容，更多请关注php中文网其它相关文章！