作者：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的所有值。**

ITPub博客

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

最新文章