写点什么

带你了解 Go 怎样实现二级缓存

用户头像
Regan Yue
关注
发布于: 3 小时前
带你了解Go怎样实现二级缓存

带你了解 Go 怎样实现二级缓存

一、需求

  • 实现二级缓存

  • 程序运行起来后提示:”请输入命令:“,如果输入getall,查询并显示所有人员的信息

  • 第一次时查询mysql并将结果缓存在redis,设置 60 秒的过期时间

  • 以后的每次查询,如果redis有数据就从redis加载,没有则重复上一步的操作

二、实现连接 Mysql 并执行查询语句

先实现需求二,当输入命令getall时,查询并显示所有人员的信息。


package main
import ( "fmt" _"github.com/go-sql-driver/mysql" "github.com/jmoiron/sqlx")
type Human struct { Name string `db:"name"` Age int `db:"age"`}func main() { var cmd string for{ fmt.Println("请输入命令:") fmt.Scan(&cmd)
switch cmd{ case "getall": //显示所有人的信息 GetAllPeople() case "exit": //退出程序 goto GAMEOVER default: fmt.Println("输入的命令有误,请重新输入!") } } GAMEOVER: fmt.Println("GAME OVER")
}
func GetAllPeople() { fmt.Println("allPeople") //先尝试拿缓存 GetPeopleFromRedis() db, _ := sqlx.Connect("mysql", "root:123456@tcp(localhost:3306)/mydb") defer db.Close()
var people []Human err := db.Select(&people, "select name,age from person") if err!=nil{ fmt.Println("查询失败!err=",err) } fmt.Println(people) CachePeople2Redis(people)}
复制代码


第一步还是导包,需要在 mysql 驱动包前面加上下划线_,因为它只是一个驱动文件,并不需要在代码中调用它的有关 API 接口.


接下来的这个结构体中后面的db:"name" db:"age"一定要加反单引号,否则运行时会报错。(傻傻的编者刚开始这里就出现问题啦~)


type Human struct {  Name string `db:"name"`  Age int `db:"age"`}
复制代码


然后 main 函数里面都是一些基本语法知识,用了switchgoto这两个内容。


接下来就是连接数据库了,这里要用到数据库扩展包SqlxSqlx包其实最大最大的优点是在查询方面,也就是使用 select 时优化得比较好。比原来的使用查询方便了不止一点。


db, _ := sqlx.Connect("mysql", "root:123456@tcp(localhost:3306)/mydb")
复制代码


driverName:mysql,表示驱动器的名称是 mysql 也就上面"github.com/go-sql-driver/mysql"导入的驱动器。


dataSourceName 是 root:123456@tcp(localhost:3306)/mydb 它的含义是 账户名:密码 @tcp(ip:端口)/数据库名称


将缓存查询结果到 Redis,就是通过这个函数 CachePeople2Redis(people)。

三、写一个错误处理函数

func HandleError(err error,why string)  {  if err != nil{    fmt.Println(err,why)    os.Exit(1)  }}
复制代码


因为后面需要处理很多错误,而错误处理也是 GO 的一个特性,所以我们这先写一个错误处理函数。

四、设置二级缓存

func CachePeople2Redis(people []Human)  {  conn, _ := redis.Dial("tcp", "localhost:6379")    defer conn.Close()  for _,human := range people{    humanStr := fmt.Sprint(human)    _, err := conn.Do("rpush", "people", humanStr)    if err != nil{      fmt.Println("缓存失败(rpush people),err=",err)      return    }  }  _, err := conn.Do("expire", "people", 66)  if err!=nil{    HandleError(err,"@expire people 60")  }  fmt.Println("缓存成功!")}
复制代码


redis.Dial()这个函数是用来连接 redis 的,需要给定网络协议和 IP 地址及端口号,redis 的端口号默认为 6379.


defer conn.Close()表示延时结束与 redis 的连接,为了节省系统的 io 资源,需要及时关闭连接!刚入门时我们很容易忘记这个,需要我们养成习惯!


conn.Do()是用来执行数据库命令的,第一个参数是命令名,后面的参数是数据库命令的参数。它返回的结果中 reply 是字节数组[]byte 类型,需要根据具体的业务类型进行数据类型转换。


这段代码先将 people 数组中的每一个 human 放入到 redis 的 people 列表中。然后再执行 expire 命令,将列表设置过期时间。


执行成功!下面是运行结果:


请输入命令:getallallPeople[{大扬 21} {小飞 21} {大红袍 1} {小芳 18}]缓存成功!请输入命令:
复制代码


然后去看看数据库里面存进去没有。


127.0.0.1:6379> lrange people 0 -11) "{\xe5\xa4\xa7\xe6\x89\xac 21}"2) "{\xe5\xb0\x8f\xe9\xa3\x9e 21}"3) "{\xe5\xa4\xa7\xe7\xba\xa2\xe8\xa2\x8d 1}"4) "{\xe5\xb0\x8f\xe8\x8a\xb3 18}"
复制代码


过了一分钟之后,再查看 redis 数据库内的数据。


127.0.0.1:6379> lrange people 0 -1(empty list or set)
复制代码


已经消失了。


再写一个函数:


func GetPeopleFromRedis() (peopleStrs []string) {    //连数据库   conn, _ := redis.Dial("tcp", "localhost:6379")    //延迟关闭  defer conn.Close()  //执行命令  reply, err := conn.Do("lrange", "people", 0, -1)  //处理错误    HandleError(err,"@lrange people 0 -1")  //类型转换  peopleStrs, err = redis.Strings(reply, err)    //打印结果  fmt.Println("缓存拿取结果:",peopleStrs,err)  return}
复制代码


如果redis里面有就不需要从mysql里面取数据了。直接从redis里面利用lrange命令来获取 people 的所有值。

发布于: 3 小时前阅读数: 5
用户头像

Regan Yue

关注

还未添加个人签名 2020.08.12 加入

还未添加个人简介

评论

发布
暂无评论
带你了解Go怎样实现二级缓存