快捷導(dǎo)航

go實現(xiàn)redigo的簡單操作

更新時間：2018年07月23日 09:54:18 作者：熔遁丶螺旋手里劍

golang操作redis主要有兩個庫，go-redis和redigo，今天我們就一起來介紹一下redigo的實現(xiàn)方法，需要的朋友可以參考下

golang操作redis主要有兩個庫，go-redis和redigo。兩者操作都比較簡單，區(qū)別上redigo更像一個client執(zhí)行各種操作都是通過Do函數(shù)去做的，redis-go對函數(shù)的封裝更好，相比之下redigo操作redis顯得有些繁瑣。但是官方更推薦redigo，所以項目中我使用了redigo。

1.連接redis

package redisclient
import (
  "fmt"
  redigo "github.com/garyburd/redigo/redis"
)
var pool *redigo.Pool
func init() {
  redis_host := "127.0.0.1"
  redis_port := 6379
  pool_size := 20
  pool = redigo.NewPool(func() (redigo.Conn, error) {
    c, err := redigo.Dial("tcp", fmt.Sprintf("%s:%d", redis_host, redis_port))
    if err != nil {
      return nil, err
    }
    return c, nil
  }, pool_size)
}
func Get() redigo.Conn {
  return pool.Get()
}

之后我們調(diào)用redisclient包中的.Get()就可以生成一個redis連接池對象來操作redis

2.操作redis

package main
import (
  "redisclient"
  "logger"
  "github.com/garyburd/redigo/redis"
)
func main() {
  c := redisclient.Get()
  //記得銷毀本次鏈連接
  defer c.Close()
  //寫入數(shù)據(jù)
  _, err := c.Do("SET", "go_key", "redigo")
  if err != nil {
    logger.Runtime().Info(map[string]interface{}{"error": err}, "error while setting")
  }
  //判斷key是否存在
  is_key_exit, err := redis.Bool(c.Do("EXISTS", "go_key"))
  if err != nil {
    logger.Runtime().Info(map[string]interface{}{"error": err}, "error while existing")
  }
  //獲取value并轉(zhuǎn)成字符串
  account_balance, err := redis.String(c.Do("GET", "go_key"))
  if err != nil {
    logger.Runtime().Info(map[string]interface{}{"error": err}, "error while getting")
  }
  //刪除key
  _, err = c.Do("DEL", "go_key")
  if err != nil {
    logger.Runtime().Info(map[string]interface{}{"error": err}, "error while deleting")
  }
  //設(shè)置key過期時間
  _, err = c.Do("SET", "mykey", "superWang", "EX", "5")
  if err != nil {
    fmt.Println("redis set failed:", err)
  }
  //創(chuàng)建key時設(shè)置5s過期
  _, err := c.Do("SET", "go_key:ex", "redigo", "EX", 5)
  if err != nil {
    logger.Runtime().Info(map[string]interface{}{"error": err}, "error while setting")
  }
  //對已有key設(shè)置5s過期時間
  n, err := rs.Do("EXPIRE", "go_key", 5)
  if err != nil {
    logger.Runtime().Info(map[string]interface{}{"error": err}, "error while setting")
  } else if n != int64(1) {
    fmt.Println("failed")
  }
}

以上就是本文的全部內(nèi)容，希望對大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。

您可能感興趣的文章: