event bus mit PHP

boehlke · 03.08.2010, 19:20

Hallo Entwickler!

In einem aktuellen Projekt entwickele ich eine Synchronisation zwischen zwei und vielleicht mal mehr PHP-Anwendungen.
Die Systeme sollen möglichst entkoppelt bleiben, deshalb bietet sich eine Ereignis-orientierte Architektur an: Bei einer Änderung der Daten feuert das verursachende System ein Ereignis ab, dass von interessierten Systemen verarbeitet wird. Ich denke also an ein Publish-Subscribe-System, auch "event bus" genannt.

Meine Frage an die Experten hier: Kennt ihr eine Event-Bus-Implementierung in PHP?

Danke für die Hilfe!

Beste Grüße,
André

xm22 · 03.08.2010, 19:51

Du könntest per Web-Service Requests an die zu benachrichtigenden System schicken (Push) oder die System in regelmäßigen Abständen nachfragen lassen (pull)

boehlke · 03.08.2010, 20:46

Danke für Dein Input!
Ich brauche ein System, das die Ereignisse speichert und verteilt. Wie diese verteilt werden, ist mir zunächst nicht so wichtig.
Beispiel:
In System 1 wird ein Benutzer angelegt. Das System erzeugt ein Ereignis "Benutzer angelegt". Dieses Ereignis soll an alle Systeme weitergeleitet werden, die sich dafür interessieren. Das macht der Event Bus.

ChrisB · 03.08.2010, 20:56

Zitat:

Zitat von boehlke

Ich brauche ein System, das die Ereignisse speichert und verteilt. Wie diese verteilt werden, ist mir zunächst nicht so wichtig.

Letzteres ist doch das hauptsächlich wichtige ...?

Zitat:

Beispiel:
In System 1 wird ein Benutzer angelegt. Das System erzeugt ein Ereignis "Benutzer angelegt". Dieses Ereignis soll an alle Systeme weitergeleitet werden, die sich dafür interessieren. Das macht der Event Bus.

Na also, dann ist doch wohl die „Verteilung“ der Events, die Benachrichtigung über ihr Eintreten, sehr wohl das wichtigste an der ganzen Sache.

(Das „Melden“ des Events ist ja simpel, da muss System 1 ja nur über einen Request dem Event Bus ein mal Bescheid geben.)

Zu überlegen wäre, ob der Event Bus ein dauernd laufendes Script/Programm sein muss, oder ob da „aufrufen“ beim Melden eines neuen Events reicht. Vermutlich ersteres, denn die Zustellung der Eventmeldung an alle anderen Systeme muss ja im Zweifelsfalle nicht augenblicklich klappen, ggf. reagiert eines dieser Systeme gerade nicht/ist ausgelastet, so dass die Nachricht kurze Zeit später noch mal gesendet werden muss.

Per Google finde ich auf die Schnelle zum Thema nur folgendes, Ajax/PHP Distributed Event Bus - ich weiß nicht, wie AJAX-lastig dieser Artikel ist, und was davon du auf dein System übertragen kannst - aber schau mal rein.

boehlke · 04.08.2010, 08:50

Zitat:

Zitat von ChrisB

Zu überlegen wäre, ob der Event Bus ein dauernd laufendes Script/Programm sein muss, oder ob da „aufrufen“ beim Melden eines neuen Events reicht. Vermutlich ersteres, denn die Zustellung der Eventmeldung an alle anderen Systeme muss ja im Zweifelsfalle nicht augenblicklich klappen, ggf. reagiert eines dieser Systeme gerade nicht/ist ausgelastet, so dass die Nachricht kurze Zeit später noch mal gesendet werden muss.

Das ist eine wichtige Überlegung. Alle Ereignisse müssen mindestens so lange gespeichert werden, wie es einer interessierte Partei nicht weitergeleitet wurde. Wenn eine empfangendes System z.B. bei der Verarbeitung des Ereignisses abschmiert oder wie Du geschrieben hast ausgelastet ist, dann muss das Ereignis aufgehoben werden.

Zitat:

Zitat von ChrisB

Letzteres ist doch das hauptsächlich wichtige ...?

Per Google finde ich auf die Schnelle zum Thema nur folgendes, Ajax/PHP Distributed Event Bus - ich weiß nicht, wie AJAX-lastig dieser Artikel ist, und was davon du auf dein System übertragen kannst - aber schau mal rein

Ja genau, dort wird das beschrieben, was ich mir vorstelle.

Es sieht so aus, als müsste ich das selbst implementieren. Ich werde im ersten Schritt mit einem Singleton arbeiten, das die Ereignis-Verteilungslogik kapselt. Ich gehe erst einmal davon aus, dass die Systeme auf demselben Rechner liegen und dass der Event Bus beide direkt aufrufen kann.

Ich schlage folgenden Aufbau vor:

Ereignis-Erzeugung läuft etwa so ab:

PHP-Code:

  require_once '.../EventBus.php';

EventBus :: getInstance()->fireEvent(new UserCreatedEvent($uid, $name));

Ereignis-Empfang wird konfiguriert.
listeners.ini

Code:

listener1.class = .../UserCrudListener.php
listener1.eventtype0 = UserCreatedEvent
listener1.eventtype1 = UserChangedEvent
listener1.eventtype2 = UserDeletedEvent

UserCrudListener.php

PHP-Code:

  class UserCrudListener implements EventListener {

  public function handleEvent(Event $oEvent) {

    $oEventSource = $oEvent->getSource();

    echo "Event fired by " . $oEventSource->getID() . "\n";

    if($oEvent instanceof UserCreatedEvent)

      ....

  }

}

Der EventBus arbeitet mit serialize/unserialize, um nicht zustellbare Ereignisse zu speichern. "Zweitzustellung" ist zunächst nicht vorgesehen.

Geht das noch einfacher?

Grüße
André

xm22 · 04.08.2010, 11:12

Die ini-Datei sieht etwas seltsam aus. Dreh doch die Speicherung lieber um, also etwa so (Mal xml, damit es sich einfacher abbilden lässt)

Code:

<events>
  <event id="UserCreatedEvent">
    <listeners>
      <listener class="UserCrudListener" />
    </listeners>
  </event>
</events>

Evtl. könnte/sollte man im Listener-Objekt direkt ein Callback hinterlegen, also so etwa:

Code:

<events>
  <event id="UserCreatedEvent">
    <listeners>
      <listener class="UserCrudListener" function="onCreated" />
    </listeners>
  </event>
</events>

boehlke · 04.08.2010, 15:16

Eine XML-Konfigurationsdatei ist in dem Fall wirklich schöner. Danke.

nikosch · 04.08.2010, 15:37

Zitat:

Das ist eine wichtige Überlegung. Alle Ereignisse müssen mindestens so lange gespeichert werden, wie es einer interessierte Partei nicht weitergeleitet wurde. Wenn eine empfangendes System z.B. bei der Verarbeitung des Ereignisses abschmiert oder wie Du geschrieben hast ausgelastet ist, dann muss das Ereignis aufgehoben werden.

Fargt sich natürlich, wie lange man das Event vorhält. Um beim Beispiel zu bleiben:

Zitat:

In System 1 wird ein Benutzer angelegt.

Stellen wir uns ein zweites Ereignis vor:

Zitat:

In System 1 wird dieser Benutzer wieder gelöscht.

Jetzt ergibt sich bereits eine Abhängigkeit von vollständigkeit. Event 2 kann vielleicht noch ohne Wissen über 1 abgearbeitet (ignoriert) werden, aber anders herum ergibt sich schon ein ganz anderer Tenor. Auf der anderen Seite - wenn ein System lange nicht antwortet (und das ist wohl der einzige Weg, wie die Events bestätigt werden können) ergibt sich eine riesige Queue von Events, die auch noch für jeden Client separat gespeichert und zusammengestekllt werden muss.

Alles nicht so trivial.

boehlke · 04.08.2010, 16:50

Zitat:

Zitat von nikosch

Jetzt ergibt sich bereits eine Abhängigkeit von vollständigkeit. Event 2 kann vielleicht noch ohne Wissen über 1 abgearbeitet (ignoriert) werden, aber anders herum ergibt sich schon ein ganz anderer Tenor. Auf der anderen Seite - wenn ein System lange nicht antwortet (und das ist wohl der einzige Weg, wie die Events bestätigt werden können) ergibt sich eine riesige Queue von Events, die auch noch für jeden Client separat gespeichert und zusammengestekllt werden muss.

Alles nicht so trivial.

Hmm, die Ereignisse müssen also in Ihrer vorgesehenen Reihenfolge verarbeitet werden. Noch ein Grund, ein fertiges System zu nehmen, das es nicht gibt.

Die Architektur ist einfach die sauberste, die mir einfällt. Lässt sich gut debuggen, erweitern und warten. Ich denke, es lohnt sich.

nikosch · 04.08.2010, 16:50

Wozu soll das ganze denn dienen?

Themen-Optionen
Druckbare Version zeigen Jemanden per E-Mail auf dieses Thema hinweisen
Thema bewerten
Thema bewerten:

Ähnliche Themen
Thema	Autor	Forum	Antworten	Letzter Beitrag
[Erledigt] SQL UPDATE bei onclick Event!	Livastyle	JavaScript, Ajax und mehr	9	14.01.2010 22:28
[Erledigt] Im <option> ein onClick Event für Vorauswahl	Felix	JavaScript, Ajax und mehr	2	08.09.2009 14:53
variable mit onclick an php	drombusch	PHP Tipps 2009	8	30.08.2009 14:45
[Erledigt] OnClick event abbrechen	Frank	JavaScript, Ajax und mehr	4	25.08.2009 12:15
addEventListener mit Parameter aus Event	drsoong	JavaScript, Ajax und mehr	4	13.04.2009 23:02
Event: User Regestrierung in die Datenbank???	Dunkelelf9	Datenbanken	2	22.12.2008 15:49
jQuery: Parameter an onclick Event	ecomeback	HTML, Usability und Barrierefreiheit	1	08.04.2008 11:23
Event abfangen	Ambience	JavaScript, Ajax und mehr	4	30.08.2007 14:36
für jedes Event immer neuen Ordner anlegen, sinnvoll?	Matthiasnet	PHP Tipps 2007	3	19.05.2007 11:57
Event in Kalender ausgeben	zoro	PHP Tipps 2007	3	02.05.2007 13:40
Mauszeiger Position (ohne Event)	cowabunga1984	HTML, Usability und Barrierefreiheit	4	04.04.2007 12:01
JS - node, onClick Event hinzufügen, MSIE	Zergling-new	HTML, Usability und Barrierefreiheit	3	21.07.2006 19:46
Suche PHP Event Kalender		PHP Tipps 2005-2	2	28.09.2005 19:57
[Erledigt] Animiertes Gif auf Event starten		HTML, Usability und Barrierefreiheit	3	12.02.2005 19:54
[Erledigt] probleme mit event datenbank		Datenbanken	1	04.09.2004 00:30

03.08.2010, 19:20
boehlke Neuer Benutzer Registriert seit: 03.08.2010 Beiträge: 8 PHP-Kenntnisse: Fortgeschritten	event bus mit PHP Hallo Entwickler! In einem aktuellen Projekt entwickele ich eine Synchronisation zwischen zwei und vielleicht mal mehr PHP-Anwendungen. Die Systeme sollen möglichst entkoppelt bleiben, deshalb bietet sich eine Ereignis-orientierte Architektur an: Bei einer Änderung der Daten feuert das verursachende System ein Ereignis ab, dass von interessierten Systemen verarbeitet wird. Ich denke also an ein Publish-Subscribe-System, auch "event bus" genannt. Meine Frage an die Experten hier: Kennt ihr eine Event-Bus-Implementierung in PHP? Danke für die Hilfe! Beste Grüße, André


Mister Ad PHP Code Flüsterer Registriert seit: 21.08.2005 Beiträge: 4682 PHP-Kenntnisse: Fortgeschritten

03.08.2010, 19:51
xm22 Erfahrener Benutzer Registriert seit: 30.07.2008 Beiträge: 1.129 PHP-Kenntnisse: Fortgeschritten	Du könntest per Web-Service Requests an die zu benachrichtigenden System schicken (Push) oder die System in regelmäßigen Abständen nachfragen lassen (pull)

03.08.2010, 20:46
boehlke Neuer Benutzer Registriert seit: 03.08.2010 Beiträge: 8 PHP-Kenntnisse: Fortgeschritten	Danke für Dein Input! Ich brauche ein System, das die Ereignisse speichert und verteilt. Wie diese verteilt werden, ist mir zunächst nicht so wichtig. Beispiel: In System 1 wird ein Benutzer angelegt. Das System erzeugt ein Ereignis "Benutzer angelegt". Dieses Ereignis soll an alle Systeme weitergeleitet werden, die sich dafür interessieren. Das macht der Event Bus.

04.08.2010, 11:12
xm22 Erfahrener Benutzer Registriert seit: 30.07.2008 Beiträge: 1.129 PHP-Kenntnisse: Fortgeschritten	Die ini-Datei sieht etwas seltsam aus. Dreh doch die Speicherung lieber um, also etwa so (Mal xml, damit es sich einfacher abbilden lässt) Code: <events> <event id="UserCreatedEvent"> <listeners> <listener class="UserCrudListener" /> </listeners> </event> </events> Evtl. könnte/sollte man im Listener-Objekt direkt ein Callback hinterlegen, also so etwa: Code: <events> <event id="UserCreatedEvent"> <listeners> <listener class="UserCrudListener" function="onCreated" /> </listeners> </event> </events>

04.08.2010, 15:16
boehlke Neuer Benutzer Registriert seit: 03.08.2010 Beiträge: 8 PHP-Kenntnisse: Fortgeschritten	Eine XML-Konfigurationsdatei ist in dem Fall wirklich schöner. Danke.

04.08.2010, 16:50
nikosch moderatives Dielektrikum Registriert seit: 21.05.2008 Beiträge: 34.241 PHP-Kenntnisse: Fortgeschritten	Wozu soll das ganze denn dienen? __________________ -- One pixel is still too big. Please make it smaller. ASAP. Initiative Mittelstand. Die wichtigste Gestaltungsregel im Screendesign ist Pi mal Daumen des Arbeitgebers. --