client cannot work when a server node in the cluster died

[aluode99]

I use this client to connect to the cluster. When a server node in the cluster dies, the client cannot be used. However, if a multi-node zk cluster dies one node, the entire cluster can still provide services.

[aluode99]

the code doesn't work as expected. if len(servers) == 0 { return nil, nil, errors.New("zk: server list must not be empty") }

srvs := make([]string, len(servers))

for i, addr := range servers {
	if strings.Contains(addr, ":") {
		srvs[i] = addr
	} else {
		srvs[i] = addr + ":" + strconv.Itoa(DefaultPort)
	}
}

// Randomize the order of the servers to avoid creating hotspots
stringShuffle(srvs)

ec := make(chan Event, eventChanSize)
conn := &Conn{
	dialer:         net.DialTimeout,
	hostProvider:   &DNSHostProvider{},
	conn:           nil,
	state:          StateDisconnected,
	eventChan:      ec,
	shouldQuit:     make(chan struct{}),
	connectTimeout: 1 * time.Second,
	sendChan:       make(chan *request, sendChanSize),
	requests:       make(map[int32]*request),
	watchers:       make(map[watchPathType][]chan Event),
	passwd:         emptyPassword,
	logger:         DefaultLogger,
	logInfo:        true, // default is true for backwards compatability
	buf:            make([]byte, bufferSize),
}

// Set provided options.
for _, option := range options {
	option(conn)
}

if err := conn.hostProvider.Init(srvs); err != nil {
	return nil, nil, err
}

conn.setTimeouts(int32(sessionTimeout / time.Millisecond))

go func() {
	conn.loop()
	conn.flushRequests(ErrClosing)
	conn.invalidateWatches(ErrClosing)
	close(conn.eventChan)
}()
return conn, ec, nil

}

the function stringShuffle has no ecffect.

func stringShuffle(s []string) { for i := len(s) - 1; i > 0; i-- { j := rand.Intn(i + 1) s[i], s[j] = s[j], s[i] } }