连接关闭问题

[gaofeixiang2014]

时间久了，发现pool 中的链接closed了，出现了error，不能正常使用。源码中没有做链接有效性的验证，并且一个zk 只创建了一个链接。

我修改了Dial 函数 返回一个*redis.Pool ，实现方式是用的redisgo。并修改了Get 方法，先得到一个zk的redis.Pool，再用redisgo中的Get方法得到链接。发现没有出现链接无效的问题。有个遗憾就是没有把所有zk的链接放在一个pool中。不知道大神有什么其他好的方法，望相告

[gaofeixiang2014]

相关代码：

func InitRedisPool(host string) (*redis.Pool) {
	return  &redis.Pool{
		MaxIdle:128,
		MaxActive:300,
		IdleTimeout: 180 * time.Second,
		Dial: func() (redis.Conn, error) {
			c,err:=redis.Dial("tcp",host)
			if err != nil {
				return nil,err
			}
			return c, nil
		},
	}
}



func (this *Pool) Get() redis.Conn {
    mu.Lock()
    if len(this.pools) == 0 {
        this.initFromZk()
    }
    this.nextIdx += 1
    if this.nextIdx >= len(this.pools) {
        this.nextIdx = 0
    }
    if len(this.pools) == 0 {
        mu.Unlock()
        err := errors.New("Proxy list empty")
        Log.Error(err)
        return errorConnection{err: err}
    } else {
        //c := this.pools[this.nextIdx]
        pool := this.pools[this.nextIdx]
        mu.Unlock()
        return pool.Get()
    }
}

[tranch]

这块还有待补充，需要一个类似 Jedis 的 adaptor 来将从 codis 中获取到连接交给 redigo 的连接池来管理。

[snailshen2014]

@gaofeixiang2014 ,有相关代码代码吗？我也用这个组件，发现连接在goroute里同一个连接会有问题