探索Google Cloud Pub/Sub的Node.js客户端库

// 引入Google Cloud Pub/Sub Node.js客户端库
const {PubSub} = require('@google-cloud/pubsub');
 
// 创建一个PubSub客户端实例
const pubSubClient = new PubSub();
 
// 异步函数，用于创建一个新的主题
async function createTopic(topicName) {
  // 尝试创建主题
  try {
    const [topic] = await pubSubClient.createTopic(topicName);
    console.log(`主题 ${topicName} 创建成功.`);
    return topic;
  } catch (error) {
    // 如果主题已存在，则会抛出错误，可以根据需要处理错误
    if (error.code === 6) {
      console.log(`主题 ${topicName} 已存在。`);
      return pubSubClient.topic(topicName);
    }
    // 如果是其它错误，则重新抛出
    throw error;
  }
}
 
// 异步函数，用于向主题发送消息
async function publishMessage(topic, message) {
  // 创建一个消息
  const data = Buffer.from(message);
  const messageId = await topic.publish(data);
  console.log(`消息 ${message} 已发送，ID: ${messageId}`);
}
 
// 使用示例
const topicName = 'my-topic'; // 替换为你的主题名称
const message = 'Hello, Pub/Sub!'; // 替换为你想发送的消息
 
// 创建主题
createTopic(topicName)
  .then(topic => {
    // 发布消息
    publishMessage(topic, message);
  })
  .catch(error => {
    console.error('发生错误:', error);
  });

这段代码展示了如何使用Google Cloud Pub/Sub Node.js客户端库创建一个主题，并向该主题发送一条消息。如果主题已存在，它会被客户端库识别并重用，而不会抛出错误。发送消息时，它会使用Buffer对象来保证消息内容的传输。