Redis节点监听SET事件，并为每个请求设置TTL

Question

在我的Nodejs应用程序中，我使用了一个在Redis数据库中设置密钥的库。因此，我需要监听每个创建/更新密钥的请求，并在每个密钥上添加一个ttl(无论它是否已经存在(。

我有我的主要Redis客户端(为Redis数据库添加密钥(：

const redisClient = createClient({
url: redisUrl,
tls: {
ca: Buffer.from(redisCertBase64, 'base64').toString('utf-8'),
},
})

我添加了另一个应该监听set事件的客户端：

const subscriberRedis = redisClient.duplicate()
function done(err) {
logger.error('Notifications not active')
if (err) {
logger.error(err.stack || err.message || err)
}
}
const eventType = 'notify-keyspace-events'
subscriberRedis.config('get', eventType, (err, conf) => {
if (err) {
logger.debug('subscriberRedis:get =>', err.message)
return done(err)
}
logger.debug('conf =>', conf)
if (conf[1].indexOf('EKx') < 0) {
subscriberRedis.config('set', eventType, conf[1] + 'EKx', function (err) {
if (err) {
logger.debug('subscriberRedis:set =>', err.message)
return done(err)
}
})
}
})
const EVENT_SET = '__keyevent@0__:set'
subscriberRedis.on('message', function (channel, key) {
switch (channel) {
case EVENT_SET:
logger.info('Key "' + key + '" set!')
break
}
})
subscriberRedis.subscribe(EVENT_SET)

当我运行此代码时，我会得到由subscriberRedis.config('set',...)记录的日志subscriberRedis:set => ERR only (P)SUBSCRIBE / (P)UNSUBSCRIBE / PING / QUIT allowed in this context

我不确定我在这里错过了什么。

编辑

我把代码改成了这个，现在它开始工作了。然而，你认为当我开始生产时，"种族状况"问题仍然存在吗？

const redisClient = createClient({
url: redisUrl,
tls: {
ca: Buffer.from(redisCertBase64, 'base64').toString('utf-8'),
},
})
/**
* Subscriber listening to `set` events
**/
const subscriber = redisClient.duplicate()
const EVENT_SET = '__keyevent@0__:set'
subscriber.on('message', function (channel, key) {
switch (channel) {
case EVENT_SET:
redisClient.expire(key, 300)
logger.debug('Key "'.red + key + '" set!'.yellow)
break
}
})
subscriber.subscribe(EVENT_SET)

Answer 1

问题是，当您调用subscriberRedis.config('set'时，您的subscriberRedis已经订阅了subscriberRedis.subscribe(EVENT_SET)。

而且，在订阅期间，您不能将此连接用于subscriberRedis.config('set'。