forked from wuxibin89/redis-go-cluster
-
Notifications
You must be signed in to change notification settings - Fork 0
/
example3.go
39 lines (32 loc) · 923 Bytes
/
example3.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
package main
import (
"log"
"fmt"
"time"
"github.com/chasex/redis-go-cluster"
)
func main() {
cluster, err := redis.NewCluster(
&redis.Options{
StartNodes: []string{"127.0.0.1:7000", "127.0.0.1:7001", "127.0.0.1:7002"},
ConnTimeout: 50 * time.Millisecond,
ReadTimeout: 50 * time.Millisecond,
WriteTimeout: 50 * time.Millisecond,
KeepAlive: 16,
AliveTime: 60 * time.Second,
})
if err != nil {
log.Fatalf("redis.New error: %s", err.Error())
}
_, err = cluster.Do("MSET", "myfoo1", "mybar1", "myfoo2", "mybar2", "myfoo3", "mybar3")
if err != nil {
log.Fatalf("MSET error: %s", err.Error())
}
values, err := redis.Strings(cluster.Do("MGET", "myfoo1", "myfoo5", "myfoo2", "myfoo3", "myfoo4"))
if err != nil {
log.Fatalf("MGET error: %s", err.Error())
}
for i := range values {
fmt.Printf("reply[%d]: %s\n", i, values[i])
}
}