我一直在玩 golang 和 redis。我只是建立了一个简单的 http 服务器,想增加 redis 上的请求。我正在炸毁连接(我认为)。我发现使用 redigo 你可以使用连接池,但不确定在我处理请求时如何实现它(你从哪里实例化/调用池)。
错误:无法分配请求的地址。
如有任何建议,我们将不胜感激....我确定我的连接有误,但不确定如何更改。
编辑:根据 pauljz 的建议进行了修改——现在效果很好
var pool redis.Pool
func qryJson(rw http.ResponseWriter, req *http.Request){
incrementRedis()
}
func incrementRedis () {
t := time.Now().Format("2006-01-02 15:04:05")
conn := pool.Get()
defer conn.Close()
if _, err := conn.Do("HINCRBY", "messages", t, 1); err != nil {
log.Fatal(err)
}
}
func main() {
runtime.GOMAXPROCS(runtime.NumCPU())
pool = redis.Pool{
MaxIdle: 50,
MaxActive: 500, // max number of connections
Dial: func() (redis.Conn, error) {
c, err := redis.Dial("tcp", ":6379")
if err != nil {
panic(err.Error())
}
return c, err
},
}
http.HandleFunc("/testqry", qryJson)
log.Fatal(http.ListenAndServe(":8082", nil))
}
最佳答案
redigo 文档有一个很好的连接池入门示例:http://godoc.org/github.com/garyburd/redigo/redis#Pool
在您的情况下,您的包中会有一个 var pool redis.Pool
(即不在函数内部)。
在 main()
中,在调用 ListenAndServe
之前,您将从 redigo 调用 pool = redis.Pool{ ... }
初始化池的示例。
在 incrementRedis()
中你会做类似的事情:
func incrementRedis () {
conn := pool.Get()
defer conn.Close()
if _, err := conn.Do("HINCRBY", "messages", t, 1); err != nil {
log.Fatal(err)
}
}
关于Golang 递增数据到 Redis,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/22004880/