cpu二级缓存-二级缓存（Go语言实现）

一、需求

二、实现连接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这两个内容。

接下来就是连接数据库了，这里要用到数据库扩展包Sqlxcpu二级缓存，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的一个特性cpu二级缓存，所以我们这先写一个错误处理函数。

四、设置二级缓存

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 -11) "{xe5xa4xa7xe6x89xac 21}"2) "{xe5xb0x8fxe9xa3x9e 21}"3) "{xe5xa4xa7xe7xbaxa2xe8xa2x8d 1}"4) "{xe5xb0x8fxe8x8axb3 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的所有值。

– End –

限时特惠：本站每日持续更新海量各大内部网赚创业教程，会员可以下载全站资源点击查看详情
站长微信：