cacheKey := r.CacheKey(req.Id) err = r.data.setCache(ctx, cacheKey, result) if err != nil { _ = tx.Rollback() return nil, biz.ErrRecordAlreadyExists } // 执行事务 err = tx.Commit() if err != nil { // 事务回滚 _ = tx.Rollback() return nil, biz.ErrRecordAlreadyExists } return r.composes(result, err)创建缓存并使用RPUSH方法把添加到缓存的数据加到队列尾部 就在我现在的代码里改
时间: 2024-04-15 07:27:39 浏览: 108
使用Promise封装wx.request wx.setStorage封装,实现设置过期时间
根据你的代码,你想在创建缓存并提交事务后,将添加到缓存的数据使用RPUSH方法加到队列尾部。以下是一个修改后的代码示例:
```go
cacheKey := r.CacheKey(req.Id)
err = r.data.setCache(ctx, cacheKey, result)
if err != nil {
_ = tx.Rollback()
return nil, biz.ErrRecordAlreadyExists
***
阅读全文