个人中心
gpt4 book ai didi

Go应该如何实现二级缓存

转载 作者：qq735679552 更新时间：2022-09-29 22:32:09 25 4
gpt4 key购买 nike

CFSDN坚持开源创造价值，我们致力于搭建一个资源共享平台，让每一个IT人在这里找到属于你的精彩世界.

这篇CFSDN的博客文章Go应该如何实现二级缓存由作者收集整理，如果你对这篇文章有兴趣，记得点赞哟.

1、需求

  • 实现二级缓存
  • 程序运行起来后提示：“请输入命令：”，如果输入getall，查询并显示所有人员的信息
  • 第一次时查询mysql并将结果缓存在redis，设置60秒的过期时间
  • 以后的每次查询，如果redis有数据就从redis加载，没有则重复上一步的操作

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

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

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
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"一定要加反单引号，否则运行时会报错。（傻傻的编者刚开始这里就出现问题啦~） 。

?
1
2
3
4
type Human struct {
     Name string `db:"name"`
     Age int `db:"age"`
}

然后main函数里面都是一些基本语法知识，用了switch和goto这两个内容。 接下来就是连接数据库了，这里要用到数据库扩展包Sqlx，Sqlx包其实最大最大的优点是在查询方面，也就是使用select时优化得比较好。比原来的使用查询方便了不止一点.

?
1
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).

3、写一个错误处理函数

?
1
2
3
4
5
6
func HandleError(err error,why string)  {
     if err != nil{
         fmt.Println(err,why)
         os.Exit(1)
     }
}

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

4、设置二级缓存

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
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命令，将列表设置过期时间。 执行成功！下面是运行结果:

请输入命令： getall allPeople [{大扬 21} {小飞 21} {大红袍 1} {小芳 18}] 缓存成功！ 请输入命令:

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

?
1
2
3
4
5
127.0.0.1:6379> lrange people 0 -1
1) "{\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数据库内的数据.

?
1
2
127.0.0.1:6379> lrange people 0 -1
(empty list or set)

已经消失了.

再写一个函数:

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
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的所有值.

到此这篇关于Go应该如何实现二级缓存的文章就介绍到这了,更多相关Go 二级缓存内容请搜索我以前的文章或继续浏览下面的相关文章希望大家以后多多支持我！ 。

原文链接：https://juejin.cn/post/6994600836101832741 。

最后此篇关于Go应该如何实现二级缓存的文章就讲到这里了,如果你想了解更多关于Go应该如何实现二级缓存的内容请搜索CFSDN的文章或继续浏览相关文章，希望大家以后支持我的博客！ 。

25 4 0
文章推荐： 提高网页打开速度的方法
文章推荐： Go实现Redis连接池方法
文章推荐： 淘宝客新手教程：如何从无到有搭建淘宝客网站
文章推荐： Go 协程超时控制的实现
qq735679552
个人简介

我是一名优秀的程序员,十分优秀！

滴滴打车优惠券免费领取
滴滴打车优惠券
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com