redis簡(jiǎn)介
Redis 是完全開(kāi)源免費(fèi)的，遵守BSD協(xié)議，是一個(gè)高性能的key-value數(shù)據(jù)庫(kù)
Redis 與其他 key - value 緩存產(chǎn)品有以下三個(gè)特點(diǎn):
優(yōu)勢(shì)
下載與安裝
下載并解壓縮
wget http://download.redis.io/releases/redis-5.0.3.tar.gztar 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.3sudo make test
編譯安裝
sudo make install
啟動(dòng)redis
redis-server
mysql與redis做二級(jí)緩存
對(duì)于訪問(wèn)量比較大的數(shù)據(jù)我們?yōu)榱四軌蚋斓墨@取到數(shù)據(jù)需要對(duì)數(shù)據(jù)庫(kù)中獲取的數(shù)據(jù)進(jìn)行數(shù)據(jù)緩存。
在項(xiàng)目當(dāng)中使用Redis緩存流程
數(shù)據(jù)緩存應(yīng)該考慮同步問(wèn)題：如果對(duì)數(shù)據(jù)進(jìn)行了緩存，當(dāng)查詢(xún)數(shù)據(jù)時(shí)，如果緩存中有數(shù)據(jù)則直接返回緩存數(shù)據(jù)不會(huì)查詢(xún)數(shù)據(jù)庫(kù)，當(dāng)數(shù)據(jù)庫(kù)數(shù)據(jù)改變的時(shí)候就有可能出現(xiàn)數(shù)據(jù)庫(kù)不一致的問(wèn)題?？梢钥紤]在每次修改數(shù)據(jù)庫(kù)的時(shí)候同時(shí)將對(duì)應(yīng)的緩存數(shù)據(jù)刪除，這樣重新查詢(xún)的時(shí)候就會(huì)查詢(xún)數(shù)據(jù)庫(kù)并緩存
步驟實(shí)現(xiàn)
創(chuàng)建redisPool.go文件用于連接池的初始化
package redigo_poolimport ( "flag" "github.com/garyburd/redigo/redis" "time")var ( Pool *redis.Pool RedisServer = flag.String("redisServer", ":6379", "") )func init() { Pool = &redis.Pool{ MaxIdle: 3, //最大空閑鏈接數(shù)，表示即使沒(méi)有redis鏈接事依然可以保持N個(gè)空閑鏈接，而不被清除 MaxActive: 3, //最大激活連接數(shù)，表示同時(shí)最多有多少個(gè)鏈接 IdleTimeout: 240 * time.Second,//最大空閑鏈接等待時(shí)間，超過(guò)此時(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 mainimport ( "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中獲取") //查詢(xún)數(shù)據(jù)庫(kù) 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) } //寫(xiě)入到redis中:將person以hash的方式寫(xiě)入到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è)置過(guò)期時(shí)間 conn.Do("EXPIRE",p.Id,60*5) if err1 != nil || err2 != nil { fmt.Println("寫(xiě)入失敗") }else { fmt.Println("寫(xiě)入成功") } } conn.Do("EXPIRE","mlist",60*5) }}總結(jié)
以上就是這篇文章的全部?jī)?nèi)容了，希望本文的內(nèi)容對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，如果有疑問(wèn)大家可以留言交流，謝謝大家對(duì)VeVb武林網(wǎng)的支持。
新聞熱點(diǎn)
疑難解答
圖片精選
