egg-easy-process-cache v0.3.0

egg-easy-process-cache

依赖说明

依赖的 egg 版本

开启插件

// config/plugin.js
exports.easyProcessCache = {
  enable: true,
  package: 'egg-easy-process-cache',
};

使用场景

• 我在一些小型项目中，经常用到一些少量的数据，但又不想搭 redis，而且部署在生产的 Egg 项目是多进程模式的，所以缓存逻辑稍微复杂点，所以封装了该库，方便使用
• 优点
  • 不依赖其他的库，实现 Egg 的多进程缓存
• 缺点
  • 每个进程都有一份缓存，所以缓存的数据量只能少

在 app.js 中

export default class App {
  constructor(app) {
    this.app = app;
    this.init();
  }

  async init() {
    const { app } = this;
    const ctx = await this.app.createAnonymousContext();
    app.messenger.on(ctx.getProcessCacheEvent.ALL_WORKER_READY, async () => {
      // 监听了 ALL_WORKER_READY 事件，当所有子进程都准备好之后，你可以在这回调进行初始化数据
      // 该回调只会随机被某个子进程触发，而不是全部子进程都触发
      await ctx.service.qrcode.index.initStoreData();
    });
  }
}

更新缓存数据

function test() {
  // 当你要更新数据的时候，通知给 agent，并把数据带过去就行了
  // agent 会再通知全部子进程进行更新
  this.ctx.app.messenger.sendToAgent(this.ctx.getProcessCacheEvent.CACHE_COVER, data)
}

详细配置

config

config.easyProcessCache = {
    primaryKey: 'id',
    cacheField: [
      'id',
      'link'
    ], // 缓存的字段，不传就缓存全部
  };

Api

我在上下文添加了两个变量：

function test() {
  this.ctx.getProcessCache() // 返回缓存对象
  this.ctx.getProcessCacheEvent = {
    CACHE_COVER,
    CACHE_UPDATE,
    CACHE_PUSH,
    CACHE_CLEAR,
    CACHE_UPDATE_BY_KEY,
    WORKER_READY,
    ALL_WORKER_READY,
  } // getProcessCacheEvent 缓存了各个触发的事件
}

Cache 对象方法

不建议通过 Cache 对象去更新缓存数据。要修改 Cache 对象的值，要用事件通知 agent 进行更新

预设的 agent 事件

上面的通知，都是先更新 agent 进程的缓存数据，然后 agent 进程再通知其他子进程进行全覆盖操作

单元测试

提问交流

请到 egg issues 异步交流。

License

MIT