今天要進入到,web屆,講到快取一定會提到的 redis 。 redis 真的是一種通用武器,不管你後端用什麼語言,還真沒看過沒人不會用 redis ,那當然我們就要介紹一下 redis 的基礎使用。
這個套件,是我從寫 go 以來,只要是用碰到 redis 的相關應用,我一定會使用的第三方套件,它的主要維護者 Gary Burd,也是我前幾天介紹的 gorilla/mux的 gorilla 團隊另一個套件 gorilla/websocket 主要貢獻者,這個套件後面章節會介紹,我們接下來介紹他的基礎使用方式。
func main() {
pool := &redis.Pool{
// 連線的 callback 定義
Dial: func() (redis.Conn, error) {
//建構一條連線
c, err := redis.Dial("tcp", server)
if err != nil {
return nil, err
}
//在這邊可以做連線池初始化 選擇 redis db的動作
if _, err := c.Do("SELECT", db); err != nil {
c.Close()
return nil, err
}
return c, nil
},
//定期對 redis server 做 ping/pong 測試
TestOnBorrow: func(c redis.Conn, t time.Time) error {
if time.Since(t) < time.Minute {
return nil
}
_, err := c.Do("PING")
return err
},
}
}
func main() {
pool := &redis.Pool{
// 連線的 callback 定義
Dial: func() (redis.Conn, error) {
//建構一條連線
c, err := redis.Dial("tcp", server)
if err != nil {
return nil, err
}
//在這邊可以做連線池初始化 選擇 redis db的動作
if _, err := c.Do("SELECT", db); err != nil {
c.Close()
return nil, err
}
return c, nil
},
//定期對 redis server 做 ping/pong 測試
TestOnBorrow: func(c redis.Conn, t time.Time) error {
if time.Since(t) < time.Minute {
return nil
}
_, err := c.Do("PING")
return err
},
}
//這邊要非常注意,redis用完連線,請一定要做close的動作,否則有機會造成 memory leak
// close完的連線,會回到 connection pool
conn := pool.Get()
defer conn.Close()
var value1 int
var value2 string
//這是package 提供的 helper
reply, err := redis.Values(conn.Do("MGET", "key1", "key2"))
if err != nil {
// handle error
}
//這是package提供的helper 幫助可以scan 相關數值
if _, err := redis.Scan(reply, &value1, &value2); err != nil {
// handle error
}
}
上面範例只有一個重點,請大家多多使用 redigo 提供的 connection pool,可以幫助你控管連線,而且也要記得每次使用完 conn ,也都要記得做 close,釋放連線。
在 redis 裡面,如果善用這個功能,就可以做到 event trigger 這個模式,而不是透過傳統輪詢的方式,來關注你的服務狀態是否已經改變。後面章節,會有一篇分享,我運用 redis 在架構面的設計。
func main() {
pool := &redis.Pool{
// 連線的 callback 定義
Dial: func() (redis.Conn, error) {
//建構一條連線
c, err := redis.Dial("tcp", server)
if err != nil {
return nil, err
}
//在這邊可以做連線池初始化 選擇 redis db的動作
if _, err := c.Do("SELECT", db); err != nil {
c.Close()
return nil, err
}
return c, nil
},
//定期對 redis server 做 ping/pong 測試
TestOnBorrow: func(c redis.Conn, t time.Time) error {
if time.Since(t) < time.Minute {
return nil
}
_, err := c.Do("PING")
return err
},
}
//這邊要非常注意,redis用完連線,請一定要做close的動作,否則有機會造成 memory leak
// close完的連線,會回到 connection pool
conn := pool.Get()
defer conn.Close()
//這邊運用 pub/sub helper
psc := redis.PubSubConn{Conn: conn}
psc.Subscribe("example")
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
}
}
}
這邊只是做基礎的 redis 應用介紹,需要更多說明,請到官方文件