zoukankan      html  css  js  c++  java
  • egg.js redis subscribe multiple channel

    'use strict';
    
    function InitRedisStrategy(agent, name, channel) {
      class RedisStrategy extends agent.ScheduleStrategy {
        start() {
          // 订阅其他的分布式调度服务发送的消息,收到消息后让一个进程执行定时任务
          agent.redis.on('message', (c, message) => {
            if (c === channel) {
              this.sendOne(message)
            }
          })
        }
      }
    
      agent.schedule.use(name, RedisStrategy)
    }
    
    // {app_root}/agent.js
    module.exports = agent => {
      // class ClusterStrategy extends agent.ScheduleStrategy {
      //   start() {
      //     // 订阅其他的分布式调度服务发送的消息,收到消息后让一个进程执行定时任务
      //     // 用户在定时任务的 schedule 配置中来配置分布式调度的场景(scene)
      //     // such as mq / redis subscribe
      //     // agent.mq.subscribe(schedule.scene, () => this.sendOne());
      //   }
      // }
      // agent.schedule.use('cluster', ClusterStrategy);
    
      agent.messenger.on('egg-ready', () => {
        agent.redis.subscribe('task1');
        agent.redis.subscribe('task2');
        agent.redis.subscribe('task3');
      });
    
      InitRedisStrategy(agent, 'redis1', 'task1');
      InitRedisStrategy(agent, 'redis2', 'task2');
      InitRedisStrategy(agent, 'redis3', 'task3');
    };
  • 相关阅读:
    vba 填写 Workbok 名片
    VBA 插入和删除工作表
    VBA for each 循环语句
    VBA 中的各种循环
    VBA 的 Join 函数
    VBA 计算数组的最大索引和最小索引
    VBA 变量赋值
    VBA 声明变量
    观察样本的变异程度
    python 将数据写入 Excel 表格
  • 原文地址:https://www.cnblogs.com/ChobitsSP/p/8759230.html
Copyright © 2011-2022 走看看