JS でパブリッシュ サブスクライブ モデルを作成する

定数ルフィ = {
  更新: 関数 (曲、ビデオ) {
    console.log(曲、ビデオ);
  },
};
定数ゾロ = {
  更新: 関数 (曲、ビデオ) {
    console.log(曲、ビデオ);
  },
};
定数サンジ = {
  更新: 関数 (曲、ビデオ) {
    console.log(曲、ビデオ);
  },
};

定数ナミ = {
  // このメソッドはナミの作業が更新されるたびに呼び出されます workUpdate: function () {
    // 作品を取得します const songs = this.getSongs();
    const ビデオ = this.getVideos();

    //アカウント更新 luffy.update(songs, videos);
    zoro.update(曲、ビデオ);
    sanji.update(曲、ビデオ);
  },
  getSongs: 関数 () {
    "mp3"を返します。
  },
  getVideos: 関数 () {
    "mp4"を返します。
  },
};

クラス スター {
  コンストラクタ() {
    this.fans = [];
  }
  ファンを追加します(ファン) {
    this.fans.push(ファン)
  }
  作業更新() {
    const songs = this.getSongs();
    const ビデオ = this.getVideos();
    this.fans.forEach((item) => item.update(songs, videos));
  }
  getSongs() {
    "MP3"を返します。
  }
  動画を取得する() {
    "MP4"を返します。
  }
}

クラスファン{
  コンストラクタ(名前、星) {
    this.name = 名前
    this.star = 星
    this.star.addFans(これ)
  }
  更新(曲、ビデオ) {
    console.log(曲、ビデオ);
  }
}

const nami = 新しい Star()
const luffy = new Fan("luffy", nami);
const zoro = new Fan("zoro", nami);
const sanji = new Fan("sanji", nami);
const robin = new Fan("robin", nami);
nami.workUpdate()

クラス スター {
  コンストラクタ() {
    this.fans = [];
    これは動作します = [];
  }
  ファンを追加します(ファン) {
    this.fans.push(ファン);
  }
  setWorks(作業) {
    this.works.push(作業);
    // 作業を追加した後、更新メソッドを呼び出します this.workUpdate();
  }
  getWorks() {
    this.works を返します。
  }
  作業更新() {
    this.fans.forEach((item) => item.update());
  }
}

クラスファン{
  コンストラクタ(名前、星) {
    this.name = 名前
    this.star = 星
    this.star.addFans(これ)
  }
  アップデート（） {
    console.log(`${this.name}:${this.star.getWorks()}`)
  }
}

const nami = new Star();
nami.setWorks('song')
nami.setWorks('ビデオ')
nami.setWorks('小説')
const luffy = new Fan("luffy", nami);
const zoro = new Fan("zoro", nami);
const sanji = new Fan("sanji", nami);
nami.workUpdate();

//オブザーバー: サブジェクトクラスSubject {
  コンストラクタ() {
    this.observerList = [];
    // サブジェクトの状態を表します this.state = 0;
  }
  オブザーバーを追加します(オブザーバー) {
    this.observerList.push(オブザーバー);
  }
  // テーマの状態を変更する setState(state) {
    this.state = 状態;
    //状態が変化したら、すべてのオブザーバーに通知します this.notify();
  }
  状態を取得する() {
    this.state を返します。
  }
  通知() {
    this.observerList.forEach((オブザーバー) => observer.update());
  }
}

//オブザーバークラスオブザーバー{
  コンストラクタ(名前, 件名) {
    this.name = 名前;
    this.subject = 件名;
    this.subject.addObserver(これ);
  }
  アップデート（） {
    console.log(`${this.name}:${this.subject.state}`);
  }
}

クラスマネージャー{
  コンストラクタ() {
    this.fans = [];
    これは動作します = [];
  }
  ファンを追加します(ファン) {
    this.fans.push(ファン);
  }
  setWorks(作業) {
    this.works.push(作業);
    // 作業を追加した後、更新メソッドを呼び出します this.workUpdate();
  }
  getWorks() {
    this.works を返します。
  }
  作業更新() {
    this.fans.forEach((item) => item.update());
  }
}

クラス スター {
  コンストラクタ() {}
  // 作成 create(manager) {
    // 作成した新しい作業をエージェントに送信します。 manager.setWorks("new work");
  }
}

クラスファン{
  コンストラクタ(名前、マネージャ) {
    this.name = 名前;
    this.manager = マネージャー;
    this.manager.addFans(これ);
  }
  アップデート（） {
    console.log(`${this.name}:${this.manager.getWorks()}`);
  }
}

//パブリッシュおよびサブスクライブ スケジューリング センター クラス Broker {
  コンストラクタ() {
    this.subscribers = [];
    // サブジェクトの状態を表します this.state = 0;
  }
  // 購読購読(購読者) {
    this.subscribers.push(サブスクライバー);
  }
  // テーマの状態を変更する setState(state) {
    this.state = 状態;
    //状態が変化したら、公開します。this.publish();
  }
  状態を取得する() {
    this.state を返します。
  }
  // 公開 publish() {
    this.subscribers.forEach((subscriber) => subscriber.update());
  }
}

// パブリッシャークラス Publisher {
  コンストラクタ() {}
  状態の変更(ブローカー、状態) {
    ブローカーの状態を設定します。
  }
}

クラス サブスクライバー {
  コンストラクタ(名前、ブローカー) {
    this.name = 名前;
    this.broker = ブローカー;
    this.broker.subscribe(これを);
  }
  アップデート（） {
    console.log(`${this.name}:${this.broker.getState()}`);
  }
}

// ディスパッチセンターを作成する const broker = new Broker()
// パブリッシャーを作成する constpublisher = new Publisher()
// サブスクライバーを作成する const subscribe1 = new Subscriber('s1', broker)
const subscribe2 = 新しいサブスクライバー('s2', ブローカー)
const subscribe3 = 新しいサブスクライバー('s3'、ブローカー)
// パブリッシャーは状態を変更し、ディスパッチ センターに通知します。ディスパッチ センターは各サブスクライバーに通知します。publisher.changeState(broker, 1)