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

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

常见使用场景

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

原文地址:https://www.cnblogs.com/zzayne/p/9196790.html

时间: 2024-11-05 13:40:49

在Golang中使用Redis的相关文章

Golang中使用log(二):Golang 标准库log的实现

前一篇文章我们看到了Golang标准库中log模块的使用,那么它是如何实现的呢?下面我从log.Logger开始逐步分析其实现. 其源码可以参考官方地址 1.Logger结构 首先来看下类型Logger的定义: type Logger struct { mu sync.Mutex // ensures atomic writes; protects the following fields prefix string // prefix to write at beginning of each

在java中使用redis

在java中使用redis很简单,只需要添加jedist.jar,通过它的api就可以了.而且,api和redis的语法几乎完全相同.以下简单的测试: 参考:http://www.runoob.com/redis/redis-java.html 1 package com.test.redis; 2 3 import org.junit.Test; 4 import redis.clients.jedis.Jedis; 5 6 import java.util.HashMap; 7 import

Golang中多用途的defer

defer顾名思义就是延迟执行,那么defer在Golang中该如何使用以及何时使用呢? A "defer" statement invokes a function whose executionis deferred to the moment the surrounding function returns, Golang的官方时这么定义的. 1.那么在什么情况下会调用defer延迟过的函数呢? 从文档中可以知道主要有两种情况: 当函数执行了return 语句后 当函数处于pan

.NET中使用Redis

Redis是一个用的比较广泛的Key/Value的内存数据库,新浪微博.Github.StackOverflow 等大型应用中都用其作为缓存,Redis的官网为http://redis.io/. 最近项目中需要使用Redis,这里简单记录一下Redis的安装,以及如何在.NET中使用Redis. Redis安装与启动 1. 下载Redis Redis本身没有提供Windows版本的,并且在Windows上也不太稳定,一般都将其部署到Linux环境下,Redis可以在其官网上下载, MSOpenT

Golang中使用log(一):Golang 标准库提供的Log

Golang的标准库提供了log的机制,但是该模块的功能较为简单(看似简单,其实他有他的设计思路).不过比手写fmt. Printxxx还是强很多的.至少在输出的位置做了线程安全的保护.其官方手册见Golang log (天朝的墙大家懂的).这里给出一个简单使用的例子: package main import ( "log" ) func main(){ log.Fatal("Come with fatal,exit with 1 \n") } 编译运行后,会看到程

Go_18: Golang 中三种读取文件发放性能对比

Golang 中读取文件大概有三种方法,分别为: 1. 通过原生态 io 包中的 read 方法进行读取 2. 通过 io/ioutil 包提供的 read 方法进行读取 3. 通过 bufio 包提供的 read 方法进行读取 下面通过代码来验证这三种方式的读取性能,并总结出我们平时应该使用的方案,以便我们可以写出最优代码: package main import ( "os" "io" "bufio" "io/ioutil"

Docker中的Redis容器如何连接上进行操作?

Docker中的Redis容器如何连接上进行操作? 1.登录putty有如下信息: 公用虚拟 IP (VIP)地址42.159.156.115内部 IP 地址10.205.178.22IP address for eth0:    10.205.178.22IP address for docker0: 172.17.42.1 2. 下载 http://download.redis.io/redis-stable/redis.conf修改如下字段 # requirepass foobared去掉

.NET中使用Redis (二)

很久以前写了一篇文章 .NET中使用Redis 介绍了如何安装Redis服务端,以及如何在.NET中调用Redis读取数据.本文简单介绍如何设计NoSQL数据库,以及如何使用Redis来存储对象. 和传统的关系型数据库不同,NoSQL大部分都是以键值对存储在内存中的,我们不能直接把RDBMS里面的一些做法直接移植到NoSQL中来,一个最主要的原因是,在NoSQL中缺少RDBMS中的一些诸如join ,union以及一些在关系型数据库中效率很高的执行语句,这些在NoSQL不能很好的支持,或者说效率

Go_14:GoLang中 json、map、struct 之间的相互转化

1. golang 中 json 转 struct <1. 使用 json.Unmarshal 时,结构体的每一项必须是导出项(import field).也就是说结构体的 key 对应的首字母必须为大写.请看下面的例子: package commontest import ( "testing" "encoding/json" ) type Person struct { name string age int } func TestStruct2Json(