{"id":3171,"date":"2019-04-19T19:49:29","date_gmt":"2019-04-19T11:49:29","guid":{"rendered":"https:\/\/damogame.cn\/wordpress\/?p=3171"},"modified":"2019-04-19T19:49:29","modified_gmt":"2019-04-19T11:49:29","slug":"golang-redis%e8%bf%9e%e6%8e%a5%e6%b1%a0%e7%9a%84%e4%bd%bf%e7%94%a8","status":"publish","type":"post","link":"https:\/\/i007.cc\/wordpress\/archives\/3171","title":{"rendered":"golang redis\u8fde\u63a5\u6c60\u7684\u4f7f\u7528"},"content":{"rendered":"
\n

\u539f\u5e16\u5730\u5740<\/a><\/p>\n

\n

<\/small><\/div>\n

\n
\n
package<\/span> main\r\n\r\nimport<\/span> (<\/span>\r\n    \"encoding\/json\"<\/span>\r\n    \"errors\"<\/span>\r\n    \"fmt\"<\/span>\r\n    \"time\"<\/span>\r\n\r\n    \"github.com\/garyburd\/redigo\/redis\"<\/span>\r\n)<\/span>\r\n\r\nconst<\/span> (<\/span>\r\n    RedisURL            =<\/span> \"redis:\/\/*****:6379\"<\/span>\r\n    redisMaxIdle        =<\/span> 3<\/span>   \/\/\u6700\u5927\u7a7a\u95f2\u8fde\u63a5\u6570<\/span>\r\n    redisIdleTimeoutSec =<\/span> 240<\/span> \/\/\u6700\u5927\u7a7a\u95f2\u8fde\u63a5\u65f6\u95f4<\/span>\r\n    RedisPassword       =<\/span> \"*****\"<\/span>\r\n)<\/span>\r\n\r\n\/\/ NewRedisPool \u8fd4\u56deredis\u8fde\u63a5\u6c60<\/span>\r\nfunc<\/span> NewRedisPool(<\/span><\/span>redisURL string<\/span>)<\/span> *<\/span>redis.<\/span>Pool {<\/span>\r\n    return<\/span> &<\/span>redis.<\/span>Pool{<\/span>\r\n        MaxIdle:<\/span>     redisMaxIdle,<\/span>\r\n        IdleTimeout:<\/span> redisIdleTimeoutSec *<\/span> time.<\/span>Second,<\/span>\r\n        Dial:<\/span> func<\/span>(<\/span>)<\/span> (<\/span>redis.<\/span>Conn,<\/span> error<\/span>)<\/span> {<\/span>\r\n            c,<\/span> err :=<\/span> redis.<\/span>DialURL(<\/span><\/span>redisURL)<\/span>\r\n            if<\/span> err !=<\/span> nil<\/span> {<\/span>\r\n                return<\/span> nil<\/span>,<\/span> fmt.<\/span>Errorf(<\/span><\/span>\"redis connection error: %s\"<\/span>,<\/span> err)<\/span>\r\n            }<\/span>\r\n            \/\/\u9a8c\u8bc1redis\u5bc6\u7801<\/span>\r\n            if<\/span> _<\/span>,<\/span> authErr :=<\/span> c.<\/span>Do(<\/span><\/span>\"AUTH\"<\/span>,<\/span> RedisPassword)<\/span>;<\/span> authErr !=<\/span> nil<\/span> {<\/span>\r\n                return<\/span> nil<\/span>,<\/span> fmt.<\/span>Errorf(<\/span><\/span>\"redis auth password error: %s\"<\/span>,<\/span> authErr)<\/span>\r\n            }<\/span>\r\n            return<\/span> c,<\/span> err\r\n        }<\/span>,<\/span>\r\n        TestOnBorrow:<\/span> func<\/span>(<\/span>c redis.<\/span>Conn,<\/span> t time.<\/span>Time)<\/span> error<\/span> {<\/span>\r\n            _<\/span>,<\/span> err :=<\/span> c.<\/span>Do(<\/span><\/span>\"PING\"<\/span>)<\/span>\r\n            if<\/span> err !=<\/span> nil<\/span> {<\/span>\r\n                return<\/span> fmt.<\/span>Errorf(<\/span><\/span>\"ping redis error: %s\"<\/span>,<\/span> err)<\/span>\r\n            }<\/span>\r\n            return<\/span> nil<\/span>\r\n        }<\/span>,<\/span>\r\n    }<\/span>\r\n}<\/span>\r\n\r\nfunc<\/span> set(<\/span><\/span>k,<\/span> v string<\/span>)<\/span> {<\/span>\r\n    c :=<\/span> NewRedisPool(<\/span><\/span>RedisURL)<\/span>.<\/span>Get(<\/span><\/span>)<\/span>\r\n    defer<\/span> c.<\/span>Close(<\/span><\/span>)<\/span>\r\n    _<\/span>,<\/span> err :=<\/span> c.<\/span>Do(<\/span><\/span>\"SET\"<\/span>,<\/span> k,<\/span> v)<\/span>\r\n    if<\/span> err !=<\/span> nil<\/span> {<\/span>\r\n        fmt.<\/span>Println(<\/span><\/span>\"set error\"<\/span>,<\/span> err.<\/span>Error(<\/span><\/span>)<\/span>)<\/span>\r\n    }<\/span>\r\n}<\/span>\r\n\r\nfunc<\/span> getStringValue(<\/span><\/span>k string<\/span>)<\/span> string<\/span> {<\/span>\r\n    c :=<\/span> NewRedisPool(<\/span><\/span>RedisURL)<\/span>.<\/span>Get(<\/span><\/span>)<\/span>\r\n    defer<\/span> c.<\/span>Close(<\/span><\/span>)<\/span>\r\n    username,<\/span> err :=<\/span> redis.<\/span>String(<\/span><\/span>c.<\/span>Do(<\/span><\/span>\"GET\"<\/span>,<\/span> k)<\/span>)<\/span>\r\n    if<\/span> err !=<\/span> nil<\/span> {<\/span>\r\n        fmt.<\/span>Println(<\/span><\/span>\"Get Error: \"<\/span>,<\/span> err.<\/span>Error(<\/span><\/span>)<\/span>)<\/span>\r\n        return<\/span> \"\"<\/span>\r\n    }<\/span>\r\n    return<\/span> username\r\n}<\/span>\r\n\r\nfunc<\/span> SetKeyExpire(<\/span><\/span>k string<\/span>,<\/span> ex int<\/span>)<\/span> {<\/span>\r\n    c :=<\/span> NewRedisPool(<\/span><\/span>RedisURL)<\/span>.<\/span>Get(<\/span><\/span>)<\/span>\r\n    defer<\/span> c.<\/span>Close(<\/span><\/span>)<\/span>\r\n    _<\/span>,<\/span> err :=<\/span> c.<\/span>Do(<\/span><\/span>\"EXPIRE\"<\/span>,<\/span> k,<\/span> ex)<\/span>\r\n    if<\/span> err !=<\/span> nil<\/span> {<\/span>\r\n        fmt.<\/span>Println(<\/span><\/span>\"set error\"<\/span>,<\/span> err.<\/span>Error(<\/span><\/span>)<\/span>)<\/span>\r\n    }<\/span>\r\n}<\/span>\r\n\r\nfunc<\/span> CheckKey(<\/span><\/span>k string<\/span>)<\/span> bool<\/span> {<\/span>\r\n    c :=<\/span> NewRedisPool(<\/span><\/span>RedisURL)<\/span>.<\/span>Get(<\/span><\/span>)<\/span>\r\n    defer<\/span> c.<\/span>Close(<\/span><\/span>)<\/span>\r\n    exist,<\/span> err :=<\/span> redis.<\/span>Bool(<\/span><\/span>c.<\/span>Do(<\/span><\/span>\"EXISTS\"<\/span>,<\/span> k)<\/span>)<\/span>\r\n    if<\/span> err !=<\/span> nil<\/span> {<\/span>\r\n        fmt.<\/span>Println(<\/span><\/span>err)<\/span>\r\n        return<\/span> false<\/span>\r\n    }<\/span> else<\/span> {<\/span>\r\n        return<\/span> exist\r\n    }<\/span>\r\n}<\/span>\r\n\r\nfunc<\/span> DelKey(<\/span><\/span>k string<\/span>)<\/span> error<\/span> {<\/span>\r\n    c :=<\/span> NewRedisPool(<\/span><\/span>RedisURL)<\/span>.<\/span>Get(<\/span><\/span>)<\/span>\r\n    defer<\/span> c.<\/span>Close(<\/span><\/span>)<\/span>\r\n    _<\/span>,<\/span> err :=<\/span> c.<\/span>Do(<\/span><\/span>\"DEL\"<\/span>,<\/span> k)<\/span>\r\n    if<\/span> err !=<\/span> nil<\/span> {<\/span>\r\n        fmt.<\/span>Println(<\/span><\/span>err)<\/span>\r\n        return<\/span> err\r\n    }<\/span>\r\n    return<\/span> nil<\/span>\r\n}<\/span>\r\n\r\nfunc<\/span> SetJson(<\/span><\/span>k string<\/span>,<\/span> data interface<\/span>{<\/span>}<\/span>)<\/span> error<\/span> {<\/span>\r\n    c :=<\/span> NewRedisPool(<\/span><\/span>RedisURL)<\/span>.<\/span>Get(<\/span><\/span>)<\/span>\r\n    defer<\/span> c.<\/span>Close(<\/span><\/span>)<\/span>\r\n    value,<\/span> _<\/span> :=<\/span> json.<\/span>Marshal(<\/span><\/span>data)<\/span>\r\n    n,<\/span> _<\/span> :=<\/span> c.<\/span>Do(<\/span><\/span>\"SETNX\"<\/span>,<\/span> k,<\/span> value)<\/span>\r\n    if<\/span> n !=<\/span> int64(<\/span><\/span>1<\/span>)<\/span> {<\/span>\r\n        return<\/span> errors.<\/span>New(<\/span><\/span>\"set failed\"<\/span>)<\/span>\r\n    }<\/span>\r\n    return<\/span> nil<\/span>\r\n}<\/span>\r\n\r\nfunc<\/span> getJsonByte(<\/span><\/span>k string<\/span>)<\/span> (<\/span>[<\/span>]<\/span>byte<\/span>,<\/span> error<\/span>)<\/span> {<\/span>\r\n    jsonGet,<\/span> err :=<\/span> redis.<\/span>Bytes(<\/span><\/span>c.<\/span>Do(<\/span><\/span>\"GET\"<\/span>,<\/span> key)<\/span>)<\/span>\r\n    if<\/span> err !=<\/span> nil<\/span> {<\/span>\r\n        fmt.<\/span>Println(<\/span><\/span>err)<\/span>\r\n        return<\/span> nil<\/span>,<\/span> err\r\n    }<\/span>\r\n    return<\/span> jsonGet,<\/span> nil<\/span>\r\n}<\/span><\/code><\/pre>\n<\/div>\n<\/div>\n","protected":false},"excerpt":{"rendered":"
\u539f\u5e16\u5730\u5740 package main im<\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"colormag_page_container_layout":"default_layout","colormag_page_sidebar_layout":"default_layout","footnotes":""},"categories":[],"tags":[122],"class_list":["post-3171","post","type-post","status-publish","format-standard","hentry","tag-06-godocker"],"_links":{"self":[{"href":"https:\/\/i007.cc\/wordpress\/wp-json\/wp\/v2\/posts\/3171","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/i007.cc\/wordpress\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/i007.cc\/wordpress\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/i007.cc\/wordpress\/wp-json\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/i007.cc\/wordpress\/wp-json\/wp\/v2\/comments?post=3171"}],"version-history":[{"count":0,"href":"https:\/\/i007.cc\/wordpress\/wp-json\/wp\/v2\/posts\/3171\/revisions"}],"wp:attachment":[{"href":"https:\/\/i007.cc\/wordpress\/wp-json\/wp\/v2\/media?parent=3171"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/i007.cc\/wordpress\/wp-json\/wp\/v2\/categories?post=3171"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/i007.cc\/wordpress\/wp-json\/wp\/v2\/tags?post=3171"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}