4.4 调用Redis

4.4.1 简介

client/redis 包是对go-redis 进行二次封装，并提供redisStub和redisClusterStub 两种访问reids方式的客户端

4.4.2 配置规范

配置说明4.4 调用Redis - 图1 (opens new window)

4.4.3 用法

访问redis示例4.4 调用Redis - 图2 (opens new window)

  1. // run: go run main.go --config=config.toml
  2. type Engine struct {
  3.     jupiter.Application
  4. }
  6. func NewEngine() *Engine {
  7.     eng := &Engine{}
  8.     if err := eng.Startup(
  9.         eng.exampleForRedisStub,
  10.         eng.exampleForRedisClusterStub,
  11.     ); err != nil {
  12.         xlog.Panic("startup", xlog.Any("err", err))
  13.     }
  14.     return eng
  15. }
  17. func main() {
  18.     app := NewEngine()
  19.     if err := app.Run(); err != nil {
  20.         panic(err)
  21.     }
  22. }
  24. func (eng *Engine) exampleForRedisStub() (err error) {
  25.     //build redisStub
  26.     redisStub := redis.StdRedisConfig("myredis").Build()
  27.     // set string
  28.     setRes := redisStub.Set("jupiter-redis", "redisStub", time.Second*5)
  29.     xlog.Info("redisStub set string", xlog.Any("res", setRes))
  30.     // get string
  31.     getRes := redisStub.Get("jupiter-redis")
  32.     xlog.Info("redisStub get string", xlog.Any("res", getRes))
  33.     return
  34. }
  35. func (eng *Engine) exampleForRedisClusterStub() (err error) {
  36.     //build redisClusterStub
  37.     redisStub := redis.StdRedisClusterConfig("myredis").Build()
  38.     // set string
  39.     setRes := redisStub.Set("jupiter-redisCluster", "redisClusterStub", time.Second*5)
  40.     xlog.Info("redisClusterStub set string", xlog.Any("res", setRes))
  41.     // get string
  42.     getRes := redisStub.Get("jupiter-redisCluster")
  43.     xlog.Info("redisClusterStub get string", xlog.Any("res", getRes))
  44.     return
  45. }

执行 go run main.go —config=config.toml,可以看到如下图结果 image