Go语言开发中redis的使用详解

前段时间因为忙一些其它的事情，分享的有些少，最近学习一下redis在go语言开发中的应用。

一、理论知识

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地址

文档地址：

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)))
  }
}

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。