分享
[笔记]使用Go语言Redigo包在Docker容器内连接Redis容器的方法
journeyonmyway · · 3832 次点击 · · 开始浏览这是一个创建于 的文章,其中的信息可能已经有所发展或是发生改变。
Docker容器之间的连接可以带来不少方便,下面记录下如何在自己容器内通过环境变量连接与之连接的Redis容器的方法。
先起一个Redis的Docker容器,命名为 redis,再起一个自己的Docker容器,使用"--link redis:redis"方式与redis容器连接。
在自己的容器内部,会有对应的环境变量,其中这里用的就是 REDIS_PORT = tcp://172.17.0.89:6379。
将其分拆为 tcp 和 172.17.0.89:6379,作为参数传入redigo的Dial函数即可,如此可不必显式的写IP和端口地址。
顺便说一句,redigo是Go语言的Redis客户端实现。
参考代码如下:
package main import ( "fmt" "github.com/garyburd/redigo/redis" "os" "strings" "time" ) func testRedis() bool { // e.g. REDIS_PORT = tcp://172.17.0.89:6379 fmt.Println("REDIS_PORT", os.Getenv("REDIS_PORT")) addr := strings.Split(os.Getenv("REDIS_PORT"), "://") conn, err := redis.DialTimeout(addr[0], addr[1], 0, 1*time.Second, 1*time.Second) if err != nil { fmt.Println(err) return false } defer conn.Close() size, err := conn.Do("DBSIZE") if err != nil { fmt.Println(err) return false } fmt.Printf("DB size is %d \n", size) _, err = conn.Do("SET", "user:user0", 123) _, err = conn.Do("SET", "user:user1", 456) _, err = conn.Do("APPEND", "user:user0", 87) user0, err := redis.Int(conn.Do("GET", "user:user0")) user1, err := redis.Int(conn.Do("GET", "user:user1")) fmt.Printf("user0 is %d , user1 is %d \n", user0, user1) return true } func main() { fmt.Println(time.Now(), "[Redis test start]") if testRedis() { fmt.Println("[Redis test ok]") } else { fmt.Println("[Redis test failed]") } }
如果连接成功,结果如下:
2015-03-12 12:16:44.796537101 +0000 UTC [Redis test start] REDIS_PORT tcp://172.17.0.89:6379 DB size is 2 user0 is 12387 , user1 is 456 [Redis test ok]
有疑问加站长微信联系(非本文作者)
入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:692541889
关注微信3832 次点击
添加一条新回复
(您需要 后才能回复 没有账号 ?)
- 请尽量让自己的回复能够对别人有帮助
- 支持 Markdown 格式, **粗体**、~~删除线~~、
`单行代码` - 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
- 图片支持拖拽、截图粘贴等方式上传
收入到我管理的专栏 新建专栏
Docker容器之间的连接可以带来不少方便,下面记录下如何在自己容器内通过环境变量连接与之连接的Redis容器的方法。
先起一个Redis的Docker容器,命名为 redis,再起一个自己的Docker容器,使用"--link redis:redis"方式与redis容器连接。
在自己的容器内部,会有对应的环境变量,其中这里用的就是 REDIS_PORT = tcp://172.17.0.89:6379。
将其分拆为 tcp 和 172.17.0.89:6379,作为参数传入redigo的Dial函数即可,如此可不必显式的写IP和端口地址。
顺便说一句,redigo是Go语言的Redis客户端实现。
参考代码如下:
package main import ( "fmt" "github.com/garyburd/redigo/redis" "os" "strings" "time" ) func testRedis() bool { // e.g. REDIS_PORT = tcp://172.17.0.89:6379 fmt.Println("REDIS_PORT", os.Getenv("REDIS_PORT")) addr := strings.Split(os.Getenv("REDIS_PORT"), "://") conn, err := redis.DialTimeout(addr[0], addr[1], 0, 1*time.Second, 1*time.Second) if err != nil { fmt.Println(err) return false } defer conn.Close() size, err := conn.Do("DBSIZE") if err != nil { fmt.Println(err) return false } fmt.Printf("DB size is %d \n", size) _, err = conn.Do("SET", "user:user0", 123) _, err = conn.Do("SET", "user:user1", 456) _, err = conn.Do("APPEND", "user:user0", 87) user0, err := redis.Int(conn.Do("GET", "user:user0")) user1, err := redis.Int(conn.Do("GET", "user:user1")) fmt.Printf("user0 is %d , user1 is %d \n", user0, user1) return true } func main() { fmt.Println(time.Now(), "[Redis test start]") if testRedis() { fmt.Println("[Redis test ok]") } else { fmt.Println("[Redis test failed]") } }
如果连接成功,结果如下:
2015-03-12 12:16:44.796537101 +0000 UTC [Redis test start] REDIS_PORT tcp://172.17.0.89:6379 DB size is 2 user0 is 12387 , user1 is 456 [Redis test ok]