1初始化:
rdb = redis.NewClient(&redis.Options{ Addr: "localhost:6379", Password: "", // no password set DB: 0, // use default DB }) _, err := rdb.Ping().Result() if err != nil { fmt.Println("链接redis数据库出错") }
2:set get方法
err := rdb.Set(key, val, time.Second*10).Err() if err != nil { fmt.Println("设置缓存出错", err) }
name, _ := rdb.Get(key).Result()
3:链接Redis集群
rdb := redis.NewClusterClient(&redis.ClusterOptions{ Addrs: []string{":7000", ":7001", ":7002", ":7003", ":7004", ":7005"}, }) _, err = rdb.Ping().Result() if err != nil { return err } return nil
4:哨兵模式
rdb := redis.NewFailoverClient(&redis.FailoverOptions{ MasterName: "master", SentinelAddrs: []string{"x.x.x.x:26379", "xx.xx.xx.xx:26379", "xxx.xxx.xxx.xxx:26379"}, }) _, err = rdb.Ping().Result() if err != nil { return err } return nil