go redis-mysql实现二级缓存

package main
import (
//导入SDK包（）
//格式化的输入输出包
"fmt"
//操作系统包
"os"
//导入mysql数据库驱动，只需要执行其包的初始化方法，不需要使用其API
_"github.com/go-sql-driver/mysql"
//导入第三方包，存储路径在GOPATH下
"github.com/garyburd/redigo/redis"
"github.com/jmoiron/sqlx"
)
/*定义结构体，用于接收数据库的数据*/
type Person struct { 
Name string `db:"name"`
Age  int    `db:"age"`
}
/* 错误处理函数 参数：传入错误、出错的场景 只要有错误，就打印错误并暴力退出程序 */
func HandleError(err error, when string) { 
if err != nil { 
fmt.Println(err, when)
//暴力结束程序
os.Exit(1)
}
}
/*程序入口*/
func main() { 
//定义字符串变量userInput，用于稍后接收用户输入
var userInput string
//源源不断地接收用户输入
for { 
//提示用户输入命令
fmt.Println("请输入命令:")
//阻塞等待用户输入，并存入userInput的内存地址
fmt.Scan(&userInput)
//根据用户的具体输入，做不同的响应
switch userInput { 
//显示所有人员信息
case "getall":
GetAllPeople()
//退出程序
case "exit":
//直接跳转到GAMEOVER处
goto GAMEOVER
default:
fmt.Println("什么破命令，fuckoff！")
}
}
GAMEOVER:
//打印并换行
fmt.Println("GAME OVER")
}
/*获取并打印所有人员信息*/
func GetAllPeople() { 
//先尝试拿缓存
strs := GetPeopleFromRedis()
if len(strs) == 0{ 
//如果没有拿到数据从MySQL拿取数据
people := GetPeopleFromMysql()
//缓存查询结果到Redis
CachePeople2Redis(people)
}else{ 
//拿到了缓存就直接打印
fmt.Println(strs)
}
}
/* 从MySQL核心数据库拿取人员信息 返回值： people []Person 预定义的Person切片容器 */
func GetPeopleFromMysql()(people []Person) { 
fmt.Println("GetPeopleFromMysql")
//连接数据库:mysql=驱动，root=用户名，123456=密码,localhost:3306=地址，mydb=数据库名称，db=数据库对象
//db, err := sqlx.Open("mysql", "root:123456@tcp(localhost:3306)/mydb")
db, err := sqlx.Connect("mysql", "root:123456@tcp(localhost:3306)/mydb")
//处理错误
HandleError(err,"sqlx.Connect")
//延时关闭数据库（当前函数结束前）
defer db.Close()
//执行SQL语句查询，查询结果转化为[]Person，丢入返回值people的地址
err = db.Select(&people, "select name,age from person")
//处理错误
HandleError(err,"db.Select")
//打印结果
fmt.Println(people)
return
}
/* 从Redis缓存获取获取人员信息 返回值：【很多的】人员信息字符串，使用【切片容器[]string】返回 */
func GetPeopleFromRedis() (strs []string) { 
fmt.Println("GetPeopleFromRedis")
//连接Redis数据库,通信协议=tcp，访问地址=localhost:6379
//获得连接或错误
conn, err := redis.Dial("tcp", "localhost:6379")
HandleError(err,"redis.Dial")
//延时关闭连接
defer conn.Close()
//执行redis命令：lrange people 0 -1
reply, err := conn.Do("lrange", "people", "0", "-1")
//尝试将结果转换为[]string
strs, err = redis.Strings(reply, err)
fmt.Println("缓存拿取结果", strs, err)
//返回结果
return
}
/*缓存查询结果到Redis*/
func CachePeople2Redis(people []Person) { 
//连接数据库并延时关闭
conn, _ := redis.Dial("tcp", "localhost:6379")
defer conn.Close()
//清除原有缓存：del people
conn.Do("del","people")
//遍历people中的每一个Person对象
//得到每一个Person对象的序号和值，序号不想用，使用下划线除掉
for _, person := range people { 
//获得待打印的字符串
personStr := fmt.Sprint(person)
//执行redis命令：rpush people xxx，把每一个personStr存入列表people
_, err := conn.Do("rpush", "people", personStr)
HandleError(err, "@ rpush people "+personStr)
}
//执行redis命令：expire people 20，使people在20秒后过期
_, err := conn.Do("expire", "people", 20)
HandleError(err, "@ expire people 60")
fmt.Println("缓存people成功！")
}
本文地址：https://blog.csdn.net/sgentle/article/details/110704272
go redis-mysql实现二级缓存

相关推荐
