redis键空间通知使用实现_Redis

来源:脚本之家  责任编辑:小易  
目录
导语
实现
在业务中使用
总结

导语

最近在开发一个定时活动,而且活动是多个场次的。这个是后就需要在活动开始的时候推送信息给客户端,结束的时候也要推送一次。简单的设计方案就是将配置缓存在redis,然后每隔一秒就轮询reids,获取配置信息,然后判断是不是到活动开始或者结束的时间点,然后推送给客户端。

但是,这里会有一个问题,如果没有到活动开始或结束的时间点,这里会造成很多无用的轮询操作。这个操作不但增大了对这个key的访问量,同时也会占用cpu,降低机器性能。

redis在2.8.0版本提供了一个键空间通知功能机制,对于这个功能的详细描述,可以查阅官方文档。简单总结就是,客户端可以订阅一个key,当这个可以发生改变时,redis会通知到已经订阅的客户端。

实现

这个实现也很简单,我们可以通过一个demo来看看如何使用这个机制。

package main

import (
   "context"
   "fmt"
   "github.com/go-redis/redis/v8"
   "time"
)

var redisCli *redis.Client

func init() {
   // 连接redis
   redisCli = redis.NewClient(&redis.Options{
      Addr:     "127.0.0.1:6379",
      Password: "redis123",
   })
}

/*
 * redis key 过期自动通知
 */
func SetExpireEvent() {
   // 设置一个键,并且3秒钟之后过期
   redisCli.Set(context.Background(), "test_expire_event_notify", "测试键值过期通知", 3*time.Second)
}

func SubExpireEvent() {
   // 订阅key过期事件
   sub := redisCli2.Subscribe(context.Background(), "__keyevent@0__:expired")
   
   // 这里通过一个for循环监听redis-server发来的消息。
   // 当客户端接收到redis-server发送的事件通知时,
   // 客户端会通过一个channel告知我们。我们再根据
   // msg的channel字段来判断是不是我们期望收到的消息,
   // 然后再进行业务处理。
   for {
      msg := <-sub.Channel()
      fmt.Println("Channel ", msg.Channel)
      fmt.Println("pattern ", msg.Pattern)
      fmt.Println("pattern ", msg.Payload)
      fmt.Println("PayloadSlice ", msg.PayloadSlice)
   }
}

func main() {
   SetExpireEvent()
   go SubExpireEvent()
   
   // 这里sleep是为了防止main方法直接推出
   time.Sleep(10 * time.Second)
}

代码结果输出如下:

上面代码实现逻辑很简单,核心逻辑就是订阅__keyevent@0__:expired这个事件,然后一个循环等待事件的通知。值得注意的是,要启用这个特性需要修改配置文件,启用notify-keyspace-events这个配置,可以参考配置文件中的注释对不同事件进行启用。

在业务中使用

回到开始提及的业务场景,如何在这种场景中使用redis的机制呢?其实很简单,当活动配置到数据库之后,会有一个更新缓存的步骤。在将数据设置在活动缓存时,只要我们计算当前时间到活动开始/结束这个时间差,将这个差作为键的过期时间。

例如,活动id1的开始时间为t0, 结束时间为t2, 当前时间为t。这个时候就可以这么设置:

// 活动开始的key设置
redisCli.Set(context.Background(), "id1:start", "活动开始了", t0 - t)
// 活动结束结束的key设置
redisCli.Set(context.Background(), "id1:start", "活动开始了", t1 - t)

通过这么设置,当活动开启/结束就可以接收到相应的通知了。

总结

这种方案其实可以完全满足文中的需求场景,但是这种方案其实也存在一些问题。其实这些问题在redis文档中也有相应说明。

第一,redis-server在推送这个事件通知时,只要订阅了这个事件的客户端端都会收到这个消息。通常,我们的业务都是跑在多个结点中,所以这个时候就要根据场景看要不要进行业务的原子操作。 第二,redis-server只会推送一次这个通知。假如说在redis-server推送这个通知时,结点挂了或者由于其他异常情况没有收到消息,redis-server不会再重新推送。 第三,通知可能会延迟。由于redis实现机制,对于过期的键,会有两种机制进行处理,一种是当命令访问键时,发现键已过期。另一种是通过后台系统在后台逐步查找过期的键,以便能够收集那些从未被访问的键。所以会有出现延迟的可能。

本文介绍了使用redis的键空间通知机制来实现了一种业务场景,当然这种方式并不是最好的,还有其他方式来实现。在实际开发中会有很多的因素要考虑,而且实现方式也是多种多样,这个就需要我们分析每一种方案的利弊,然后进行抉择。

到此这篇关于redis键空间通知使用实现的文章就介绍到这了,更多相关redis键空间通知 内容请搜索真格学网以前的文章或继续浏览下面的相关文章希望大家以后多多支持真格学网!

您可能感兴趣的文章:Redis开启键空间通知实现超时通知的步骤详解

  • 本文相关:
  • redis哈希类型_动力节点java学院整理
  • redis底层数据结构详解
  • 解析redis cluster原理
  • redis sentinel服务配置流程(详解)
  • 浅谈redis在项目中的应用
  • redis适合场景八点总结
  • redis 出现错误1067的解决办法
  • redis在windows中下载及安装、设置教程
  • redis遍历所有key的两个命令(keys 和 scan)
  • 银河麒麟v10sp1服务器系统安装redis不能使用的快速解决办法
  • 如何使用redis实现订阅发布模式
  • 使用redis客户端时不能使用快捷键怎么使用
  • PHP使用redis实现统计缓存mysql压力的方法
  • PHP使用Redis实现Session共享的实现示例
  • Java怎么使用memcached和redis实现缓存
  • 怎么使用memcached和redis实现缓存?
  • PHP使用php-resque库配合Redis实现MQ消息队列的教程
  • 如何使用Docker实现Redis 3.0集群的一键部署交付
  • 如何利用Redis扩展数据服务,实现分片及高可用
  • redis 队列有几种实现策略
  • redis与oracle之间怎么实现数据同步?
  • 网站首页网页制作脚本下载服务器操作系统网站运营平面设计媒体动画电脑基础硬件教程网络安全mssqlmysqlmariadboracledb2mssql2008mssql2005sqlitepostgresqlmongodbredisaccess数据库文摘数据库其它首页redisredis开启键空间通知实现超时通知的步骤详解redis哈希类型_动力节点java学院整理redis底层数据结构详解解析redis cluster原理redis sentinel服务配置流程(详解)浅谈redis在项目中的应用redis适合场景八点总结redis 出现错误1067的解决办法redis在windows中下载及安装、设置教程redis遍历所有key的两个命令(keys 和 scan)银河麒麟v10sp1服务器系统安装redis不能使用的快速解决办法超强、超详细redis数据库入门教程redis常用命令、常见错误、配置技redis中5种数据结构的使用场景介redis操作命令总结64位windows下安装redis教程redis中使用redis-dump导出、导入redis 密码设置和查看密码的方法redis中统计各种数据大小的方法redis常用命令小结让redis在你的系统中发挥更大作用redis cluster 集群搭建你会吗redis3.2配置文件redis.conf详细说明redis配置文件redis.conf中文版(基于2.4还不懂redis?看完这个趣味小故事就明白了基于redis分布式锁的实现代码解决redis连接无法正常释放的问题redis cluster 字段模糊匹配及删除通俗易懂的redis数据结构基础教程(入门)redis学习之rdb、aof与复制时对过期键的处redis value过大问题(键值过大)
    免责声明 - 关于我们 - 联系我们 - 广告联系 - 友情链接 - 帮助中心 - 频道导航
    Copyright © 2017 www.zgxue.com All Rights Reserved