使用 @google-cloud/pubsub npm 包进行发布-订阅消息传递-JavaScript中文网-JavaScript教程资源分享门户

前言

在分布式应用程序的开发中，消息传递是一种可靠且轻量级的通信方式。@google-cloud/pubsub 是 Google Cloud 中的一个服务，可以帮助我们轻松地实现发布-订阅消息传递。利用 pubsub，我们可以通过 Google Cloud 提供的 REST API 进行应用程序和服务之间的通信。

本文将介绍如何在 Node.js 环境下使用 @google-cloud/pubsub 包，并提供一些示例代码和说明，以帮助您更好地理解如何使用该功能。

安装和设置

在使用 @google-cloud/pubsub 包之前，您需要先安装它。您可以在终端中使用以下命令进行安装：

$ npm install --save @google-cloud/pubsub

在使用该包之前，您还需要设置 Google Cloud Console 中的项目和认证凭据。具体步骤如下：

在 Google Cloud Console 中创建一个项目。
启用 Pub/Sub API。
在“凭据”部分中创建一组服务账户密钥并下载 JSON 文件。
将 JSON 文件中的内容保存在安全位置，并记录其路径。

接下来，您需要在 Node.js 项目的代码中引用 @google-cloud/pubsub 包，并设置您的凭据。您可以使用以下代码设置凭据：

const {PubSub} = require('@google-cloud/pubsub');
const pubSub = new PubSub({
  projectId: 'PROJECT_ID',
  keyFilename: '/path/to/keyfile.json'
});

在代码中调用 PubSub() 构造函数。在 projectId 参数中，输入您在 Google Cloud Console 中创建的项目的项目 ID。在 keyFilename 参数中，输入您在 Google Cloud Console 中下载的 JSON 文件的路径。

发布-订阅消息传递

完成了设置之后，我们就可以开始使用 Pub/Sub 进行发布-订阅消息传递了。下面是一个基本的 Pub/Sub 消息传递示例，其中包括两个主要阶段：发布构建消息和订阅器监听并处理此类消息。

发布构建消息

在发布消息之前，您需要有一个有效的 Pub/Sub 话题。在下面的代码中，我们使用 pubSub.topic() 方法创建并返回一个名为“test”（可以替换为您自己的话题名称）的 Pub/Sub 话题。如果话题不存在，则会自动创建该话题：

async function publishMessage() {
  const topic = pubSub.topic('test');
  const data = JSON.stringify({ message: 'Hello, world!' });
  const messageId = await topic.publish(Buffer.from(data));
  console.log(`Message ${messageId} published.`);
}

在发布消息之前，我们需要将消息保存为字符串。在本例中，我们定义了名为“message”的 JSON 对象，然后使用 JSON.stringify() 将其转换为字符串，并将其存储在变量 data 中。之后，我们将此消息发布到话题中，此处的 message ID 是我们将在后续的示例中使用的消息的唯一 ID。

使用订阅器

在订阅器的代码中，我们使用 pubSub.subscription() 方法创建订阅器并开始监听话题。当有新消息时，订阅器将订阅该消息并调用处理器函数。下面是一个基本的订阅器代码示例：

async function subscribe() {
  const subscription = pubSub.subscription('test');
  console.log('Listening for messages...');
  subscription.on('message', (message) => {
    console.log(`Received message: ${message.data}`);
    message.ack();
  });
}

在示例代码中，我们首先创建了一个订阅器，其中的“test”是刚刚创建的 Pub/Sub 话题的名称。然后我们使用订阅器上的 on() 方法监听新消息。当新消息到达时，订阅器将调用 message 处理器函数并将接收到的消息作为参数传递。在本例中，我们只是简单地日志记录收到的消息，并使用 message.ack() 确认已处理此消息，以便 Pub/Sub 在需要时可以再次发布该消息。

结论

本文涵盖了如何在 Node.js 中使用 @google-cloud/pubsub 包进行发布-订阅消息传递的基础知识，包括创建一个话题、发布消息和订阅消息。我们还提供了一些示例代码和说明，以帮助您更好地理解如何使用该包。

但是，在实际的应用程序中，消息传递可能会变得更加复杂。例如，在处理多个事件或关联广播的消息时，您可能需要实现自定义处理逻辑。我们希望您可以依靠本文所提供的知识作为基础，继续学习和探究更复杂的用例。

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