這篇文章帶給大家的內容是關於MySQL與Redis實現二級快取的方法介紹（程式碼範例），有一定的參考價值，有需要的朋友可以參考一下，希望對你有幫助。
redis簡介
Redis 是完全開源免費的，遵守BSD協議，是一個高效能的key-value資料庫
Redis 與其他key - value 快取產品有以下三個特點:
#Redis支援資料的持久化，可以將記憶體中的資料保存在磁碟中，重啟的時候可以再次加載進行使用
Redis不僅僅支持簡單的key-value類型的數據，同時還提供list，set，zset，hash等數據結構的存儲
Redis支援資料的備份，即master-slave模式的資料備份
效能極高- Redis能讀的速度是110000次/s,寫的速度是81000次/s
豐富的資料型別– Redis支援二進位案例的Strings, Lists, Hashes, Sets 及Ordered Sets 資料型別操作
原子– Redis的所有操作都是原子性的，意思就是要成功執行或失敗完全不執行。單一操作是原子性的。多個操作也支援事務，即原子性，透過MULTI和EXEC指令包起來
下載並解壓縮
wget http://download.redis.io/releases/redis-5.0.3.tar.gz tar xzf redis-5.0.3.tar.gz
將資料夾移到/usr/local/中
mv redis-5.0.3 /usr/local/
進入到資料夾中並編譯測試
cd /usr/local/redis-5.0.3 sudo make test
編譯安裝
sudo make install
#開始redis
redis-server
若出現下列畫面則表示redis資料庫已經啟動了：
jpg
在專案當中使用Redis快取流程
package redigo_pool
import (
"flag"
"github.com/garyburd/redigo/redis"
"time"
)
var (
Pool *redis.Pool
RedisServer = flag.String("redisServer", ":6379", "")
)
func init() {
Pool = &redis.Pool{
MaxIdle: 3, //最大空闲链接数，表示即使没有redis链接事依然可以保持N个空闲链接，而不被清除
MaxActive: 3, //最大激活连接数，表示同时最多有多少个链接
IdleTimeout: 240 * time.Second,//最大空闲链接等待时间，超过此时间，空闲将被关闭
Dial: func() (redis.Conn, error) {
c, err := redis.Dial("tcp", *RedisServer)
if err != nil {
return nil, err
}
return c, err
},
TestOnBorrow: func(c redis.Conn, t time.Time) error {
if time.Since(t) < time.Minute {
return nil
}
_, err := c.Do("PING")
return err
},
}
}package main
import (
"database/sql"
"encoding/json"
"fmt"
"github.com/garyburd/redigo/redis"
_ "github.com/go-sql-driver/mysql"
"strconv"
"web/redis/redigo_pool"
_ "web/redis/redigo_pool"
)
type Person struct {
Id int `db:"id"`
Name string `db:"name"`
Age int `db:"age"`
Rmb int `db:"rmb"`
}
func main() {
var cmd string
for{
fmt.Println("输入命令")
fmt.Scan(&cmd)
switch cmd {
case "getall":
getAll()
default:
fmt.Println("不能识别其他命令")
}
fmt.Println()
}
}
func getAll() {
//从连接池当中获取链接
conn := redigo_pool.Pool.Get()
//先查看redis中是否有数据
//conn,_ :=redis.Dial("tcp","localhost:6379")
defer conn.Close()
values, _ := redis.Values(conn.Do("lrange", "mlist",0,-1))
if len(values) > 0 {
//如果有数据
fmt.Println("从redis获取数据")
//从redis中直接获取
for _,key := range values{
pid :=string(key.([]byte))
id ,_:= strconv.Atoi(pid)
results,_ := redis.Bytes(conn.Do("GET",id))
var p Person
err := json.Unmarshal(results,&p)
if err != nil {
fmt.Println("json 反序列化出错")
}else {
fmt.Printf("name = %s\n",p.Name)
}
}
}else {
fmt.Println("从mysql中获取")
//查询数据库
db,_ := sql.Open("mysql","root:Szt930708@tcp(localhost:3306)/mydb")
defer db.Close()
var persons []Person
rows,_ := db.Query("select id,name,age,rmb from person")
for rows.Next() {
var id int
var name string
var age int
var rmb int
rows.Scan(&id,&name,&age,&rmb)
per := Person{id,name,age,rmb}
persons = append(persons,per)
}
//写入到redis中:将person以hash的方式写入到redis中
for _,p := range persons{
p_byte,_ := json.Marshal(p)
_,err1 := conn.Do("SETNX",p.Id,p_byte)
_,err2 := conn.Do("lpush","mlist",p.Id)
// 设置过期时间
conn.Do("EXPIRE",p.Id,60*5)
if err1 != nil || err2 != nil {
fmt.Println("写入失败")
}else {
fmt.Println("写入成功")
}
}
conn.Do("EXPIRE","mlist",60*5)
}
}以上是MySQL與Redis實作二級快取的方法介紹（程式碼範例）的詳細內容。更多資訊請關注PHP中文網其他相關文章！
