Node.js EventEmitterの仕組みと活用方法：非同期イベント駆動設計のベストプラクティス

2026年5月18日

非同期処理・イベントループ

Node.jsは非同期I/Oとイベント駆動アーキテクチャを最大の特徴とするプラットフォームです。

その核となるのが、今回解説する EventEmitter という強力なモジュールです。

サーバーサイドJavaScriptにおいて、効率的でスケーラブルなアプリケーションを構築するためには、この仕組みを深く理解することが欠かせません。

本記事では、2026年現在の最新のトレンドやベストプラクティスを交えながら、EventEmitterの基本的な使い方から内部構造、そして実務で役立つ高度な活用法までを詳しく説明します。

目次 [ close ]

EventEmitterの基本概念と役割

Node.jsにおけるイベント駆動設計とは、特定の状態変化やアクションが発生した際に、あらかじめ登録しておいた処理を自動的に実行させる仕組みを指します。

この仕組みを実現するための中心的な役割を担うのが events モジュールに含まれる EventEmitter クラスです。

EventEmitterは、特定の「イベント」に対して「リスナー(コールバック関数)」を紐付け、イベントが発生したタイミングでそれらを一斉に呼び出す機能を提供します。

これはデザインパターンの1つであるオブザーバーパターンの実装であり、コンポーネント間の結合度を低く保つのに役立ちます。

Node.jsの標準ライブラリの多く、例えば fs (ファイルシステム) や http サーバーなども、内部的にこのEventEmitterを継承して作られています。

EventEmitterの基本的な実装方法

まずは、最もシンプルにEventEmitterをインスタンス化して使用する手順を見ていきましょう。

Node.jsの組み込みモジュールである events をインポートすることから始まります。

JavaScript

// eventsモジュールからEventEmitterをインポート
const EventEmitter = require('events');

// インスタンスを作成
const myEmitter = new EventEmitter();

// 'greet' という名前のイベントにリスナーを登録
myEmitter.on('greet', (name) => {
  console.log(`こんにちは、${name}さん！`);
});

// 'greet' イベントを発火させる
myEmitter.emit('greet', 'エンジニア');

実行結果

こんにちは、エンジニアさん！

イベントの登録と発火の仕組み

上記のコードにおいて、on メソッドは「イベントの購読」を意味します。

第一引数にはイベント名を文字列(またはSymbol)で指定し、第二引数にはそのイベントが起きたときに実行したい関数を渡します。

そして、emit メソッドを使用することで、任意のタイミングで特定のイベントをプログラムから明示的に発生させることができます。

emit の第二引数以降に渡したデータは、そのままリスナー関数の引数として受け取ることが可能です。

一度だけ実行されるイベントリスナー

場合によっては、イベントが何度発生しても、最初の1回だけ処理を行いたいケースがあります。

その場合は on メソッドの代わりに once メソッドを使用します。

JavaScript

const myEmitter = new EventEmitter();

// onceを使用すると、1回実行された後に自動的に登録が解除される
myEmitter.once('init', () => {
  console.log('初期化処理を実行しました');
});

myEmitter.emit('init');
myEmitter.emit('init'); // 2回目は何も起きない

実行結果

初期化処理を実行しました

EventEmitterの内部的な動作と実行順序

EventEmitterを扱う上で注意すべき重要なポイントは、その同期的な性質です。

多くの初心者は「Node.jsのイベントだから非同期で動く」と誤解しがちですが、実際には emit が呼ばれると、登録されているすべてのリスナーが登録された順序に従って同期的に呼び出しされます。

つまり、あるリスナーの中で重い計算処理を記述すると、後続のリスナーの実行をブロックしてしまいます。

もしリスナーを非同期に実行したい場合は、関数内で setImmediate や process.nextTick を明示的に利用する必要があります。

JavaScript

const myEmitter = new EventEmitter();

myEmitter.on('event', () => {
  console.log('リスナー1');
});

myEmitter.on('event', () => {
  setImmediate(() => {
    console.log('リスナー2 (非同期)');
  });
});

myEmitter.on('event', () => {
  console.log('リスナー3');
});

myEmitter.emit('event');
console.log('emit呼び出し完了');

実行結果

リスナー1
リスナー3
emit呼び出し完了
リスナー2 (非同期)

実務的な活用：EventEmitterを継承したクラス設計

実際の開発現場では、単純に new EventEmitter() を使うことは稀です。

独自の業務ロジックを持つクラスにEventEmitterの機能を継承させ、そのオブジェクト自身がイベントを投げられるように設計するのが一般的です。

これにより、オブジェクトの状態変化を外部に通知するクリーンなインターフェースを提供できます。

JavaScript

const EventEmitter = require('events');

// EventEmitterを継承したカスタムクラス
class DatabaseConnector extends EventEmitter {
  constructor(dbName) {
    super();
    this.dbName = dbName;
  }

  connect() {
    console.log(`${this.dbName} に接続を試みています...`);
    
    // 接続完了を想定した擬似的な遅延
    setTimeout(() => {
      console.log('接続成功');
      // 外部へ接続完了イベントを通知
      this.emit('connected', this.dbName);
    }, 1000);
  }
}

const db = new DatabaseConnector('UsersDB');

// イベントをリッスンする
db.on('connected', (name) => {
  console.log(`${name} への接続を検知しました。クエリを開始します。`);
});

db.connect();

メモリリークを防ぐためのベストプラクティス

EventEmitterを長期間稼働するアプリケーションで使用する場合、メモリリークには細心の注意を払う必要があります。

特にリスナーを動的に登録し、適切に解除し忘れると、ガベージコレクションによってメモリが解放されず、プロセスのメモリ使用量が肥大化し続けます。

リスナーの適切な解除

不要になったリスナーは、必ず off (または removeListener) を使用して削除しましょう。

ここで注意が必要なのは、匿名関数を登録してしまうと、後からその関数を特定して削除することができない点です。

JavaScript

const myEmitter = new EventEmitter();

const callback = () => {
  console.log('処理実行');
};

// 登録
myEmitter.on('data', callback);

// 解除 (関数リファレンスが必要)
myEmitter.off('data', callback);

最大リスナー数の制限

Node.jsは、1つのイベントに対してデフォルトで 10 個を超えるリスナーが登録されると、警告を出力します。

これはプログラミングミスによるメモリリークを早期に発見するための親切な機能です。

どうしても多くのリスナーが必要な場合は、setMaxListeners() メソッドを使用して上限値を変更することができます。

しかし、安易に上限を増やすのではなく、「本当にそれほど多くのリスナーが必要か」を再検討することが重要です。

エラーハンドリングの徹底

EventEmitterには、「error」という名前のイベントに対して特別な挙動が存在します。

もしプログラムが 'error' イベントを発火させた際、そのイベントに対するリスナーが1つも登録されていない場合、Node.jsのプロセスはスタックトレースを表示して異常終了してしまいます。

堅牢なアプリケーションを作るためには、必ず error イベントのハンドリングを行わなければなりません。

JavaScript

const myEmitter = new EventEmitter();

// エラーリスナーがない状態で emit('error') するとクラッシュする
myEmitter.on('error', (err) => {
  console.error('致命的なエラーをキャッチしました:', err.message);
});

myEmitter.emit('error', new Error('データベース接続失敗'));

2026年における最新のイベント処理手法

近年のNode.jsでは、従来のEventEmitterに代わる、あるいは補完する新しいAPIも普及しています。

AbortSignalによるイベントのキャンセル

リスナーの解除をよりモダンに、かつ汎用的に行う方法として AbortController と AbortSignal が標準化されています。

これを活用することで、複数の異なる非同期処理やイベントをまとめて「キャンセル」することが容易になります。

JavaScript

const { on, EventEmitter } = require('events');
const ac = new AbortController();
const { signal } = ac;

const ee = new EventEmitter();

async function start() {
  try {
    // signalを渡すことで、外部からリスニングを停止できる
    await on(ee, 'foo', { signal });
    console.log('イベントを受信しました');
  } catch (err) {
    if (err.name === 'AbortError') {
      console.log('リスニングがキャンセルされました');
    }
  }
}

start();
ac.abort(); // 即座にキャンセル

AsyncIterableによるストリーム処理

最新のNode.jsでは、EventEmitterのイベントを for await...of ループで処理することが可能です。

これにより、コールバック地獄を避け、非同期イベントをまるでリストデータのように反復処理できるようになります。

これはコードの可読性を飛躍的に向上させるベストプラクティスの1つです。

EventEmitter活用時のチェックリスト

最後に、EventEmitterを正しく使いこなすための主要なポイントを以下の表にまとめました。

項目	注意すべきポイント	推奨されるアクション
同期実行	リスナーは登録順に同期的に実行される	重い処理は非同期APIでラップする
メモリ管理	不要なリスナーが残るとリークの原因になる	off() や AbortSignal で適切に解除する
エラー処理	‘error’ イベント未処理でプロセスが終了する	必ず error リスナーを登録する
リスナー数	デフォルト10個の制限がある	警告が出たら設計を見直すか制限値を調整する