MySQL與Redis實作二級快取的方法介紹（程式碼範例）

這篇文章帶給大家的內容是關於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

mysql與redis做二級快取

• 對於訪問量比較大的資料我們為了能夠更快的取得到資料需要對資料庫中取得的資料進行資料快取。

  在專案當中使用Redis快取流程

資料快取應該考慮同步問題：如果對資料進行了緩存，當查詢資料時，如果快取中有資料則直接傳回快取資料不會查詢資料庫，當資料庫資料改變的時候就有可能出現資料庫不一致的問題。可以考慮在每次修改資料庫的時候同時將對應的快取資料刪除，這樣重新查詢的時候就會查詢資料庫並快取

2. 查詢時先從快取當中查詢

3. 快取當中如果沒有資料再從資料庫查詢，並將資料儲存進快取當中

##如果快取中查詢到了數據直接傳回，不再需要查詢資料庫

步驟實作
#建立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, //最大空闲链接数，表示即使没有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
          },
      }
  }

建立main.go檔案實作二級快取

######

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中文網其他相關文章！