小程序中使用nats.ws 实现消息订阅

在微信小程序中，如果你想通过 NATS（Node.js 的一个高性能、轻量级的消息代理服务器）实现消息订阅，你需要先安装 `nats` 和 `nats-streaming-client` 这两个npm库。NATS.ws 是 NATS 客户端的一个基于 WebSockets 版本，它提供了一种可靠的方式向服务器发送和接收消息。

以下是基本步骤：

1. **安装依赖**:
使用 npm 或 yarn 安装所需的库：

   npm install nats ws

2. **创建连接**:
创建一个新的 NATS 连接并监听WebSocket，通常在小程序的生命周期钩子如 `onLoad` 中完成：

   const nats = require('nats');
   const NatsStreamingClient = require('nats-streaming-client');

   wx.onLoad(() => {
     const nc = new nats.Connection({
       servers: ['ws://your-nats-server.com:4222'], // 替换为你实际的NATS服务器地址
     });

     const ns = new NatsStreamingClient(nc);
   });

3. **订阅主题**:
通过 `ns.subscribe` 函数订阅一个主题，指定处理消息的回调函数：

   ns.subscribe('your-topic', (msg) => {
     console.log(`Received message on topic ${msg.subject}:`, msg.data);
   }, { durableName: 'subscriber-name'}); // 设置持久化订阅名称

4. **开始连接**:
连接到NATS服务器后，可以使用 `nc.connect()` 和 `ns.connect()` 开始订阅：

   nc.connect();
   ns.connect();

5. **断开连接**:
当不再需要时，记得调用 `nc.close()` 和 `ns.close()` 来关闭连接。