Go应该如何实现二级缓存

 更新时间:2021年08月12日 10:50:21   作者:ReganYue  
本文主要介绍了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函数里面都是一些基本语法知识,用了switch和goto这两个内容。
接下来就是连接数据库了,这里要用到数据库扩展包Sqlx,Sqlx包其实最大最大的优点是在查询方面,也就是使用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命令,将列表设置过期时间。
执行成功!下面是运行结果:

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

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

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数据库内的数据。

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的所有值。

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

相关文章

  • go语言使用中提示%!(NOVERB)的解决方案

    go语言使用中提示%!(NOVERB)的解决方案

    o语言的设计目标是提供一种简单易用的编程语言,同时保持高效性和可扩展性,它支持垃圾回收机制,具有强大的并发编程能力,可以轻松处理大规模的并发任务,Go语言还拥有丰富的标准库和活跃的开发社区,使得开发者能够快速构建出高质量的应用程序,需要的朋友可以参考下
    2023-10-10
  • Go语言标准库sync.Once使用场景及性能优化详解

    Go语言标准库sync.Once使用场景及性能优化详解

    这篇文章主要为大家介绍了Go语言标准库sync.Once使用场景及性能优化详解,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
    2023-12-12
  • Go函数的使用示例教程

    Go函数的使用示例教程

    这篇文章主要介绍了Go函数的使用示例,本文通过实例代码给大家介绍的非常详细,感兴趣的朋友跟随小编一起看看吧
    2024-07-07
  • go语言中结构体tag使用小结

    go语言中结构体tag使用小结

    Go语言是一种静态类型、编译型的编程语言,其中结构体是一种非常重要的数据类型,本文就来介绍一下go语言中结构体tag使用,具有一定的参考价值,感兴趣的可以了解一下
    2023-10-10
  • go语法入门泛型type parameters简称T(类型形参)两种场景使用

    go语法入门泛型type parameters简称T(类型形参)两种场景使用

    这篇文章主要为大家介绍了go语法入门泛型type parameters简称T(类型形参)两种场景使用示例,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
    2023-09-09
  • 使用Go实现邮箱验证码API功能

    使用Go实现邮箱验证码API功能

    本文将带你了解一个项目如何实现一个邮箱验证接口,即一个可用的发送邮箱验证码API和验证验证码是否正确功能,对Go实现邮箱验证码API详细过程感兴趣的朋友一起看看吧
    2024-06-06
  • 一文带你掌握Golang中panic与recover的使用方法

    一文带你掌握Golang中panic与recover的使用方法

    这篇文章主要介绍了Golang中panic与recover的作用和使用方法,文中的示例代码讲解详细,具有一定的学习价值,需要的小伙伴可以参考一下
    2023-04-04
  • Golang使用gin框架实现一个完整的聊天室功能

    Golang使用gin框架实现一个完整的聊天室功能

    由于我们项目的需要,我就研究了一下关于websocket的相关内容,去实现一个聊天室的功能,经过几天的探索,现在使用Gin框架实现了一个完整的聊天室+消息实时通知系统,感兴趣的小伙伴欢迎阅读本文
    2023-08-08
  • 从Context到go设计理念轻松上手教程

    从Context到go设计理念轻松上手教程

    这篇文章主要为大家介绍了从Context到go设计理念轻松上手教程详解,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
    2022-09-09
  • Go并发与锁的两种方式该如何提效详解

    Go并发与锁的两种方式该如何提效详解

    如果没有锁,在我们的项目中,可能会存在多个goroutine同时操作一个资源(临界区),这种情况会发生竞态问题(数据竞态),下面这篇文章主要给大家介绍了关于Go并发与锁的两种方式该如何提效的相关资料,需要的朋友可以参考下
    2022-12-12

最新评论