这篇文章给大家介绍如何在golang开发中使用redis,内容非常详细,感兴趣的小伙伴们可以参考借鉴,希望对大家能有所帮助。
创新互联建站是专业的诸暨网站建设公司,诸暨接单;提供做网站、网站设计,网页设计,网站设计,建网站,PHP网站建设等专业做网站服务;采用PHP框架,可快速的进行诸暨网站开发网页制作和功能扩展;专业做搜索引擎喜爱的网站,专业的做网站团队,希望更多企业前来合作!一、理论知识
Redis是一个开源的、使用C语言编写的、支持网络交互的、可基于内存也可持久化的Key-Value数据库。
Redis 优势
性能极高 – Redis能读的速度是110000次/s,写的速度是81000次/s 。
丰富的数据类型 – Redis支持二进制案例的 Strings, Lists, Hashes, Sets 及 Ordered Sets 数据类型操作。
原子 – Redis的所有操作都是原子性的,同时Redis还支持对几个操作全并后的原子性执行。
丰富的特性 – Redis还支持 publish/subscribe, 通知, key 过期等等特性。
Redis与其他key-value存储有什么不同?
Redis有着更为复杂的数据结构并且提供对他们的原子性操作,这是一个不同于其他数据库的进化路径。Redis的数据类型都是基于基本数据结构的同时对程序员透明,无需进行额外的抽象。
Redis运行在内存中但是可以持久化到磁盘,所以在对不同数据集进行高速读写时需要权衡内存,因为数据量不能大于硬件内存。在内存数据库方面的另一个优点是,相比在磁盘上相同的复杂的数据结构,在内存中操作起来非常简单,这样Redis可以做很多内部复杂性很强的事情。同时,在磁盘格式方面他们是紧凑的以追加的方式产生的,因为他们并不需要进行随机访问。
二、使用:
在开发过程中我们使用到了开源库redis如下
github地址
https://github.com/garyburd/redigo
文档地址:
http://godoc.org/github.com/garyburd/redigo/redis
1、数据库的连接
func connDB() (c redis.Conn, err error) { db, err := redis.Dial("tcp", "127.0.0.1:6379") if err != nil { fmt.Println("Connect to redis error", err) return } return db, err }
2、写入
func saveToDB(c redis.Conn) { _, err := c.Do("SET", "name", "qiuqiu", "EX", "50") if err != nil { fmt.Println("redis set failed:", err) } else { fmt.Println("save success") } } //批量写入 _, err := c.Do("MSET", "name", "superWang", "SEX", "F", "EX", "50") if err != nil { fmt.Println("redis set failed:", err) } else { fmt.Println("save success") } //tips:EX是这个值的过期时间
3、读取
func readFromDB(c redis.Conn) { username, err := redis.String(c.Do("GET", "name")) if err != nil { fmt.Println("redis get failed:", err) } else { fmt.Printf("Get mykey: %v \n", username) } } //批量读取 func readFromDB(c redis.Conn) { username, err := redis.Strings(c.Do("MGET", "SEX", "name")) if err != nil { fmt.Println("redis get failed:", err) } else { fmt.Printf("Get mykey: %v \n", username) } }
4、删除
func delFromDB(c redis.Conn) { _, err := c.Do("DEL", "name", "SEX") if err != nil { fmt.Println("redis delete failed:", err) } else { fmt.Println("delete success") } }
5、设置keys 过期时间
在写入的时候如果设置了EX的时间,则当前的key过期时间为设置时间,不设置则当前的key永久有效
6、读写json到redis
//写json func saveJsonDataToDB(c redis.Conn) { imap := map[string]string{"name": "waiwaigo", "phone": "13498739038"} value, _ := json.Marshal(imap) n, err := c.Do("SETNX", "jsonkey", value) if err != nil { fmt.Println(err) } if n == int64(1) { fmt.Println("success") } } //读json func readJsonFromDB(c redis.Conn) { var imapGet map[string]string valueGet, err := redis.Bytes(c.Do("GET", "jsonkey")) if err != nil { fmt.Println(err) } errShal := json.Unmarshal(valueGet, &imapGet) if errShal != nil { fmt.Println(err) } fmt.Println(imapGet["name"]) fmt.Println(imapGet["phone"]) }
7、列表操作,存入一组数据
//存列表 func saveListToDB(c redis.Conn) { _, err := c.Do("lpush", "username", "zhangsan") if err != nil { fmt.Println("redis set failed:", err) } _, err = c.Do("lpush", "username", "lisi") if err != nil { fmt.Println("redis set failed:", err) } _, err = c.Do("lpush", "username", "wangwu") if err != nil { fmt.Println("redis set failed:", err) } } //读列表 func readListFromDB(c redis.Conn) { values, _ := redis.Values(c.Do("lrange", "username", "0", "2")) fmt.Printf("count%d", len(values)) for _, v := range values { fmt.Println(string(v.([]byte))) } }
关于如何在golang开发中使用redis就分享到这里了,希望以上内容可以对大家有一定的帮助,可以学到更多知识。如果觉得文章不错,可以把它分享出去让更多的人看到。
另外有需要云服务器可以了解下创新互联scvps.cn,海内外云服务器15元起步,三天无理由+7*72小时售后在线,公司持有idc许可证,提供“云服务器、裸金属服务器、高防服务器、香港服务器、美国服务器、虚拟主机、免备案服务器”等云主机租用服务以及企业上云的综合解决方案,具有“安全稳定、简单易用、服务可用性高、性价比高”等特点与优势,专为企业上云打造定制,能够满足用户丰富、多元化的应用场景需求。