redis簡介
Redis 是完全開源免費(fèi)的，遵守BSD協(xié)議，是一個高性能的key-value數(shù)據(jù)庫
Redis 與其他 key - value 緩存產(chǎn)品有以下三個特點(diǎn):
- Redis支持?jǐn)?shù)據(jù)的持久化，可以將內(nèi)存中的數(shù)據(jù)保存在磁盤中，重啟的時候可以再次加載進(jìn)行使用
- Redis不僅僅支持簡單的key-value類型的數(shù)據(jù)，同時還提供list，set，zset，hash等數(shù)據(jù)結(jié)構(gòu)的存儲
- Redis支持?jǐn)?shù)據(jù)的備份，即master-slave模式的數(shù)據(jù)備份
優(yōu)勢
- 性能極高 - Redis能讀的速度是110000次/s,寫的速度是81000次/s
- 豐富的數(shù)據(jù)類型 – Redis支持二進(jìn)制案例的 Strings, Lists, Hashes, Sets 及 Ordered Sets 數(shù)據(jù)類型操作
- 原子 – Redis的所有操作都是原子性的，意思就是要么成功執(zhí)行要么失敗完全不執(zhí)行。單個操作是原子性的。多個操作也支持事務(wù)，即原子性，通過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/
進(jìn)入到文件夾中并編譯測試
cd /usr/local/redis-5.0.3
sudo make test
編譯安裝
啟動redis
mysql與redis做二級緩存
對于訪問量比較大的數(shù)據(jù)我們?yōu)榱四軌蚋斓墨@取到數(shù)據(jù)需要對數(shù)據(jù)庫中獲取的數(shù)據(jù)進(jìn)行數(shù)據(jù)緩存。
在項(xiàng)目當(dāng)中使用Redis緩存流程
- 查詢時先從緩存當(dāng)中查詢
- 緩存當(dāng)中如果沒有數(shù)據(jù)再從數(shù)據(jù)庫查詢，并將數(shù)據(jù)保存進(jìn)緩存當(dāng)中
- 如果緩存中查詢到了數(shù)據(jù)直接返回，不再需要查詢數(shù)據(jù)庫
數(shù)據(jù)緩存應(yīng)該考慮同步問題：如果對數(shù)據(jù)進(jìn)行了緩存，當(dāng)查詢數(shù)據(jù)時，如果緩存中有數(shù)據(jù)則直接返回緩存數(shù)據(jù)不會查詢數(shù)據(jù)庫，當(dāng)數(shù)據(jù)庫數(shù)據(jù)改變的時候就有可能出現(xiàn)數(shù)據(jù)庫不一致的問題?？梢钥紤]在每次修改數(shù)據(jù)庫的時候同時將對應(yīng)的緩存數(shù)據(jù)刪除，這樣重新查詢的時候就會查詢數(shù)據(jù)庫并緩存
步驟實(shí)現(xiàn)
創(chuàng)建redisPool.go文件用于連接池的初始化
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, //最大空閑鏈接數(shù)，表示即使沒有redis鏈接事依然可以保持N個空閑鏈接，而不被清除
MaxActive: 3, //最大激活連接數(shù)，表示同時最多有多少個鏈接
IdleTimeout: 240 * time.Second,//最大空閑鏈接等待時間，超過此時間，空閑將被關(guān)閉
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
},
}
}
創(chuàng)建main.go文件實(shí)現(xiàn)二級緩存
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() {
//從連接池當(dāng)中獲取鏈接
conn := redigo_pool.Pool.Get()
//先查看redis中是否有數(shù)據(jù)
//conn,_ :=redis.Dial("tcp","localhost:6379")
defer conn.Close()
values, _ := redis.Values(conn.Do("lrange", "mlist",0,-1))
if len(values) > 0 {
//如果有數(shù)據(jù)
fmt.Println("從redis獲取數(shù)據(jù)")
//從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中獲取")
//查詢數(shù)據(jù)庫
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)
// 設(shè)置過期時間
conn.Do("EXPIRE",p.Id,60*5)
if err1 != nil || err2 != nil {
fmt.Println("寫入失敗")
}else {
fmt.Println("寫入成功")
}
}
conn.Do("EXPIRE","mlist",60*5)
}
}
總結(jié)
以上就是這篇文章的全部內(nèi)容了，希望本文的內(nèi)容對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，如果有疑問大家可以留言交流，謝謝大家對腳本之家的支持。
您可能感興趣的文章:- MySQL的查詢緩存和Buffer Pool
- mysqldump造成Buffer Pool污染的研究
- redis服務(wù)器環(huán)境下mysql實(shí)現(xiàn)lnmp架構(gòu)緩存
- mysql select緩存機(jī)制使用詳解
- MySQL緩存的查詢和清除命令使用詳解
- PHP使用redis實(shí)現(xiàn)統(tǒng)計(jì)緩存mysql壓力的方法
- MySQL高速緩存啟動方法及參數(shù)詳解(query_cache_size)
- 清空mysql 查詢緩存的可行方法
- 使用Memcache緩存mysql數(shù)據(jù)庫操作的原理和緩存過程淺析
- 詳解MySQL中的緩沖池（buffer pool）
