快捷導(dǎo)航

MySQL和Redis實(shí)現(xiàn)二級(jí)緩存的方法詳解

更新時(shí)間：2019年02月01日 09:44:29 作者：我濤

這篇文章主要給大家介紹了關(guān)于MySQL和Redis實(shí)現(xiàn)二級(jí)緩存的相關(guān)資料，文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧

redis簡(jiǎn)介

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

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

Redis支持?jǐn)?shù)據(jù)的持久化，可以將內(nèi)存中的數(shù)據(jù)保存在磁盤中，重啟的時(shí)候可以再次加載進(jìn)行使用
Redis不僅僅支持簡(jiǎn)單的key-value類型的數(shù)據(jù)，同時(shí)還提供list，set，zset，hash等數(shù)據(jù)結(jié)構(gòu)的存儲(chǔ)
Redis支持?jǐn)?shù)據(jù)的備份，即master-slave模式的數(shù)據(jù)備份

優(yōu)勢(shì)

性能極高 - Redis能讀的速度是110000次/s,寫的速度是81000次/s
豐富的數(shù)據(jù)類型 – Redis支持二進(jìn)制案例的 Strings, Lists, Hashes, Sets 及 Ordered Sets 數(shù)據(jù)類型操作
原子 – Redis的所有操作都是原子性的，意思就是要么成功執(zhí)行要么失敗完全不執(zhí)行。單個(gè)操作是原子性的。多個(gè)操作也支持事務(wù)，即原子性，通過MULTI和EXEC指令包起來

下載與安裝

下載并解壓縮

wget http://download.redis.io/releases/redis-5.0.3.tar.gz
tar xzf redis-5.0.3.tar.gz

將文件夾移動(dòng)到/usr/local/中

mv redis-5.0.3 /usr/local/

進(jìn)入到文件夾中并編譯測(cè)試

cd /usr/local/redis-5.0.3
sudo make test

編譯安裝

sudo make install

啟動(dòng)redis

redis-server

mysql與redis做二級(jí)緩存

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

在項(xiàng)目當(dāng)中使用Redis緩存流程

查詢時(shí)先從緩存當(dāng)中查詢
緩存當(dāng)中如果沒有數(shù)據(jù)再從數(shù)據(jù)庫查詢，并將數(shù)據(jù)保存進(jìn)緩存當(dāng)中
如果緩存中查詢到了數(shù)據(jù)直接返回，不再需要查詢數(shù)據(jù)庫

數(shù)據(jù)緩存應(yīng)該考慮同步問題：如果對(duì)數(shù)據(jù)進(jìn)行了緩存，當(dāng)查詢數(shù)據(jù)時(shí)，如果緩存中有數(shù)據(jù)則直接返回緩存數(shù)據(jù)不會(huì)查詢數(shù)據(jù)庫，當(dāng)數(shù)據(jù)庫數(shù)據(jù)改變的時(shí)候就有可能出現(xiàn)數(shù)據(jù)庫不一致的問題。可以考慮在每次修改數(shù)據(jù)庫的時(shí)候同時(shí)將對(duì)應(yīng)的緩存數(shù)據(jù)刪除，這樣重新查詢的時(shí)候就會(huì)查詢數(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個(gè)空閑鏈接，而不被清除
  MaxActive: 3, //最大激活連接數(shù)，表示同時(shí)最多有多少個(gè)鏈接
  IdleTimeout: 240 * time.Second,//最大空閑鏈接等待時(shí)間，超過此時(shí)間，空閑將被關(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)二級(jí)緩存

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("不能識(shí)別其他命令")
  }
  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 反序列化出錯(cuò)")
   }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è)置過期時(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é)

以上就是這篇文章的全部?jī)?nèi)容了，希望本文的內(nèi)容對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，如果有疑問大家可以留言交流，謝謝大家對(duì)腳本之家的支持。

您可能感興趣的文章: