使用Node客户端调用Pub/Sub StreamingPull无响应问题排查

你的代码存在几个关键问题，导致无法正常接收Pub/Sub消息：

• 字符串语法错误：subscription字段末尾多了一个单引号，无效的订阅路径会让Pub/Sub无法识别目标订阅。
• 过早关闭流：stream.end()会直接终止StreamingPull的长连接，而Pub/Sub的StreamingPull依赖持续连接来接收消息，不能在发送请求后立刻关闭流。
• 不必要的await调用：streamingPull()返回的是流对象，不需要用await修饰。

修正后的代码示例 #

const { v1 } = require('@google-cloud/pubsub');

// 初始化订阅客户端（确保已完成认证配置）
const subClient = new v1.SubscriberClient();

const request = {
  subscription: 'projects/<projectId>/subscriptions/Temp', // 修正单引号错误
  stream_ack_deadline_seconds: 600
};

console.log('Pulling Messages...');
const stream = subClient.streamingPull();

// 监听消息数据
stream.on('data', response => {
  console.log('收到消息:', response);
  // 处理消息后需发送ACK确认，示例：
  // const ackReq = {
  //   subscription: request.subscription,
  //   ackIds: response.receivedMessages.map(item => item.ackId)
  // };
  // stream.write(ackReq);
});

stream.on('error', err => {
  console.error('流错误:', err);
});

stream.on('end', () => {
  console.log("流已结束");
});

// 发送初始请求，保持流处于打开状态
stream.write(request);
// 不要主动调用stream.end()，除非你需要停止接收消息

额外注意事项 #

• 确认服务账号拥有pubsub.subscriptions.consume权限，权限不足可能导致静默失败。
• 新创建的订阅可能需要等待1-2分钟让Pub/Sub同步配置。
• 可以通过GCP控制台查看订阅的未确认消息数，确认确实有消息待接收。

内容的提问来源于stack exchange，提问作者Neil