【Node.js】事件机制：从EventEmitter到EventTarget

1
const domain = require('domain')
2
const { EventEmitter } = require('events')
3

4
// 创建一个domain实例
5
const d = domain.create()
6

7
// 创建EventEmitter实例，domain会自动覆盖其init方法
8
const emitter = new EventEmitter()
9
d.add(emitter) // domain将emitter纳入上下文追踪
10

11
// 当emitter触发事件时，domain会捕获其上下文
12
emitter.on('test', () => {
13
  console.log('Event in domain:', process.domain === d) // 输出true
14
})

1
const net = require('net')
2
const server = net.createServer()
3

4
// 监听客户端连接事件（每次连接都会触发）
5
server.on('connection', (socket) => {
6
  console.log('Client connected:', socket.remoteAddress)
7
  socket.write('Hello from server!')
8
  socket.end()
9
})
10

11
server.listen(3000, () => {
12
  console.log('Server listening on port 3000')
13
})

1
const net = require('net')
2
const server = net.createServer((socket) => {
3
  // 仅监听一次'close'事件
4
  socket.once('close', () => {
5
    console.log('Socket closed (only once)')
6
  })
7
  socket.write('Hello!')
8
  socket.end() // 关闭socket，触发'close'事件
9
})
10

11
server.listen(3000)

1
const fs = require('fs')
2
const { EventEmitter } = require('events')
3
const emitter = new EventEmitter()
4

5
// 情况1：未监听error，触发后崩溃
6
emitter.emit('error', new Error('File not found')) // 抛出异常，程序终止
7

8
// 情况2：监听error，优雅处理
9
emitter.on('error', (err) => {
10
  console.error('Handled error:', err.message) // 输出"Handled error: File not found"
11
})
12
emitter.emit('error', new Error('File not found')) // 程序继续运行

1
const { EventEmitter } = require('events')
2
const emitter = new EventEmitter({ captureRejections: true })
3

4
// 模拟数据库查询（async函数）
5
emitter.on('fetchUser', async (userId) => {
6
  // 假设db.query会抛错（如userId不存在）
7
  const user = await db.query('SELECT * FROM users WHERE id = ?', [userId])
8
  console.log('User:', user)
9
})
10

11
// 监听error事件，处理async函数的错误
12
emitter.on('error', (err) => {
13
  console.error('Database error:', err.message) // 输出"Database error: User not found"
14
})
15

16
// 触发事件（userId=999不存在）
17
emitter.emit('fetchUser', 999)

1
const { EventTarget, Event } = require('events')
2
const fetch = require('node-fetch')
3

4
// 实现一个支持取消的HTTP请求控制器
5
class FetchController extends EventTarget {
6
  constructor() {
7
    super()
8
    this.abortController = new AbortController()
9
  }
10

11
  async fetch(url) {
12
    try {
13
      // 使用abortController的signal取消请求
14
      const response = await fetch(url, { signal: this.abortController.signal })
15
      const data = await response.json()
16
      // 触发success事件，传递数据
17
      this.dispatchEvent(new CustomEvent('success', { detail: data }))
18
    } catch (err) {
19
      if (err.name === 'AbortError') {
20
        this.dispatchEvent(new Event('abort')) // 触发abort事件
21
      } else {
22
        this.dispatchEvent(new CustomEvent('error', { detail: err })) // 触发error事件
23
      }
24
    }
25
  }
26

27
  abort() {
28
    this.abortController.abort() // 取消请求
29
  }
30
}
31

32
// 使用FetchController
33
const controller = new FetchController()
34

35
// 监听success事件
36
controller.addEventListener('success', (e) => {
37
  console.log('Data:', e.detail) // 输出请求到的数据
38
})
39

40
// 监听abort事件
41
controller.addEventListener('abort', () => {
42
  console.log('Request aborted')
43
})
44

45
// 发起请求（1秒后取消）
46
controller.fetch('https://jsonplaceholder.typicode.com/todos/1')
47
setTimeout(() => controller.abort(), 1000)