如何在Redlang（redigo）Pubsub中更好地編寫Golang中的Receive（）？

Question

psc := redis.PubSubConn{c} 
psc.Subscribe("example") 

func Receive() { 
    for { 
     switch v := psc.Receive().(type) { 
     case redis.Message: 
      fmt.Printf("%s: message: %s\n", v.Channel, v.Data) 
     case redis.Subscription: 
      fmt.Printf("%s: %s %d\n", v.Channel, v.Kind, v.Count) 
     case error: 
      return v 
     } 
    } 
} 

在上面的代碼中（取自Redigo doc），如果連接丟失，所有訂閱也會丟失。什麼是更好的方式來恢復丟失的連接和重新訂閱。

Answer 1

使用兩個嵌套循環。外部循環獲取連接，設置訂閱，然後調用內部循環接收消息。執行內部循環，直到連接出現永久性錯誤。

for { 
    // Get a connection from a pool 
    c := pool.Get() 
    psc := redis.PubSubConn{c} 

    // Set up subscriptions 
    psc.Subscribe("example")) 

    // While not a permanent error on the connection. 
    for c.Err() == nil { 
     switch v := psc.Receive().(type) { 
     case redis.Message: 
      fmt.Printf("%s: message: %s\n", v.Channel, v.Data) 
     case redis.Subscription: 
      fmt.Printf("%s: %s %d\n", v.Channel, v.Kind, v.Count) 
     case error: 
      fmt.Printf(err) 
     } 
    } 
    c.Close() 
} 

本示例使用Redigo pool來獲取連接。另一種方法是直接撥號連接：

c, err := redis.Dial("tcp", serverAddress)