主页 / coding / 问题 / 79562158
Accepted
vbulash
Asked: 2025-04-08 21:18:59 +0800 CST

Redigo：XADD 的错误论点

  • 772

我喜欢 Redis 流，因为它可以充当物联网数据库。向流中添加数据的主要 Redis 命令是 XADD：

XADD log * name Some_name_to_write text Some_text_to_write

它运行良好。

然后我尝试使用Redigo执行相同的操作：

type LogEntry struct {
    Name string `json:"name"`
    Text string `json:"text"`
}

func (l *LogEntry) Push() error {
    var args []string // XADD arguments

    log.Printf("Log Entry: %+v\n", l)
    args = make([]string, 6)
    args = append(args, "log") // Stream key
    args = append(args, "*")   // Auto-generated stream ID
    args = append(args, "name", l.Name)
    args = append(args, "text", l.Text)
    log.Printf("Args for XADD: %+v\n", args)

    new := make([]any, len(args))
    for index, value := range args {
        new[index] = value
    }

    _, err := connection.Do("XADD", new...)
    if err != nil {
        log.Println("XADD error", err)
        return err
    }

    return nil
}

connection这里是redis.Conn。

此代码产生以下输出：

2025-04-08 16:03:08 2025/04/08 13:03:08 Log Entry: &{Name:Some_name_to_write Text:Some_text_to_write}
2025-04-08 16:03:08 2025/04/08 13:03:08 Args for XADD: [      log * name Some_name_to_write text Some_text_to_write]
2025-04-08 16:03:08 2025/04/08 13:03:08 XADD error ERR Invalid stream ID specified as stream command argument

因此，我看到的参数与conn.Do我之前在 CLI 中使用的完全相同。

这里出了什么问题？

go

1 个回答

  1. Best Answer

    问题就在这里

    args = make([]string, 6)

    您正在创建一个长度为 6 的字符串切片，但当您对其调用 append 时，它会向切片中添加新项。这意味着您的切片现在的长度为 12，而不是 6。（它开头有 6 个空字符串，而不是 redis 命令）。

    因此，要么只用 0 调用 make（或者只删除该行，它会执行相同的操作，因为变量已经事先声明过）

    args = make([]string, 0)
    • 1

相关问题