GO redis连接池DEMO

158670阅读 0评论2019-09-16 nuoyazhou110
分类:Web开发


点击(此处)折叠或打开

  1. package main

  2. import (
  3.     "fmt"
  4.     "github.com/gomodule/redigo/redis"
  5. )
  6. var pool *redis.Pool


  7. func newPool(addr string) *redis.Pool {
  8.     return &redis.Pool{
  9.         MaxIdle: 10,
  10.         IdleTimeout: 240 * time.Second,
  11.         // Dial or DialContext must be set. When both are set, DialContext takes precedence over Dial.
  12.         Dial: func () (redis.Conn, error) {
  13.             return redis.Dial("tcp", addr)
  14.         },
  15.     }
  16. }
  17. func set() {
  18.     conn := pool.Get()
  19.     defer conn.Close()
  20.     err := conn.Send("SET","key1","aaaaaaaaaaaa")
  21.     if err != nil {
  22.         fmt.Println(err.Error())
  23.     }
  24. }
  25. func get() {
  26.     conn := pool.Get()
  27.     defer conn.Close()
  28.     str,err := redis.String(conn.Do("GET","key1"))
  29.     if err != nil {
  30.         fmt.Println(err)
  31.     }
  32.     fmt.Println(str)
  33. }
  34. func main() {
  35.     pool = newPool("192.168.99.100:6379")
  36.     set()
  37.     get()
  38. }

上一篇:go简单聊天室
下一篇:python3.4中asyncio