Node.js 內建 fetch API 預覽這個話題社群討論了很多次,但隨著版本迭代,很多結論需要更新。本文基於最新版本重新梳理。
入門指南
先來看基本的實現方式:
javascript
const express = require('express')
const app = express()
app.use(express.json())
class AppError extends Error {
constructor(status, message) {
super(message); this.statusCode = status
}
}
const asyncHandler = (fn) => (req, res, next) =>
Promise.resolve(fn(req, res, next)).catch(next)
app.get('/api/users/:id', asyncHandler(async (req, res) => {
const user = await User.findById(req.params.id)
if (!user) throw new AppError(404, '使用者不存在')
res.json({ data: user })
}))
這段程式碼展示了基本的使用方式。實際專案中還需要考慮錯誤處理和邊界條件。
原始碼分析
在這個基礎上,我們可以進一步最佳化:
javascript
const fs = require('fs')
const { Transform, pipeline } = require('stream')
const { promisify } = require('util')
const pipelineAsync = promisify(pipeline)
const csvToJson = new Transform({
transform(chunk, encoding, callback) {
const lines = chunk.toString().split('\n')
const headers = lines[0].split(',')
for (let i = 1; i < lines.length; i++) {
if (!lines[i].trim()) continue
const values = lines[i].split(',')
const obj = {}
headers.forEach((h, idx) => obj[h.trim()] = values[idx]?.trim())
this.push(JSON.stringify(obj) + '\n')
}
callback()
}
})
這種模式在大型專案中非常實用,能顯著降低維護成本。
真實場景應用
實際專案中的用法會更復雜一些:
javascript
const express = require('express')
const app = express()
app.use(express.json())
class AppError extends Error {
constructor(status, message) {
super(message); this.statusCode = status
}
}
const asyncHandler = (fn) => (req, res, next) =>
Promise.resolve(fn(req, res, next)).catch(next)
app.get('/api/users/:id', asyncHandler(async (req, res) => {
const user = await User.findById(req.params.id)
if (!user) throw new AppError(404, '使用者不存在')
res.json({ data: user })
}))
通過這種方式,程式碼的可測試性和可擴充套件性都得到了提升。
最佳化技巧
以下是一個完整的示例:
javascript
const fs = require('fs')
const { Transform, pipeline } = require('stream')
const { promisify } = require('util')
const pipelineAsync = promisify(pipeline)
const csvToJson = new Transform({
transform(chunk, encoding, callback) {
const lines = chunk.toString().split('\n')
const headers = lines[0].split(',')
for (let i = 1; i < lines.length; i++) {
if (!lines[i].trim()) continue
const values = lines[i].split(',')
const obj = {}
headers.forEach((h, idx) => obj[h.trim()] = values[idx]?.trim())
this.push(JSON.stringify(obj) + '\n')
}
callback()
}
})
注意邊界條件處理,這在生產環境中至關重要。
小結
- 團隊協作中約定和文件比技術本身更重要
- 關注社群動態,技術方案需要持續迭代
- 不要為了用新技術而用新技術