conn.flush() 不会刷新所有记录到redis

Question

这是代码

 func main() {
   ...
   pool := createPool(*redis_server, *redis_pass)
   defer pool.Close()
   c := pool.Get() 
   var i int64
   st := tickSec()
   for i = 0; i < *total; i++ {
      r := time.Now().Unix() - rand.Int63n(60*60*24*31*12)
      score, _ := strconv.Atoi(time.Unix(r, 0).Format("2006010215"))
      id := utee.PlainMd5(uuid.NewUUID().String())
      c.Send("ZADD", "app_a_5512", score, id)
      if i%10000 == 0 {
          c.Flush()
          log.Println("current sync to redis", i)
      }
  }
  //c.Flush()
  c.Close()
  ...
}

如果我使用 c.Close()，总集合 100000，真正的排序集合计数 100000。但是如果我使用c.Flush()，总数也设置为100000，真正的sortedset计数小于100000(96932)；如果我在主函数的末尾使用time.Sleep()，总数是还有100000

当main func退出时，flush func没有完成？为什么？谢谢！

Answer 1

循环后调用 Close() 时程序运行的原因是池连接的 Close() 方法读取并丢弃所有未决响应。

应用程序应该 Receive 所有命令的响应，而不是让响应备份并消耗服务器上的内存。无需在循环中刷新。

go func() {
  for i = 0; i < *total; i++ {
     r := time.Now().Unix() - rand.Int63n(60*60*24*31*12)
     score, _ := strconv.Atoi(time.Unix(r, 0).Format("2006010215"))
     id := utee.PlainMd5(uuid.NewUUID().String())
     c.Send("ZADD", "app_a_5512", score, id)
  }
  c.Flush()
}

for i = 0; i < *total; i++ {
   c.Receive()
}
c.Close()

此外，应用程序应检查并处理来自发送、刷新和接收的错误 returns。

conn.flush() 不会刷新所有记录到redis

conn.flush() will not flush all record to redis

go

redigo