forked from wuxibin89/redis-go-cluster
-
Notifications
You must be signed in to change notification settings - Fork 0
/
example1.go
66 lines (56 loc) · 1.4 KB
/
example1.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
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
package main
import (
"fmt"
"log"
"strconv"
"time"
"github.com/MoSunDay/redis-go-cluster"
)
const kNumOfRoutine = 50
func main() {
cluster, err := redis.NewCluster(
&redis.Options{
StartNodes: []string{"10.168.66.193:7001", "10.168.66.193:7000", "10.168.66.187: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())
}
chann := make(chan int, kNumOfRoutine)
for i := 0; i < kNumOfRoutine; i++ {
go redisTest(cluster, i*100000, (i+1)*100000, chann)
}
for i := 0; i < kNumOfRoutine; i++ {
_ = <-chann
}
}
func redisTest(cluster *redis.Cluster, begin, end int, done chan int) {
prefix := "mykey"
for i := begin; i < end; i++ {
key := prefix + strconv.Itoa(i)
_, err := cluster.Do("set", key, i*10)
if err != nil {
fmt.Printf("-set %s: %s\n", key, err.Error())
time.Sleep(100 * time.Millisecond)
continue
}
value, err := redis.Int(cluster.Do("GET", key))
if err != nil {
fmt.Printf("-get %s: %s\n", key, err.Error())
time.Sleep(100 * time.Millisecond)
continue
}
if value != i*10 {
fmt.Printf("-mismatch %s: %d\n", key, value)
time.Sleep(100 * time.Millisecond)
continue
}
fmt.Printf("+set %s\n", key)
time.Sleep(50 * time.Millisecond)
}
done <- 1
}