redis簡介
Redis 是完全開源免費的，遵守BSD協議，是一個高性能的key-value數據庫
Redis 與其他 key - value 緩存產品有以下三個特點:
優勢
下載與安裝
下載并解壓縮
wget http://download.redis.io/releases/redis-5.0.3.tar.gztar xzf redis-5.0.3.tar.gz
將文件夾移動到/usr/local/中
mv redis-5.0.3 /usr/local/
進入到文件夾中并編譯測試
cd /usr/local/redis-5.0.3sudo make test
編譯安裝
sudo make install
啟動redis
redis-server
mysql與redis做二級緩存
對于訪問量比較大的數據我們為了能夠更快的獲取到數據需要對數據庫中獲取的數據進行數據緩存。
在項目當中使用Redis緩存流程
數據緩存應該考慮同步問題：如果對數據進行了緩存，當查詢數據時，如果緩存中有數據則直接返回緩存數據不會查詢數據庫，當數據庫數據改變的時候就有可能出現數據庫不一致的問題。可以考慮在每次修改數據庫的時候同時將對應的緩存數據刪除，這樣重新查詢的時候就會查詢數據庫并緩存
步驟實現
創建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, //最大空閑鏈接數，表示即使沒有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 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("不能識別其他命令") } 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) }}總結
以上就是這篇文章的全部內容了，希望本文的內容對大家的學習或者工作具有一定的參考學習價值，如果有疑問大家可以留言交流，謝謝大家對VeVb武林網的支持。
新聞熱點
疑難解答
