npm 包 mwp-consumer 使用教程

介绍

mwp-consumer 是一个用于消费蚂蚁金服中间件平台(Middleware Platform)的 npm 包。它可以在前端 JavaScript 中接入 Middleware 并与 Middleware 进行交互。Middleware 是一种中间件能力，可以通过 Middleware ConnectHub 将业务方与中间件方打通，实现数据的双向传输。mwp-consumer 可以使开发者更加方便地接入 Middleware 进行开发。

本教程将向您介绍如何使用 mwp-consumer。我们将通过一个简单的示例来说明 mwp-consumer 的基本用法。

安装

在使用 mwp-consumer 之前，您需要先安装它。您可以通过 npm 的方式进行安装：

npm install mwp-consumer

使用方法

在您的 JavaScript 代码中，您需要先引入 mwp-consumer：

import MwpConsumer from 'mwp-consumer';

mwp-consumer 的主要接口是 connect() 方法。您可以通过它来与 Middleware 连接。

MwpConsumer.connect({
  appId: '<appid>',
  connectCallback: function (connectId) {
    console.log('Middleware connection established with connectId=' + connectId);
  },
});

通过 connect() 方法您需要提供以下参数:

• appId: 您在 Middleware 平台中创建的应用 ID。
• connectCallback: 连接建立后的回调函数。

在 Middleware 中，您需要将您的应用接入 Middleware ConnectHub，并与 Middleware ConnectHub 建立连接。在 JavaScript 中，您可以通过调用 MwpConsumer.connect() 方法进行连接。当连接建立后，回调函数 connectCallback 将被调用。在回调函数中，您可以获取 Middleware ConnectHub 分配的连接 ID。

mwp-consumer 的另一个重要接口是 subscribe() 方法。您可以通过它来订阅 Middleware 中的消息。

MwpConsumer.subscribe({
  topic: '<topic>',
  messageCallback: function (message) {
    console.log('Received message ' + JSON.stringify(message));
  },
});

通过 subscribe() 方法您需要提供以下参数:

• topic: 您要订阅的消息主题。
• messageCallback: 接收到消息时的回调函数。

在 Middleware 中，您需要给所属 Middleware app 所有的 consumer 实例发送消息。例如，如果您在 JavaScript 中订阅了主题 user.login，则您需要在 Middleware 中将所有的 user.login 的消息发送到 consumer 实例。发送消息的代码示例如下：

String topic = "user.login";
Consumer consumer = hub.getConsumer(topic);
if (consumer != null) {
    Map<String, String> message = new HashMap<String, String>();
    message.put("userId", "12345");
    consumer.sendMessage(new Gson().toJson(message));
}

当 messageCallback 被调用时，您就可以处理 Middleware 中的消息了。

示例代码

以下是一个完整的 mwp-consumer 示例代码：

-- -------------------- ---- -------
------ ----------- ---- ---------------

---------------------
  ------ ----------
  ---------------- -------- ----------- -
    ----------------------- ---------- ----------- ---- ----------- - -----------
  --
---

-----------------------
  ------ -------------
  ---------------- -------- --------- -
    --------------------- ------- - - -------------------------
  --
---

在 Middleware 中，您需要将所有的 user.login 的消息发送到 consumer 实例。在这个简单示例中，我们将在 Middleware 中向 user.login 发送一个名为 {"userId": "12345"} 的消息。当 Middleware 发送消息到 user.login 主题时，您在 JavaScript 中订阅 user.login 主题的回调函数 messageCallback 将会被调用。

结语

mwp-consumer 是一个非常方便的 npm 包，可以实现在前端 JavaScript 中接入 Middleware 并与 Middleware 进行交互。本篇文章向您介绍了 mwp-consumer 的基本用法，您可以通过它轻松地与 Middleware 平台进行交互。希望本文对您有指导意义。

来源：JavaScript中文网 ，转载请注明来源 https://www.javascriptcn.com/post/79344