Function RedisClient

pac/redis_connect.go:20–39

RedisClient 连接 Redis

(pwd string)

// RedisClient 连接 Redis
func RedisClient(pwd string) (err error) {

	Rdb = redis.NewClient(&redis.Options{
		Addr:     fmt.Sprintf("%s:%s", Rhost, Rport),
		Password: pwd, // 密码认证
	})

	ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)

	defer cancel()

	pong, err := Rdb.Ping(ctx).Result()
	if err != nil {
		return err
	}
	if strings.Contains(pong, "PONG") {
		redisVersion()
	}
	return nil
}

var wg sync.WaitGroup