node集群下重复消费redis的过期通知

没人回复..........

不会，在agent.js 里定义，多看看egg文档就行

'use strict'; module.exports = function(agent) { const dbIndx = agent.config.redis.clients.clientSub.db; const subscribeTopic = __keyevent@${dbIndx}__:expired;

agent.messenger.on('egg-ready', () => {
    if (agent.config.redis.app) {
        agent.redis.get('clientSub').subscribe(subscribeTopic, (err, result) => {
            if (err) {
                throw err;
            }
            console.info(result, `subscribe:${subscribeTopic} succeed`);
        });
    }
});

class CustomStrategy extends agent.ScheduleStrategy {
    start() {
        if (agent.config.redis.app) {
            agent.redis.get('clientSub').on('message', (channel, message) => {
                this.sendOne([ channel, message ]);
            });

        }
    }
}
agent.schedule.use('redispush', CustomStrategy);

};