在Golang中使用Redis的方法示例

周五上班的主要任务是在公司老平台上用redis处理一个队列问题,顺便复习了一下redis操作的基础知识,回来后就想着在自己的博客demo里,用redis来优化一些使用场景,学习一下golang开发下redis的使用。

Redis简单介绍

简介

关于Redis的讨论,其实在现在的后台开发中已经是个老生常谈的问题,基本上也是后端开发面试的基本考察点。其中 Redis的背景介绍和细节说明在这里就不赘述。不管怎么介绍,核心在于Redis是一个基于内存的key-value的多数据结构存储,并可以提供持久化服务。基于内存的特性决定了Redis天然适合高并发的数据读写缓存优化,同时也带来了内存开销过大的问题。所以在一些特定情景下,Redis是一把无往不利的大杀器,值得深入学习。

学习Redis的一个难点或者说入门点,我个人感觉在于对象存储理念的转变。刚接触 Redis 时,我刚从大学毕业,脑子里基本都是关系型数据存储的理念,使用时总想着靠数据内的关系来建立数据之间的联系,用起来很不顺手。后来慢慢入门了才感受到了一些操作的好处。举个栗子,比如查询用户在某个文章下的评论,用 sql 的思路就是搜索评论表里面用户ID和文章ID匹配的数据,有时还需要联合查询出其他信息,但是如果是 Redis 操作,以'前缀:文章ID:用户ID'为key,比如'comment:666:888'就可以快速取出用户评论,十分方便。 Redis 的强大远不仅如此,可以在实践中慢慢体会。

主要数据结构

Redis主要有五种基本数据结构,满足了绝大多数缓存结构的需要,如果你在使用一种结构存储时感觉别扭时,很有可能是选错了存储结构,可以考虑一下其他结构的正确实现。

  1. String ,可以是字符串、整数和浮点数。如果是序列化数据,并涉及到修改操作的话,不推荐用 string ,可以考虑用 Hash
  2. Hash, key-value 对象,可以存放对象数据,比如用户信息之类。
  3. List,有序数据集合,元素可以重复,用 LPUSH LPOP RPUSH RPOP 等指令组合可以实现栈和队列操作。
  4. Set,无序集合,元素唯一。
  5. Sorted Set,Sort的有序版,可以设定 Score 值来决定元素排序,适合用户排名这样的业务场景。

常见使用场景

  1. 高并发下数据缓存。 比如在某个场景下,大量日志同时写入数据库会给服务器带来巨大压力,这时可以先将数据写入 redis 中,再由 redis 写入数据库,减轻同时写入压力。
  2. 热点信息快速显示。假设现在有一个新闻首页,需要快速显示各栏目前20条热点新闻,如果直接查询数据库,在大量用户同时访问下,会消耗极大数量的数据库请求。这时就可以用 redis 来优化,在新闻录入的时候将标题、时间和来源写入 redis 中,客户端访问时,可以从内存中一次性取出当天热单新闻列表,极大地提高请求速度和节约了服务器开销。
  3. 保存会话信息。可以将登录后用户信息缓存入 redis 并同时设置 key 过期时间,这样后台 api 过滤请求时,就可以从内存中读取用户信息,而且 redis 的过期机制,天然支持用户身份有效期校验,用起来十分方便。
  4. 统计计数。比如系统中常见一个功能是限制同一用户固定时间段内的登录次数或者所有请求次数,这时就可以以用户id为key,次数值为value,将计数信息缓存起来,并且有 INCRBY 命令原生支持。
  5. 其他。Redis的应用场景十分广发,队列、发布订阅、统计分析等等,可以看看其他文章的介绍说明。

Golang连接Redis

使用 Golang 开发的一大直观感受就是,基本上你日常遇到的开发问题,都有官方或者第三方包帮你辅助实现,同时这些包都是开源的,只要你感兴趣,都可以深入到包的内部实现去学习理解包的实现思路和方法。当然这也有利有弊,第三包的不稳定和质量参差不齐也增加了一些开发成本,目前还是感受利大于弊。研究好的包源码实现,也是目前我的一个学习方向。

garyburd/redigo 包简介

garyburd/redigo 包是网上很多博文都在推荐使用的一个高Star的 Redis 连接包,但是当我自己去 Github 的项目地址 garyburd/redigo上查看 API 时,发现这个项目目前是归档状态,项目已经迁移到了 gomodule/redigo ,同时包的获取也理所当然地改成了 go get github.com/gomodule/redigo/redis ,这已经不是我第一次感受了第三方包的不稳定,之前用 dep 进行包管理时,就遇到过 dep 拉取的包版本和本地包版本 API 冲突的问题,这个有时间单独再说。总之,暂时不管这两个包的详细区别,以下就以新包为准,介绍下 redigo 包使用。

建立连接池

Redigo Pool 结构维护一个 Redis 连接池。应用程序调用 Get 方法从池中获取连接,并使用连接的 Close 方法将连接的资源返回到池中。一般我们在系统初始化时声明一个全局连接池,然后在需要操作 redis 时获得连接,执行指令。

pool := &redis.Pool{
    MaxIdle:   3, /*最大的空闲连接数*/
    MaxActive:  8, /*最大的激活连接数*/
    Dial: func() (redis.Conn, error) {
      c, err := redis.Dial("tcp", '链接地址,例如127.0.0.1:6379', redis.DialPassword('密码'))
      if err != nil {
        return nil, err
      }
      return c, nil
    }
}
c:=pool.Get()
defer c.Close()

执行指令

查看源码,发现 Conn 接口有一个执行 Redis 命令的通用方法:

```

//gomodule/redigo/redis/redis.go

// Conn represents a connection to a Redis server.

type Conn interface {

// Close closes the connection.

Close() error

// Err returns a non-nil value when the connection is not usable.
Err() error

// Do sends a command to the server and returns the received reply.
Do(commandName string, args ...interface{}) (reply interface{}, err error)

// Send writes the command to the client's output buffer.
Send(commandName string, args ...interface{}) error

// Flush flushes the output buffer to the Redis server.
Flush() error

// Receive receives a single reply from the Redis server
Receive() (reply interface{}, err error)
}

```

http://redis.io/commands 中的 Redis 命令参考列出了可用的命令。 do 的参数和 redis-cli 命令参数格式一致,比如 SET key value EX 360 对应函数调用为 Do("SET", "key", "value","EX",360) ,常用的命令示例有:

c:=pool.Get()
defer c.Close()
//存值,
_, err := c.Do("SET", "key", "value")
//设置过期时间
_, err := c.Do("SET", "key", "value","EX",360)
//存int
_, err := c.Do("SET", "key", 2)

//取值
v,err:=redis.String(c.Do("GET","key"))
bytes, err := redis.Bytes(c.Do("GET", "key"))

总结

golang 中连接使用 redis 相对比较简单,所以暂时也没什么其他好说的,如果后面自己使用过程中发现有遗漏再进行补充,关键还是在于熟悉 redis-cli 原生的指令操作。

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持我们。

(0)

相关推荐

  • python连接MySQL、MongoDB、Redis、memcache等数据库的方法

    用Python写脚本也有一段时间了,经常操作数据库(MySQL),现在就整理下对各类数据库的操作,如后面有新的参数会补进来,慢慢完善. 一,python 操作 MySQL:详情见:[apt-get install python-mysqldb] 复制代码 代码如下: #!/bin/env python# -*- encoding: utf-8 -*-#-------------------------------------------------------------------------

  • 将MongoDB作为Redis式的内存数据库的使用方法

     基本思想 将MongoDB用作内存数据库(in-memory database),也即,根本就不让MongoDB把数据保存到磁盘中的这种用法,引起了越来越多的人的兴趣.这种用法对于以下应用场合来讲,超实用: 置于慢速RDBMS系统之前的写操作密集型高速缓存 嵌入式系统 无需持久化数据的PCI兼容系统 需要轻量级数据库而且库中数据可以很容易清除掉的单元测试(unit testing) 如果这一切可以实现就真是太优雅了:我们就能够巧妙地在不涉及磁盘操作的情况下利用MongoDB的查询/检索功能.可

  • Linux系统安装NoSQL(MongoDB和Redis)步骤及问题解决办法(总结篇)

    如下是我工作中的记录,介绍的是linux系统下NoSQL:MongoDB和Redis的安装过程和遇到的问题以及解决办法: 需要的朋友可以按照如下步骤进行安装,可以快速安装MongoDB和Redis,希望可以帮助大家:)! 一.MongoDB 1.MongoDB安装 (1)将安装包mongodb-linux-i686-3.0.2.tgz拷贝到要安装的服务器中 这里我用的rz命令,如果不支持需要安装yum -y install lrzsz (2)解压安装程序 tar xzvf mongodb-lin

  • Go语言中通过Lua脚本操作Redis的方法

    前言 为了在我的一个基本库中降低与Redis的通讯成本,我将一系列操作封装到LUA脚本中,借助Redis提供的EVAL命令来简化操作. EVAL能够提供的特性: 可以在LUA脚本中封装若干操作,如果有多条Redis指令,封装好之后只需向Redis一次性发送所有参数即可获得结果 Redis可以保证Lua脚本运行期间不会有其他命令插入执行,提供像数据库事务一样的原子性 Redis会根据脚本的SHA值缓存脚本,已经缓存过的脚本不需要再次传输Lua代码,减少了通信成本,此外在自己代码中改变Lua脚本,执

  • centos7 + php7 lamp全套最新版本配置及mongodb和redis教程详解

    所有软件的版本一直会升级,注意自己当时的版本是不是已经更新了. 首先装centos7 如果你忘了设置swap分区,下面的文章可以教你怎么补一个上去: http://www.jb51.net/os/201409/338170.html 装好centos7后默认是不能上网的 cd /etc/sysconfig/network-scripts/ 找到形如ifcfg-enp0s3的文件,修改onboot=yes 然后 service network restart 安装apache2 (centos里叫

  • 在CentOS 7下安装Redis和MongoDB教程

    前一篇折腾了node.js,这一次折腾下Redis和Mongodb,这样基本就安装好nodejs的整套开发环境了. Redis 在CentOS下安装Redis也比较简单,按照步骤一步一步的操作,基本不会出错. 1.切换到 /usr/src目录(如果你安装在别的目录,注意后面要一些路径也要修改),下载Redis,目前最新的是2.8.13版本 d /usr/src wget http://download.redis.io/releases/redis-2.8.13.tar.gz 2.解压,切换目录

  • Go语言操作redis用法实例

    本文实例讲述了Go语言操作redis用法.分享给大家供大家参考.具体如下: 复制代码 代码如下: package main import (  "fmt"  "log"  "redis" ) func main() {  //DefaultSpec()创建一个连接规格  spec := redis.DefaultSpec().Db(0).Password("");  //创建一个新的syncClient,并连接到Redis的服

  • go语言操作redis连接池的方法

    本文实例讲述了go语言操作redis连接池的方法.分享给大家供大家参考.具体实现方法如下: 复制代码 代码如下: func newPool(server, password string) *redis.Pool {     return &redis.Pool{         MaxIdle: 3,         IdleTimeout: 240 * time.Second,         Dial: func () (redis.Conn, error) {             c

  • Django中redis的使用方法(包括安装、配置、启动)

    一.安装redis: 1.下载: wget http://download.redis.io/releases/redis-3.2.8.tar.gz 2.解压 tar -zxvf redis-3.2.8.tar.gz 3.复制,放到/usr/local目录下 sudo mv ./redis-3.2.8 /usr/local/redis 4.进入到redis目录下 cd /usr/local/redis/ 5.生成 sudo make 6.测试,时间会比较长 sudo make test 7.安装

  • redis之django-redis的简单缓存使用

    本文介绍了redis之django-redis的简单缓存使用,分享给大家,具体如下: 自定义连接池 这种方式跟普通py文件操作redis一样,代码如下: views.py import redis from django.shortcuts import render,HttpResponse from utils.redis_pool import POOL def index(request): conn = redis.Redis(connection_pool=POOL) conn.hs

随机推荐