2020QQ音乐年度听歌陈述

2026-07-20 22:46:40 焦点 227℃

1、若何需求

完成二级缓存
法度圭表类型运转起来后提示：“请输进呼唤：”，完成假定输进getall，若何查询并展示全数人员的完成信息
第一次时查询mysql并将下场缓存在redis，设置60秒的若何过不时分
往后的每次查询，假定redis罕有据就从redis加载，完成没有则几回上一步的若何独霸

2、完成邻接Mysql并奉行查询语句

先完成需求二，完成当输进呼唤getall时，若何查询并展示全数人员的完成信息。

package mainimport (    "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) 。

3 、写一个偏向措置函数

func HandleError(err error,why string)  {     if err != nil{         fmt.Println(err,why)        os.Exit(1)    }}

因为后背需求措置良多偏向，而偏向措置也是GO的一个特点，所以我们这先写一个偏向措置函数。

4 、设置二级缓存

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) "{ \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的全数值。

到此这篇

1、需求

完成二级缓存
法度圭表类型运转起来后提示：“请输进呼唤：” ，假定输进getall，查询并展示全数人员的信息
第一次时查询mysql并将下场缓存在redis ，设置60秒的过不时分
往后的每次查询，假定redis罕有据就从redis加载，没有则几回上一步的独霸

2 、完成邻接Mysql并奉行查询语句

先完成需求二，当输进呼唤getall时，查询并展示全数人员的信息。

package mainimport (    "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"`}

db, _ := sqlx.Connect("mysql", "root:123456@tcp(localhost:3306)/mydb")

3、写一个偏向措置函数

func HandleError(err error,why string)  {     if err != nil{         fmt.Println(err,why)        os.Exit(1)    }}