Node.js管道中如何为Crypto加密设置UTF-8编码并保障性能？

首先纠正一个代码错误：crypto.createCipheriv是同步方法，不需要加await，这可能导致cipher初始化异常，先修正这个问题：

const cipher = crypto.createCipheriv(
  'aes-256-cbc', 
  Buffer.from('y642GnzY61Has9hoKPAQereA3Jih3XiW'), 
  Buffer.from('usLmN9ZtJn1D0ArF')
);

接下来解决编码问题，分两步确保全程UTF-8编码：

1. 确保PostgreSQL源数据为UTF-8 #

数据库返回的数据编码如果不是UTF-8，后续JSON转换和加密都会出现编码问题。在pg连接池配置中显式指定编码：

const updateProvider = new pg.Pool({
  // 你的其他连接配置（host、user、password等）
  client_encoding: 'utf8'
});

2. 流式处理中强制UTF-8编码转换 #

Node.js流在字符串转Buffer时默认用UTF-8，但显式设置可以避免潜在的编码歧义。有两种轻量方案：

方案一：直接设置JSON流的输出编码 #

给JSONStream.stringify()返回的流设置UTF-8编码，确保输出的字符串转Buffer时使用UTF-8：

updateProvider.connect(async (err, client, done) => {
  if (err) throw err;
  const query = new QueryStream('SELECT * FROM table');
  const stream = await client.query(query);
  stream.on('end', done);
  
  const jsonStream = JSONStream.stringify();
  jsonStream.setEncoding('utf8'); // 显式指定输出编码为UTF-8
  
  stream.pipe(jsonStream).pipe(cipher).pipe(res);
});

方案二：用Transform流显式转码（更可控） #

如果需要更精确控制编码转换，创建一个轻量的Transform流，将JSON字符串转为UTF-8编码的Buffer，再传入cipher：

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

// 轻量转码流，确保输出UTF-8 Buffer
const utf8Encoder = new Transform({
  writableObjectMode: true,
  transform(chunk, encoding, callback) {
    const utf8Buffer = typeof chunk === 'string' 
      ? Buffer.from(chunk, 'utf8') 
      : chunk;
    this.push(utf8Buffer);
    callback();
  }
});

updateProvider.connect(async (err, client, done) => {
  if (err) throw err;
  const query = new QueryStream('SELECT * FROM table');
  const stream = await client.query(query);
  stream.on('end', done);
  
  stream.pipe(JSONStream.stringify())
        .pipe(utf8Encoder)
        .pipe(cipher)
        .pipe(res);
});

这两种方案都是流式处理，不会像for循环那样阻塞或损失性能，全程保持分块传输的优势。

内容的提问来源于stack exchange，提问作者Halil Han BADEM