MySQL與Redis實現(xiàn)二級緩存的方法是什么

這篇文章將為大家詳細講解有關MySQL與Redis實現(xiàn)二級緩存的方法是什么，小編覺得挺實用的，因此分享給大家做個參考，希望大家閱讀完這篇文章后可以有所收獲。

redis簡介

• Redis 是完全開源免費的，遵守BSD協(xié)議，是一個高性能的key-value數(shù)據(jù)庫

• Redis 與其他 key - value 緩存產(chǎn)品有以下三個特點:

• Redis支持數(shù)據(jù)的持久化，可以將內存中的數(shù)據(jù)保存在磁盤中，重啟的時候可以再次加載進行使用

• Redis不僅僅支持簡單的key-value類型的數(shù)據(jù)，同時還提供list，set，zset，hash等數(shù)據(jù)結構的存儲

• Redis支持數(shù)據(jù)的備份，即master-slave模式的數(shù)據(jù)備份

優(yōu)勢

• 性能極高 - Redis能讀的速度是110000次/s,寫的速度是81000次/s

• 豐富的數(shù)據(jù)類型 – Redis支持二進制案例的 Strings, Lists, Hashes, Sets 及 Ordered Sets 數(shù)據(jù)類型操作

• 原子 – Redis的所有操作都是原子性的，意思就是要么成功執(zhí)行要么失敗完全不執(zhí)行。單個操作是原子性的。多個操作也支持事務，即原子性，通過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

若出現(xiàn)以下畫面則表示redis數(shù)據(jù)庫已經(jīng)啟動了：
jpg

mysql與redis做二級緩存

• 對于訪問量比較大的數(shù)據(jù)我們?yōu)榱四軌蚋斓墨@取到數(shù)據(jù)需要對數(shù)據(jù)庫中獲取的數(shù)據(jù)進行數(shù)據(jù)緩存。

• 在項目當中使用Redis緩存流程

  數(shù)據(jù)緩存應該考慮同步問題：如果對數(shù)據(jù)進行了緩存，當查詢數(shù)據(jù)時，如果緩存中有數(shù)據(jù)則直接返回緩存數(shù)據(jù)不會查詢數(shù)據(jù)庫，當數(shù)據(jù)庫數(shù)據(jù)改變的時候就有可能出現(xiàn)數(shù)據(jù)庫不一致的問題。可以考慮在每次修改數(shù)據(jù)庫的時候同時將對應的緩存數(shù)據(jù)刪除，這樣重新查詢的時候就會查詢數(shù)據(jù)庫并緩存

1. 查詢時先從緩存當中查詢

2. 緩存當中如果沒有數(shù)據(jù)再從數(shù)據(jù)庫查詢，并將數(shù)據(jù)保存進緩存當中

3. 如果緩存中查詢到了數(shù)據(jù)直接返回，不再需要查詢數(shù)據(jù)庫

步驟實現(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,//最大空閑鏈接等待時間，超過此時間，空閑將被關閉
        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文件實現(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()  {
    //從連接池當中獲取鏈接
    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)
            // 設置過期時間
            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實現(xiàn)二級緩存的方法是什么就分享到這里了，希望以上內容可以對大家有一定的幫助，可以學到更多知識。如果覺得文章不錯，可以把它分享出去讓更多的人看到。