进程间通信

Pandora.js 提供了一个进程间对象代理的功能，可以方便的实现跨进程访问、调用。

直接发布对象和获取对象代理

看下面的例子：

  1. const {getProxy, publishObject} = require('dorapan');
  3. async function main() {
  5.   // 发布 Math 到 IPC-Hub
  6.   await publishObject('math', Math);
  8.   // 获得对象代理
  9.   const proxy = await getProxy('math');
  11.   // 所有方法直接 await 调用
  12.   const val = await proxy.abs(-1234);
  13.   console.log(val);
  15. }
  16. main().catch(console.error);

Service 使用 IPC-Hub

Pandora.js 提供了进程间的对象代理功能，Service 可以便捷的发布到 IPC-Hub 中。

procfile.js

  1. module.exports = function (pandora) {
  3.   // 定义两个进程
  4.   pandora
  5.     .process('a')
  6.     .scale(1);
  7.   pandora
  8.     .process('b')
  9.     .scale(1);
  11.   // 定义两个 Service 
  12.   // （该例子 Service 实现全部写在 procfile.js 中了，这不是一个好的实践）
  13.   class ServiceA {
  14.     async getPid() {
  15.       return process.pid;
  16.     }
  17.   }
  18.   class ServiceB {
  19.     constructor(context) {
  20.       this.context = context;
  21.     }
  22.     async start() {
  23.       // 或者 require('dorapan').getProxy();
  24.       const serviceA = await this.context.getProxy('serviceA');
  25.       const pid = await serviceA.getPid();
  26.       console.log();
  27.       console.log();
  28.       console.log('pid from serviceA', pid);
  29.       console.log('pid from self', process.pid);
  30.       console.log();
  31.       console.log();
  32.     }
  33.   }
  35.   // 定义 ServiceA 在 进程 a
  36.   pandora
  37.     .service('serviceA', ServiceA)
  38.     .process('a')
  39.     // 标识 serviceA 发布到 IPC-Hub 中
  40.     .publish();
  42.   // 定义 ServiceB 在进程 b
  43.   pandora
  44.     .service('serviceB', ServiceB)
  45.     .process('b');
  47. }

获得 IPC-Hub 整体对象

IPC-Hub 还有一些别的能力，可以通过 require('dorapan').getHub() 获得。

具体参考 pandora-hub 包下的 Facade 类的 API进程间通信 - 图1。