跨 Redis 数据结构自动执行命令

在 Redis 中执行命令时，可以使用 watch 功能实现事务性操作，保证操作的原子性。不过，对于不涉及修改键值的操作，如 hdel、sadd、hset 等，使用 watch 可能过于繁琐。这时，可以使用 txpipelined 功能将这些命令封装在一起，虽然不能保证原子性，但可以提高操作效率。

我想自动执行一些redis命令（hdel、sadd、hset等）。我在 go-redis 中看到 watch 功能来实现事务，但是由于我不打算修改键的值，即使用 set、get 等，因此使用 watch 将其作为事务执行或只是包装是否有意义txpipeline 中的命令就足够了吗？

方法一：使用手表

func sampletransaction() error{
    transactionfunc := func(tx *redis.tx) error {
        // get the current value or zero.

        _, err := tx.txpipelined(context.background(), func(pipe redis.pipeliner) error {
            _, err := tx.sadd(context.background(), "redis-set-key", "value1").result()
            if err != nil {
                return err
            }

            _, deleteerr := tx.hdel(context.background(), "redis-hash-key", "value1").result()
            if deleteerr != nil {
                return deleteerr
            }
            return nil
        })
        return err
    }

retries:=10
    // retry if the key has been changed.
    for i := 0; i < retries; i++ {
        fmt.println("tries", i)
        err := redisclient.watch(context.background(), transactionfunc())
        if err == nil {
            // success.
            return nil
        }
        if err == redis.txfailederr {
            continue
        }
        return err
    }
}

方法 2：仅封装在 txpipelined 中

func sampleTransaction() error {
 _, err:= tx.TxPipelined(context.Background(), func(pipe redis.Pipeliner) error {
            _, Err := tx.SAdd(context.Background(), "redis-set-key", "value1").Result()
            if Err != nil {
                return Err
            }

            _, deleteErr := tx.HDel(context.Background(), "redis-hash-key", "value1").Result()
            if deleteErr != nil {
                return deleteErr
            }
            return nil
        })
return err
}

正确答案

据我所知，管道不能保证原子性。如果需要原子性，请使用lua。 https://pkg.go.dev/github.com/mediocregopher/radix.v3#NewEvalScript

今天关于《跨 Redis 数据结构自动执行命令》的内容就介绍到这里了，是不是学起来一目了然！想要了解更多关于的内容请关注golang学习网公众号！