I can't connect Redis cluster

[soulshuangchen]

I use this code to create cluster, but it has a problem:

cluster, err := clust.NewCluster(
		&clust.Options{
			StartNodes:   []string{"10.151.3.24:6379", "10.151.3.24:6383", "10.151.3.24:6381"},
			ConnTimeout:  5 * time.Second,
			ReadTimeout:  5 * time.Second,
			WriteTimeout: 5 * time.Second,
			KeepAlive:    16,
			AliveTime:    60 * time.Second,
		})

NewCluster: no valid node in [10.151.3.24:6379 10.151.3.24:6383 10.151.3.24:6381]

but when I use "github.com/gomodule/redigo/redis" to create Redis.conn it was worked.
this is codes:

var RedisPool *redis.Pool
var ip = "10.151.3.24:6381"
func NewRedisPool(ip string) *redis.Pool {
	return &redis.Pool{
		MaxIdle:     6,
		IdleTimeout: 240 * time.Second,
		Dial: func() (redis.Conn, error) {
			c, err := redis.Dial("tcp", ip)
			if err != nil {
				return nil, err
			}
			return c, nil
		},
		TestOnBorrow: func(c redis.Conn, t time.Time) error {
			if time.Since(t) < time.Minute {
				return nil
			}
			_, err := c.Do("PING")
			return err
		},
	}
}
RedisPool = NewRedisPool(ip)
redisConn := RedisPool.Get()
defer redisConn.Close()

redisConn.Do("AUTH", "123456")
reply, err := redisConn.Do("set", "demo_key", "666")

I don't know what cause this problem. What Redis cluster need? I use Virtualmachine+Docker to create Redis cluster.What should I do to handle this problem. Please help me.Thanks

[LicaSterian]

I get the same error:
NewCluster: no valid node in [localhost:6379]
Also tried connecting to redis with github.com/garyburd/redigo/redis and it works just fine, Dial, PING, SET, GET commands are working just fine.
I'm just unable to get it working with this repo.

[sxpujs]

Redis version: 5.0.7

I got the similar error:

panic: runtime error: invalid memory address or nil pointer dereference
[signal SIGSEGV: segmentation violation code=0x1 addr=0x0 pc=0x10ef11a]

goroutine 1 [running]:
github.com/chasex/redis-go-cluster.(*redisConn).shutdown(...)
        /Users/hao/codes/go/pkg/mod/github.com/chasex/redis-go-cluster@v1.0.0/node.go:146
github.com/chasex/redis-go-cluster.(*redisNode).do(0xc0000ad200, 0x113f0d1, 0x3, 0xc00000e1c0, 0x2, 0x2, 0x20, 0x20, 0xc00000e1c0, 0xc0000b5e80)
        /Users/hao/codes/go/pkg/mod/github.com/chasex/redis-go-cluster@v1.0.0/node.go:192 +0x23a
github.com/chasex/redis-go-cluster.(*redisCluster).Do(0xc0000aa000, 0x113f0d1, 0x3, 0xc00000e1c0, 0x2, 0x2, 0xc000053f90, 0xc00009a000, 0xc000053ef0, 0x10ee196)
        /Users/hao/codes/go/pkg/mod/github.com/chasex/redis-go-cluster@v1.0.0/cluster.go:254 +0x20f
main.main()
        /Users/hao/codes/go/src/github.com/sxpujs/go-example/redis/redis_cluster.go:24 +0x211

Process finished with exit code 2

source code:

package main

import (
	"fmt"
	"github.com/chasex/redis-go-cluster"
	"os"
	"time"
)

func main() {
	cluster, err := redis.NewCluster(
		&redis.Options{
			StartNodes: []string{"127.0.0.1:30001", "127.0.0.1:30002", "127.0.0.1:30003"},
			ConnTimeout: 500 * time.Millisecond,
			ReadTimeout: 500 * time.Millisecond,
			WriteTimeout: 500 * time.Millisecond,
			KeepAlive: 16,
			AliveTime: 60 * time.Second,
		})
	if err != nil {
		fmt.Println("err=", err)
		os.Exit(1)
	}
	cluster.Do("SET", "foo", "bar")
	cluster.Do("INCR", "mycount", 1)
	cluster.Do("LPUSH", "mylist", "foo", "bar")
	cluster.Do("HMSET", "myhash", "f1", "foo", "f2", "bar")
}

redis-server cluster is running normally.

> c ps -ef|grep redis
  501 40677     1   0 10:38下午 ??         0:28.61 ../../src/redis-server *:30001 [cluster]
  501 40679     1   0 10:38下午 ??         0:28.79 ../../src/redis-server *:30002 [cluster]
  501 40681     1   0 10:38下午 ??         0:28.72 ../../src/redis-server *:30003 [cluster]
  501 40683     1   0 10:38下午 ??         0:28.44 ../../src/redis-server *:30004 [cluster]
  501 40685     1   0 10:38下午 ??         0:28.47 ../../src/redis-server *:30005 [cluster]
  501 40687     1   0 10:38下午 ??         0:28.26 ../../src/redis-server *:30006 [cluster]

[liqing455]

this problem caused by errcode "ECONNTIMEOUT", you should close cluster conn after use cluster
defer cluster.Close()