使用开放的Web服务发布订阅消息传递

<code class="bash">export OSC_ACCESS_TOKEN=<access-token-copied-above></code>

<code class="bash">mkdir pubsub
cd pubsub
npm init</code>

<code class="bash">npm install --save @osaas/client-core @osaas/client-services</code>

<code class="javascript">const { context, getportsforinstance } = require('@osaas/client-core');
const {
  createvalkeyiovalkeyinstance,
  getvalkeyiovalkeyinstance
} = require('@osaas/client-services');

async function setup() {
  // ... (代码与原文相同)
}</code>

<code class="bash">npm install --save ioredis</code>

<code class="javascript">const redis = require('ioredis');

async function main() {
  // ... (代码与原文相同)
}

main();</code>

<code class="bash">node subscriber.js</code>

<code class="javascript">async function publishmessage(topic, message) {
  // ... (代码与原文相同)
}

if (!process.argv[2]) {
  console.error('please provide a message to publish');
  process.exit(1);
}
publishmessage('messages', process.argv[2]);</code>

<code class="bash">node publisher.js "Hello world"</code>