基于redis实现定时任务的方法详解_redis定时器

redis定时任务

redis定时器

75 浏览量更新于2023-03-03 评论收藏 67KB PDF 举报

身份认证购VIP最低享 7 折!

领优惠券(最高得80元）

资源详情

资源评论

资源推荐

基于基于redis实现定时任务的方法详解实现定时任务的方法详解

主要给大家介绍了基于redis实现定时任务的相关资料，文中通过示例代码介绍的非常详细，对大家学习或者使用

redis具有一定的参考学习价值，需要的朋友们下面来一起学习学习吧

前言前言

业务中碰到的需求（抽象描述一下）：针对不同的用户能够实现不同时间的间隔循环任务。比如在用户注册成功24小时后给用户推

送相关短信等类似需求。

使用crontab?太重，且基本不现实，不可能给每一个用户在服务器上生成一个定时任务。

定时轮询?IO频繁且效率太低

想到经常的使用的redis可以设置缓存时间，应该会有过期的事件通知吧，查了一下文档，果然有相关配置，叫做“键空间事件通

知”。具体说明可参考官方文档。

技术栈技术栈

redis / nodeJs / koa

技术重难点技术重难点

开启redis的键空间通知功能(2.8.0及以上的版本才有此功能)

尽量使用单独的redis db来实现

使用基于redis的分布式锁来实现相关事件不会被重复消费

需要二次使用的信息需要体现在redis缓存的key中

redis cache key使用业务前缀，避免重名覆盖

防止业务服务重启导致nodejs层面的监听失效

"talk is cheap, show me the code "

核心代码

const { saveClient, subClient } = require('./db/redis') // 存储实例和订阅实例需要为两个不同的实例

const processor = require('./service/task')

const config = require('./config/index')

const innerDistributedLockKey = '&&__&&' // 内部使用的分布式锁的key的特征值

const innerDistributedLockKeyReg = new RegExp(`^${innerDistributedLockKey}`)

saveClient.on('ready', async () => {

saveClient.config('SET', 'notify-keyspace-events', 'Ex') // 存储实例设置为推送键过期事件

console.log('redis init success')

})

subClient.on('ready', () => { // 服务重启后依旧可以初始化所有processor

subClient.subscribe(`__keyevent@${config.redis.sub.db}__:expired`) // 订阅实例负责订阅消息

subClient.on('message', async (cahnnel, expiredKey) => {

// 分布式锁的key不做监听处理

if (expiredKey.match(innerDistributedLockKeyReg)) return

// 简易分布式锁，拿到锁的实例消费event

const cackeKey = `${innerDistributedLockKey}-${expiredKey}`

const lock = await saveClient.set(cackeKey, 2, 'ex', 5, 'nx') // 这里的用法可以实现简易的分布式锁

if (lock === 'OK') {

await saveClient.del(cackeKey)

for (let key in processor) {

processor[key](expiredKey) // processor对应的是接收到相关键过期通知后执行的业务逻辑，比如推送短信，然后在相关processor中再次set一个定时过期的key

}

})

console.log('subClient init success')

})

servide/task (processor)

exports.sendMessage = async function sendMessage(expiredKey, subClient) {

// 只处理相关业务的过期事件

if (expiredKey.match(/^send_message/)) {

const [prefix, userId, type] = expiredKey.split('-')

let user = getUser(userId)

if (user.phone) {

push(message) // 伪代码

resetRedisKey(expiredKey, ttl) // 重新把key设置为一段时间后过期，过期后会再次触发本逻辑

}

总结总结

本内容试读结束，登录后可阅读更多

下载后可阅读完整内容，剩余1页未读，立即下载

weixin_38631282

粉丝: 5
资源: 923

会员权益专享

基于redis实现定时任务的方法详解

评论0

会员权益专享

最新资源

基于redis实现定时任务的方法详解

评论0

jobor:基于golang redis实现的分布式定时任务，支持API，shell，python，go等任务类型

redis 定时检测服务是否正常

基于redis的秒杀系统模拟

springboot使用redis实现定时任务

redis实现定时任务

tp5 redis实现定时任务

redis实现定时任务代码

flask+apscheduler+redis实现定时任务持久化

java 使用redis实现定时任务

redis定时任务实现

redis实现分布式定时任务

java redis定时任务

redis查询定时任务

redis定时任务反弹shell

微博与微信朋友关注模型基于redis实现

kratos+ent+redis定时任务 定时更新钱包余额 读取数据

java 基于redis实现的分布式锁工具类

基于redis实现分布式锁

微服务基于redis实现单点登录

基于redis的实现分布式锁

会员权益专享

最新资源

kratos+ent+redis定时任务定时更新钱包余额读取数据