Node.js谷歌API示例能否用fs.readFile替代fs.readFileSync？可否改用Socket流？

Great question! I totally get why you’d raise an eyebrow at that synchronous fs.readFileSync call—blocking the Node.js event loop in server-side code is definitely a practice we want to avoid, especially if your service handles multiple concurrent requests. Let’s break down both of your questions:

1. 替换为异步的fs.readFile版本 #

Absolutely! The modern way to do this cleanly is using Node.js’s promise-based fs.promises API combined with async/await, which keeps your code readable while avoiding blocking operations. Here’s how you’d refactor that example:

const fs = require('fs').promises; // 使用基于Promise的文件系统方法

async function runTranscription(filename) {
  try {
    // 异步读取文件并转换为base64格式
    const audioBuffer = await fs.readFile(filename);
    const audio = { content: audioBuffer.toString('base64') };
    const request = { audio: audio };

    // 发起长时识别请求并等待完成
    const [operation] = await client.longRunningRecognize(request);
    const [response] = await operation.promise();

    // 处理并返回识别结果
    const transcription = response.results
      .map(result => result.alternatives[0].transcript)
      .join('\n');
    
    console.log('识别完成：', transcription);
    return transcription;
  } catch (error) {
    console.error('识别失败：', error);
    throw error; // 抛出错误让调用方处理
  }
}

这种方式能让服务器的事件循环在文件读取和API请求过程中保持空闲，处理其他请求，完全符合Node.js服务端的异步范式。

2. 使用Socket流（或流式处理） #

当然可以！谷歌的语音转文字API专门提供了streamingRecognize方法来支持流式处理，非常适合大音频文件（无需将整个文件加载到内存）或实时音频输入（比如WebSocket、TCP Socket的场景）。

下面是一个用Node.js流读取文件并直接传给API的示例：

const fs = require('fs');
const { Transform } = require('stream');

async function streamAudioTranscription(filename) {
  // 配置音频参数（必须和你的文件格式匹配！）
  const config = {
    encoding: 'LINEAR16', // 根据音频格式调整，比如MP3文件填'MP3'
    sampleRateHertz: 16000,
    languageCode: 'zh-CN' // 按需设置语言代码
  };

  // 创建语音转文字API的流式客户端
  const stream = client.streamingRecognize({
    config,
    interimResults: false // 设置为true可获取实时临时识别结果
  });

  // 监听识别结果
  stream.on('data', (response) => {
    const result = response.results[0];
    if (result.isFinal) {
      console.log('最终识别文本：', result.alternatives[0].transcript);
    }
  });

  stream.on('error', (err) => {
    console.error('流式处理错误：', err);
  });

  stream.on('end', () => {
    console.log('流式识别完成');
  });

  // 创建转换流：将原始音频块转为API要求的base64格式
  const audioToBase64 = new Transform({
    objectMode: true,
    transform(chunk, _, callback) {
      this.push({ audioContent: chunk.toString('base64') });
      callback();
    }
  });

  // 管道流：文件读取流 → 格式转换流 → API流式客户端
  fs.createReadStream(filename)
    .pipe(audioToBase64)
    .pipe(stream);
}

如果是Socket场景（比如客户端通过WebSocket分块发送音频数据），你可以把fs.createReadStream(filename)替换为Socket的输入数据流，直接将Socket的数据导入audioToBase64转换流，再传给API的流式客户端——完全不需要先把文件存到磁盘！

关键提示 #

• 中小文件用异步fs.readFile的方式简单高效；
• 大文件或实时场景用流式处理，内存占用更低、响应更及时。

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