otto_chat_api/redis_connection.go at develop · ottokafka/otto_chat_api · GitHub

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
67
package main

import (
	// This json package allows us to encode string into a json format
	"fmt"

	"github.com/go-redis/redis"
)

// Raspberry pi address
var redisHost = "192.168.0.101:6379"

var RedisClient = redis.NewClient(&redis.Options{
	// Addr:     "10.90.24.205:6379", // TeamCity server
	// Addr:     "localhost:6379", // TeamCity server
	Addr:     redisHost, // TeamCity server
	Password: "",        // no password set
	DB:       0,         // use default DB
})

// fmt.Println("redis connected")

func RedisTest() {
	redis.NewClient(&redis.Options{
		// Addr:     "10.90.24.205:6379", // TeamCity server
		Addr:     redisHost, // TeamCity server
		Password: "",        // no password set
		DB:       0,         // use default DB
	})
	fmt.Println("connected to redis")
}

func ExampleClient() {

	//Save to Redis
	err := RedisClient.Set("myKey", "money", 0).Err()
	if err != nil {
		panic(err)
	}

	// Get from Redis
	val, err := RedisClient.Get("myKey").Result()
	if err != nil {
		panic(err)
	}
	fmt.Println("myKey", val)
}

// err := RedisClient.Set("myKey", "money", 0).Err()
// if err != nil {
// 	panic(err)
// }

// val, err := RedisClient.Get("myKey").Result()
// if err != nil {
// 	panic(err)
// }
// fmt.Println("myKey", val)

// val2, err := RedisClient.Get("key2").Result()
// if err == redis.Nil {
// 	fmt.Println("key2 does not exist")
// } else if err != nil {
// 	panic(err)
// } else {
// 	fmt.Println("key2", val2)
// }