Previous Next

Zend_Feed_Pubsubhubbub

Zend_Feed_Pubsubhubbub ist eine Implementation der PubSubHubbub Core 0.2 Spezifikation (Working Draft). Sie bietet eine Implementation eines Pubsubhubbub Publizisten und Abonnenten geeignet für den Zend Framework und andere PHP Anwendungen.

Was ist Pubsubhubbub?

Pubsubhubbub ist ein offenes, einfaches Web-skalierbares Pubsub Protokoll. Der normale Anwendungsfall ist es Blogs (Publizist) zu erlauben Aktualisierungen von deren RSS oder Atom Feeds (Themen) an Abonnenten zu "senden". Diese Abonenten müssen dem RSS oder Atom Feed des Blogs über einen Hub abonniert haben. Das ist ein zentraler Server der benachrichtigt wird wenn es Aktualisierungen des Publizisten gibt und diese anschließend an alle Abonnenten verteilt. Jeder Feed kann bekanntgeben das er ein oder mehrere Hubs unterstützen indem ein Atom Namespaced Linkelement mit dem Rel Attribut "hub" verwendet wird.

Pubsubhubbub hat Aufmerksamkeit erlangt weil es ein Pubsub Protokoll ist das einfach zu implementieren ist und über HTTP arbeitet. Seine Philosophie ist es das traditionelle Modell zu ersetzen indem Blog Feeds mit einem regulären Interfall abgefragt werden um Aktualisierungen zu erkennen und zu empfangen. Abhängig von der Frequenz der Abfrage kann es viel Zeit in Anspruch nehmen Aktualisierungen an interessierte Menschen bei Sammelstellen bis zu Desktop Lesern, bekannt zu machen. Mit der Verwendung eines Pubsub Systems werden Aktualisierungen nicht einfach von Abonnenten abgefragt sondern an die Abonnenten geschickt, was jegliche Verzögerung ausschaltet. Aus diesem Grund fungiert Pubsubhubbub als Teil von dem was als Echt-Zeit Web bekannt ist.

Das Protokoll existiert nicht isoliert. PubSub Systems gibt es schon seit einiger Zeit, wie auch das übliche Jabber Publish-Subscribe Protokoll, XEP-0060, oder das nicht so bekannte rssCloud (beschrieben 2001). Trotzdem haben diese keine keine breite Anwendung gefunden weil Sie entweder komplex sind, ein schlechtes Timing haben, oder nicht für Web Anwendungen verwendbar sind. Bei rssCloud, welches zuletzt als Antwort auf das Erscheinen von Pubsubhubbub revidiert wurde, wurde auch eine signifikante Steigerung gesehen obwohl es an einer formalen Spezifikation fehlt und es aktuell keine Atom 1.0 Feeds unterstützt.

Warscheinlich überraschend weil es noch relativ Jung ist, ist Pubsubhubbub trotzdem bereits in Verwendung unter anderem bei Google Reader, Feedburner und es sind Plugins für Wordpress Blogs vorhanden.

Architektur

Zend_Feed_Pubsubhubbub implementiert zwei Seiten der Pubsubhubbub 0.2 Spezifikation: einen Publizisten und einen Abonnenten. Es implementiert aktuell keinen Hub Server. Dieser ist aber in Arbeit für ein zukünftiges Zend Framework Release.

Ein Publizist ist verantwortlich für die Mitteilung aller Aktualisierungen seines Feeds an alle unterstützten Hubs (es können viele unterstützt werden um Redundanz zu einem System hinzuzufügen), egal ob es sich um Atom oder RSS basierte handelt. Das wird getan indem die unterstützten Hub Server mit der URL des aktualisierten Feeds gepingt werden. In der Pubsubhubbub Terminologie wird jede aktualisierbare Ressource welche in der Lage ist abonniert zu werden als Thema bezeichnet. Sobald ein Ping empfangen wird, frägt der Hub den aktualisierten Feed ab, bearbeitet die aktualisierten Elemente, und leitet alle Aktualisierungen an alle Abonnenten weiter die diesen Feed abonniert haben.

Ein Abonnent ist jedes Mitglied oder jede Anwendung welche einen oder mehrere Hubs abonniert um Aktuslisierungen von einem Thema zu empfangen welches von einem Publizisten gehostet wird. Der Abonnent kommuniziert niemals direkt mit dem Publizisten da der Hub als Zwischenglied fungiert welches Abos akzeptiert und Aktualisierungen an Abonnenten sendet. Der Abonnent kommuniziert seinerseits nur mit dem Hub um Themen entweder zu abonnieren und Abos zu entfernen, oder wenn er Aktualisierungen vom Hub empfängt. Dieses Design der Kommunikation ("Fat Pings") entfernt effektiverweise die Möglichkeit eines "Thundering Herd" Problems. Dieses findet in einem Pubsub System statt in dem der Hub Abonnenten über eine vorhandene Aktualisierung informiert, und alle Abonnenten dazu auffordert den Feed sofort vom Publizisten zu empfangen, was zu einer Verkehrsspitze führt. In Pubsubhubbub verteilt der Hub das aktuelle Update in einem "Fat Ping" so dass der Publizist keine Verkehrsspitze aushalten muss.

Zend_Feed_Pubsubhubbub implementiert Pubsubhubbub Publizisten und Abonnenten mit den Klassen Zend_Feed_Pubsubhubbub_Publisher und Zend_Feed_Pubsubhubbub_Subscriber. Zusätzlich kann die Implementation des Abonnenten alle Feed Aktualisierungen behandeln die von einem Hub weitergeleitet werden indem Zend_Feed_Pubsubhubbub_Subscriber_Callback verwendet wird. Diese Klassen, deren Verwendungszweck, und die APIs werden in den weiterführenden Abschnitten behandelt.

Zend_Feed_Pubsubhubbub_Publisher

In Pubsubhubbub ist der Publizist der Teilnehmer welcher einen lebenden Feed veröffentlicht und Ihn regelmäßig mit neuem Inhalt aktualisiert. Das kann ein Blog, eine Sammlung, oder sogar ein Webservice mit einer öffentlichen Feed basierenden API sein. Damit diese Aktualisierungen zu den Abonnenten geschickt werden können, muss der Publizist alle seine unterstützten Hubs darüber informieren das eine Aktualisierung stattgefunden hat, indem eine einfache HTTP POST Anfrage verwendet wird, welche die URI oder das aktualisierte Thema enthält (z.B. den aktualisierten RSS oder Atom Feed). Der Hub bestätigt den Empfang der Benachrichtigung, holt den aktualisierten Feed, und leitet alle Aktualisierungen an alle Abonnenten weiter welche sich bei diesem Hub für Aktualisierungen für den relevanten Feed angemeldet haben.

Vom Design her bedeutet dies dass der Publizist sehr wenig zu tun hat ausser diese Hub Pings jedesmal zu senden wenn sich seine Feeds ändern. Als Ergebnis hiervon ist die Implementation des Publizisten extrem einfach zu verwenden und benötigt sehr wenig Arbeit für die Einrichtung und Verwendung wenn Feeds aktualisiert werden.

Zend_Feed_Pubsubhubbub_Publisher implementiert einen kompletten Pubsubhubbub Publizisten. Sein Setup ist sehr einfach und hauptsächlich müssen bei Ihm nur die URI Endpunkte für alle Hubs konfiguriert werden welche bei Aktualisierungen benachrichtigt werden müssen, und die URIs aller Themen die in Benachrichtigungen einzubinden sind.

Das folgende Beispiel zeigt einen Publizisten der eine Sammlung von Hubs über Aktualisierungen zu einem Paar von lokalen RSS und Atom Feeds benachrichtigt. Die Klasse enthält eine Anzahl von Fehlern welche die URLs des Hubs enthalten, damit Benachrichtigungen stäter wieder ausgeführt oder protokolliert werden können wenn irgendeine Benachrichtigung fehlschlägt. Jedes resultierende Fehlerarray enthält auch einen "response" Schlüssel welche das betreffende HTTP Antwortobjekt enthält. In Falle irgendeines Fehlers wird empfohlen die Operation für den fehlgeschlagenen Hub Endpunkt in Zukunft zumindest noch einmal zu versuchen. Das kann die Verwendung einer geplanten Aufgabe für diesen Zweck oder einer Job Queue wenn solche extra Schritte optional sind.

$publisher = new Zend_Feed_Pubsubhubbub_Publisher;
$publisher->addHubUrls(array(
    'http://pubsubhubbub.appspot.com/',
    'http://hubbub.example.com',
));
$publisher->addUpdatedTopicUrls(array(
    'http://www.example.net/rss',
    'http://www.example.net/atom',
));
$publisher->notifyAll();

if (!$publisher->isSuccess()) {
    // Auf Fehler prüfen
    $errors     = $publisher->getErrors();
    $failedHubs = array()
    foreach ($errors as $error) {
        $failedHubs[] = $error['hubUrl'];
    }
}

// Benachrichtigung für fehlgeschlagene Hubs in $failedHubs nochmals planen

Wenn man eine konkretere Kontrolle über den Publizisten bevorzugt, gibt es die Methoden addHubUrls() und addUpdatedTopicUrls() welche jeden Arraywert an die einzelnen öffentlichen Methoden addHubUrl() und addUpdatedTopicUrl() übergeben. Es gibt auch passende removeUpdatedTopicUrl() und removeHubUrl() Methoden.

Man kann das Setzen der Hub URIs auch überspringen und jeden in Folge benachrichtigen indem die Methode notifyHub() verwendet wird welche die URI eines Hub Endpunkts als sein einziges Argument akzeptiert.

Es gibt keine anderen Aufgaben die abzudecken sind. Die Implementation des Publizisten ist sehr einfach da das meiste der Feedbearbeitung und Verteilung von den ausgewählten Hubs durchgeführt wird. Es ist trotzdem wichtig Fehler zu erkennen und Benachrichtigungen wieder so früh wie möglich zu planen (mit einer vernünftigen maximalen Anzahl an Versuchen) um sicherzustellen das Benachrichtigungen alle Abonnenten erreichen. In vielen Fällen können Hubs, als endgültige Alternative, den eigenen Feed regelmäßig abfragen um zusätzliche Toleranzen bei Fehlern anzubieten sowohl wegen deren eigenen temporären Downtime als auch den Fehlern und der Downtime des Publizisten.

Zend_Feed_Pubsubhubbub_Subscriber

In Pubsubhubbub ist der Abonnent ein Teilnehmer welcher Aktualisierungen zu irgendeinem Thema (einem RSS oder Atom Feed) empfangen will. Er kann dass bewerkstelligen indem er einen oder mehrere Hubs abonniert welche von diesem Thema beworben werden, normalerweise als ein Set von ein oder mehreren Atom 1.0 Links mit dem Rel Attribut "hub". Ab diesem Punkt sendet der Hub, wenn er eine Benachrichtigung über eine Aktualisierung des Publizisten empfängt, einen Atom oder RSS Feed, welcher alle Aktualisierungen enthält, zur Callback URL des Abonnenten. Über diesen Weg muss der Abonnent niemals den originalen Feed besuchen (obwohl es trotzdem empfohlen wird um sicherzustellen das Aktualisierungen empfangen werden wenn ein Hub jemals offline geht). Alle Anfragen für Abos müssen die URI des Themas enthalten welches abonniert werden soll, und eine Callback URL welche der Hub verwendet um das Abo zu bestätigen und um Aktualisierungen weiterzuleiten.

Der Abonnent hat deswegen zwei Rollen. Abos zu erstellen und zu managen, inklusive der Abonnierung von neuen Themen mit einem Hub, dem kündigen von Abos (wenn notwendig), und periodisch Abos zu erneuern da diese eine begrenzte Gültigkeit haben können was durch den Hub gesetzt wird. Dies wird von

Die zweite Rolle ist es Aktualisierungen zu akzeptieren welche vom Hub zur Callback URL des Abonnenten gesendet werden, wenn z.B. die URI des Abonnenten zugeordnet wurde um Aktualisierungen zu behandeln. Die Callback URL behandelt auch Events wenn der Hub den Abonnenten kontaktiert um alle Abos zu das Löschen von Abos zu bestätigen. Dies wird behandelt indem eine Instanz von Zend_Feed_Pubsubhubbub_Subscriber_Callback verwendet wird wenn auf die Callback URL zugegriffen wird.

Important

Zend_Feed_Pubsubhubbub_Subscriber implementiert die Pubsubhubbub Spezifikation 0.2. Da dies eine Version der Spezifikation ist implementieren Sie aktuell nicht alle Hubs. Die neue Spezifikation erlaubt der Callback URL einen Abfragestring einzubinden welcher von dieser Klasse verwendet, aber nicht von allen Hubs unterstützt wird. Im Interesse einer maximalen Kompatibilität wird deshalb empfohlen die Komponente des Abfragestrings der Callback URI des Abonnenten als Pfadelement darzustellen, z.B. als Parameter in der Route erkannt und mit der Callback URI assoziiert und vom Router der Anwendung verwendet.

Abonnieren und Abos löschen

Zend_Feed_Pubsubhubbub_Subscriber implementiert einen kompletten Pubsubhubbub Abonnenten der in der Lage ist jedes Thema über jeden Hub der von diesem Thema vermittelt wird zu abonnieren und Abos zu löschen. Er arbeitet in Verbindung mit Zend_Feed_Pubsubhubbub_Subscriber_Callback welcher Anfragen von einem Hub akzeptiert um alle Aboanfragen und das Löschen von Abos zu bestätigen (um Missbrauch durch andere zu verhindern).

Jedes Abo (oder Löschen eines Abos) benötigt die betreffende Information bevor es bearbeitet werden kann, z.B. die URI des Themas (Atom oder RSS Feed) das für Aktualisierungen abonniert werden soll, und die URI des Endpunkts für den Hub welcher die Anmeldung auf das Abo bearbeitet und die Aktualisierungen weiterleitet. Die Lebenszeit eines Abos kann durch den Hub ermittelt werden, aber die meisten Hubs sollten die automatische Auffrischung des Abos unterstützen indem der Abonnenten geprüft wird. Das wird von Zend_Feed_Pubsubhubbub_Subscriber_Callback unterstützt und benötigt keine weitere Arbeit. Es wird trotzdem empfohlen dass man die vom Hub kommende Lebenszeit des Abos (time to live, ttl) verwendet um die Erstellung neuer Abos zu planen (der Prozess ist identisch mit dem eines neuen Abos) um es beim Hub zu aktualisieren. Wärend das per se nicht notwendig ist, deckt es Fälle ab in denen ein Hub die automatische Aktualisierung des Abos nicht unterstützt und deckt damit Fehler des Hubs mit zusätzlicher Redundanz ab.

Mit der relevanten Information an der Hand kann eine Abonnierung wie anbei gezeigt versucht werden:

$storage = new Zend_Feed_Pubsubhubbub_Model_Subscription;

$subscriber = new Zend_Feed_Pubsubhubbub_Subscriber;
$subscriber->setStorage($storage);
$subscriber->addHubUrl('http://hubbub.example.com');
$subscriber->setTopicUrl('http://www.example.net/rss.xml');
$subscriber->setCallbackUrl('http://www.mydomain.com/hubbub/callback');
$subscriber->subscribeAll();

Um Abos zu speichern und Zugriff auf dessen Daten für eine generelle Verwendung zu Speichern benötigt die Komponente eine Datenbank (ein Schema wird später in diesem Abschnitt angeboten). Standardmäßig wird angenommen das der Name der Tabelle "subscription" ist und im Hintergrund Zend_Db_Table_Abstract anwendet, was bedeutet das der Standardadapter verwendet wird welcher in der Anwendung gesetzt ist. Man kann auch eine eigene spezielle Instanz von Zend_Db_Table_Abstract in das assoziierte Modell von Zend_Feed_Pubsubhubbub_Model_Subscription übergeben. Dieser eigene Adapter kann so einfach wie gewünscht sein indem der Name der Tabelle welche zu verwenden ist geändert wird, oder so komplex wie es notwendig ist.

Wärend das Modell als standardmäßige bereits verwendbare Lösung angeboten wird, kann man sein eigenes Modell verwenden indem irgendein anderes Backend oder Datenbanklayer (z.B. Doctrine) verwendet wird, solange die resultierende Klasse das Interface Zend_Feed_Pubsubhubbub_Model_SubscriptionInterface implementiert.

Ein Beispielschema (MySQL) für eine Abotabelle auf welche vom angebotenen Modell aus zugegriffen werden kann, könnte wie folgt aussehen:

CREATE TABLE IF NOT EXISTS `subscription` (
  `id` varchar(32) COLLATE utf8_unicode_ci NOT NULL DEFAULT '',
  `topic_url` varchar(255) COLLATE utf8_unicode_ci DEFAULT NULL,
  `hub_url` varchar(255) COLLATE utf8_unicode_ci DEFAULT NULL,
  `created_time` datetime DEFAULT NULL,
  `lease_seconds` bigint(20) DEFAULT NULL,
  `verify_token` varchar(255) COLLATE utf8_unicode_ci DEFAULT NULL,
  `secret` varchar(255) COLLATE utf8_unicode_ci DEFAULT NULL,
  `expiration_time` datetime DEFAULT NULL,
  `subscription_state` varchar(12) COLLATE utf8_unicode_ci DEFAULT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_unicode_ci;

Im Hintergrund sendet der Abonnent eine Anfrage an den Endpunkt des Hubs welche die folgenden Parameter enthält (basierend auf dem vorhergehenden Beispiel):

Anfrageparameter beim Abonnieren
Parameter Wert Beschreibung
hub.callback http://www.mydomain.com/hubbub/callback?xhub.subscription=5536df06b5dcb966edab3a4c4d56213c16a8184

Die URI welche von einem Hub verwendet wird um den Abonnenten zu kontaktieren und entweder eine Bestätigung für eine Anfrage oder das Löschen eines Abos abzufragen oder Aktualisierungen für abonnierte Feeds zu senden. Der angehängte Abfragestring enthält einen eigenen Parameter (demzufolge der Zweck von xhub). Es ist ein Parameter für einen Abfragestring welcher vom Hub aufbewahrt um mit allen Anfragen des Abonnenten wieder versendet wird. Sein Zweck ist es dem Abonnenten zu erlauben sich zu identifizieren und die Abos zu betrachten welche mit einer beliebigen Hubanfrage in einem Backend-Speichermedium assoziiert sind. Das ist kein Standardparameter welcher von dieser Komponente verwendet wird statt einen Aboschlüssel im URI Pfad zu kodieren, was in einer Zend Framework Anwendung viel komplizierter zu implementieren wäre.

Trotzdem, da nicht alle Hubs Parameter für den Abfragestring unterstützen wird empfohlen den Aboschlüssel als Pfadkomponente in der Form von http://www.mydomain.com/hubbub/callback/5536df06b5dcb966edab3a4c4d56213c16a8184 hinzuzufügen. Um das zu bewerkstelligen, wird die Definition einer Route benötigt welche in der Lage ist den endgültigen Wert des Schlüssels herauszuparsen den Wert zu erhalten und Ihn an das Callback Objekt des Abonnenten zu übergeben. Der Wert würde an die Methode Zend_Pubsubhubbub_Subscriber_Callback::setSubscriptionKey() übergeben. Ein detailiertes Beispiel wird später gezeigt.

hub.lease_seconds 2592000

Die Anzahl an Sekunden für welche der Abonnenten will dass ein neues Abo gültig bleibt (z.B. ein TTL). Hubs können Ihre eigene maximale Abodauer erzwingen. Alle Abos sollten erneuert werden indem einfach erneut abonniert wird bevor die Abodauer endet um die Kontinuierlichkeit der Aktualisierungen zu gewährleisten. Hubs sollten zusätzlich versuchen Abos automatisch zu aktualisieren bevor diese auslaufen indem die Abonnenten kontaktiert werden (dies wird automatisch von der Callback Klasse behandelt).

hub.mode subscribe

Ein einfacher Wert welche anzeigt das dies eine Aboanfrage ist. Anfragen für das Löschen von Abos würden den Wert "unsubscribe" verwenden.

hub.topic http://www.example.net/rss.xml

Die URI des Themas (z.B. Atom oder RSS Feed) welche der Abonnent zu abonnieren wünscht damit er Aktualisierungen bekommt.

hub.verify sync

Zeigt dem Hub die bevorzugte Methode der Prüfung von Abos und dem Löschen von Abos. Sie wird im Normalfall zwei mal wiederholt. Technisch gesehen unterscheidet diese Komponente nicht zwischen den zwei Modi und behandelt beide gleich.

hub.verify async

Zeigt dem Hub die bevorzugte Methode der Prüfung von Abos und dem Löschen von Abos. Sie wird im Normalfall zwei mal wiederholt. Technisch gesehen unterscheidet diese Komponente nicht zwischen den zwei Modi und behandelt beide gleich.

hub.verify_token 3065919804abcaa7212ae89.879827871253878386

Ein Prüftoken welcher dem Abonnenten vom Hub zurückgegeben wird wenn er ein Abos oder das Löschen eines Abos bestätigt. Bietet ein Maß an Vertrauen dass die Bestätigung der Anfrage vom aktuellen Hub kommt um Missbrauch zu vermeiden.

Man kann verschiedene dieser Parameter verändern um eine andere Vorliebe anzuzeigen. Zum Beispiel kann man eine anderen Wert der Gültigkeit in Sekunden setzen indem man Zend_Pubsubhubbub_Subscriber::setLeaseSeconds() verwendet, oder eine Vorliebe für eine asynchrone Prüfung zeigen indem setPreferredVerificationMode(Zend_Feed_Pubsubhubbub::VERIFICATION_MODE_ASYNC) verwendet wird. Trotzdem bleiben die Hubs in der Lage Ihre eigenen Vorlieben zu erzwingen, und aus diesem Grund wurde die Komponente so designt dass Sie mit fast jedem Set an Optionen arbeitet und eine minimale Konfiguration des End-Benutzers erfordert. Konventionen sind toll wenn Sie funktionieren!

Hinweis:

Wärend Hubs die Verwendung eines spezifischen Prüfmodus benötigen können (beide werden von Zend_Pubsubhubbub unterstützt), kann eine spezifische die zu bevorzugen ist durch Verwendung der Method Zend_Pubsubhubbub angezeigt werden. Im Modus "sync" (synchron) versucht der Hub eine Aboanfrage sofort zu bestätigen sobald diese empfangen, und noch bevor auf die Aboanfrage geantwortet wird. Im Modus "async" (asynchron) gibt der Hub sofort eine Antwort auf die Aboanfrage zurück, und die Prüfanfrage kann später stattfinden. Da Zend_Pubsubhubbub die Rolle der Aboprüfung als eigene Callback Klasse implementiert, und die Verwendung eines Backend Speichermediums, unterstützt Sie beide transparent im Sinne der Geschwindigkeit des Endbenutzers. Die acynchrone Prüfung ist stark zu bevorzugen um die Nachteile eines schlecht performenden Hubs zu eliminieren, und die Server Ressourcen des End-Benutzers und die Verbindungen nicht zu lange zu binden.

Das Löschen eines Abos folgt exakt dem gleichen Pattern wie im vorherigen Beispiel, mit der Ausnahme das stattdessen unsubscribeAll() aufgerufen wird. Die enthaltenen Parameter sind identisch mit einer Aboanfrage mit der Ausnahme das "hub.mode" auf "unsubscribe" gesetzt wird.

Standardmäßig versucht eine neue Instanz von Zend_Pubsubhubbub_Subscriber ein Datenbank Backend Speichermedium zu verwenden mit Standardwerten um den standardmäßigen Zend_Db Adapter mit dem Tabellennamen "subscription" zu verwenden. Es wird empfohlen eine eigene Speicherlösung zu setzen welche diese Standardwerte nicht verwendet, entweder duch übergabe eines neuen Modells welches das benötigte Interface unterstützt, oder durch Übergabe einer neuen Instanz von Zend_Db_Table_Abstract an dem Constructor des standardmäßigen Modells um den verwendeten Tabellennamen zu verändern.

Callbacks von Abonnenten behandeln

Wann auch immer eine Aboanfrage oder eine Anfrage auf Löschen eines Abos gemacht wird muss der Hub die Anfrage prüfen indem er eine neue Prüfanfrage an die Callback URL weiterleitet welche in den Abo or Abo löschen Parametern gesetzt ist. Um diese Hub Anfragen zu behandeln, welche alle zukünftigen Kommunikationen enthalten können wie z.B. Themenaktualisierungen (Feed), sollte die Callback URL die Ausführung einer Instanz von Zend_Pubsubhubbub_Subscriber_Callback auslösen um die Anfrage zu behandeln.

Die Callback Klasse sollte konfiguriert werden dass Sie das selbe Speichermedium wie die Subscriber Klasse verwendet. Ihre Verwendung ist sehr einfach da die meiste Arbeit intern erledigt wird.

$storage = new Zend_Feed_Pubsubhubbub_Model_Subscription;
$callback = new Zend_Feed_Pubsubhubbub_Subscriber_Callback;
$callback->setStorage($storage);
$callback->handle();
$callback->sendResponse();

/**
 * Prüfe ob der resultierende Callback das Ergebnis eines Feed Updates ist.
 * Andernfalls war es entweder eine (De-)Abo-Prüfanfrage oder ungültig.
 * Typischerweise müssen wir nicht mehr tun als die Behandlung der
 * Aktualisierungen vom Feed hinzuzufügen - der Rest wird intern von der
 * Klasse behandelt.
 */
if ($callback->hasFeedUpdate()) {
    $feedString = $callback->getFeedUpdate();
    /**
     * Die Aktualisierung des Feeds asynchron bearbeiten um ein Timeout
     * des Hubs zu vermeiden.
     */
}

Hinweis:

Es sollte beachtet werden dass Zend_Feed_Pubsubhubbub_Subscriber_Callback jeden hereinkommenden Anfragestring und andere Parameter unabhängig parsen kann. Dies ist notwendig da PHP die Struktur und Schlüssel eines Abfragestrings ändert wenn diese in die Superglobals $_GET oder $_POST geparst wird. Zum Beispiel werden alle doppelten Schlüssel ignoriert und Punkte werden in Unterstriche konvertiert. Pubsubhubbub unterstützt beide in den Abfragestring die es erzeugt.

Important

Es ist wichtig das Entwickler erkennen das Hubs nur mit dem Senden von Anfragen und dem Empfangen einer Antwort beschäftigt sind welche den Empfang prüft. Wenn eine Feedaktualisierung empfangen wird sollte Sie niemals nachfolgend bearbeitet werden da Sie den Hub auf eine Antwort warten lässt. Stattdessen sollte jede Bearbeitung auf einen anderen Prozess ausgelagert werden oder verzögert bis eine Antwort zum Hub zurückgesendet wird. Ein Symptom des Fehlers Hubanfragen sofort zu komplettieren besteht darin das ein Hub weitere Versuche durchführen kann die Aktualisierungs- oder Prüfanfrage zuzustellen was zu doppelten Aktualisierungsversuchen führen kann die vom Abonnenten bearbeitet werden. Das scheint problematisch zu sein -- aber in Wirklichkeit kann ein Hub ein Timeout von ein paar Sekunden anwenden, und wenn keine Antwort in dieser Zeit empfangen wird kann er trennen (in der annahme eines Zustellfehlers) und es später nochmal versuchen. Es ist zu beachten das von Hubs erwartet wird das Wie große Mengen an Aktualisierungen verteilen und Ihre Ressources deswegen gestreckt sind - bitte bearbeiten Sie Feeds asynchron (z.B. in einem separaten Prozess oder einer Job Queue oder sogar in einem geplanten Cron Task) soweit das möglich ist.

Eine Callback URL Route einstellen und verwenden

Wie vorher erwähnt empfängt die Klasse Zend_Feed_Pubsubhubbub_Subscriber_Callback den kombinierten Schlüssel welche mit jedem Abo assoziiert ist vom Hub über eine oder zwei Methoden. Die technisch bevorzugte Methode ist das Hinzufügen dieses Schlüssels zur Callback URL welcher für den Hub in allen zukünftigen Anfragen tätig ist indem ein Stringparameter in der Abfrage mit dem Schlüssel "xhub.subscription" verwendet wird. Trotzdem, aus historischen Gründen, weil es in Pubsubhubbub 0.1 nicht unterstützt wurde (es wurde kürzlich nur in 0.2 hinzugefügt) ist es stärkstens empfohlen das kompatibelste zu verwenden und den Schlüssel der Callback URL hinzuzugefügen indem er den URL Pfaden angehängt wird.

Deshalb würde die URL http://www.example.com/callback?xhub.subscription=key zu http://www.example.com/callback/key werden.

Da die Abfragestring Methode der Standard in der Vermeidung eines größeren Levels der zukünftigen Unterstützung der kompletten 0.2 Spezifikation ist, benötigt es etwas zusätzliche Arbeit um Sie zu implementieren.

Der erste Schritt besteht darin der Klasse Zend_Feed_Pubsubhubbub_Subscriber_Callback dem Pfad bewusst zu machen welcher den Aboschlüssel enthält. Er wird hierfür manuell injiziert, da man für diesen Zweck auch eine Route manuell definieren muss. Das wird erzielt indem einfach die Methode Zend_Feed_Pubsubhubbub_Subscriber_Callback::setSubscriptionKey() mit dem Parameter aufgerufen wird welcher der Schlüsselwert ist der vom Router kommt. Das folgende Beispiel zeigt dies durch Verwendung eines Zend Framework Controllers.

class CallbackController extends Zend_Controller_Action
{

    public function indexAction()
    {
        $storage = new Zend_Feed_Pubsubhubbub_Model_Subscription;
        $callback = new Zend_Feed_Pubsubhubbub_Subscriber_Callback;
        $callback->setStorage($storage);
        /**
         * Injiziert den Aboschlüssel welcher er vom URL Pfad geparst wird
         * indem ein Parameter vom Router verwendet wird
         */
        $subscriptionKey = $this->_getParam('subkey');
        $callback->setSubscriptionKey($subscriptionKey);
        $callback->handle();
        $callback->sendResponse();

        /**
         * Prüfen ob der Callback als Ergebnis den Empfang eines Feed Updates
         * enthält. Anderfalls war es entweder eine De-Aboprüfungsanfrage oder
         * eine ungültige Anfrage. Typischerweise muss nichts anderes getan
         * werden als das Handling der Feedaktualisierungen hinzuzufügen - der
         * Rest wird intern von der Klasse behandelt.
         */
        if ($callback->hasFeedUpdate()) {
            $feedString = $callback->getFeedUpdate();
            /**
             * Die Aktualisierung des Feeds asynchron behandeln um Hub
             * Timeouts zu vermeiden.
             */
        }
    }

}

Aktuell kann das Hinzufügen der Route zu einem Parameter welcher den Schlüssel der an den Pfad angehängt wird mappen würde durchgeführt werden indem eine Routenkonfiguration wie im kommenden INI formatierten Beispiel für die Verwendung mit dem Bootstrapping von Zend_Application verwendet wird.

; Callback Route fürs Hinzufügen einer PuSH Aboschlüssel Abfrage zu aktivieren
resources.router.routes.callback.route = "callback/:subkey"
resources.router.routes.callback.defaults.module = "default"
resources.router.routes.callback.defaults.controller = "callback"
resources.router.routes.callback.defaults.action = "index"
Previous Next
Einführung zum Zend Framework
Übersicht
Installation
Einstieg ins Zend Framework
Schnellstart in den Zend Framework
Zend Framework & MVC Einführung
Das Projekt erstellen
Ein Layout erstellen
Ein Modell und eine Datenbank Tabelle erstellen
Erstellen eines Formulars
Gratulation!
Autoloading im Zend Framework
Einführung
Ziele und Design
Grundsätzliche Verwendung von Autoloadern
Automatisches Laden von Ressourcen
Zusammenfassung
Plugins im Zend Framework
Einführung
Verwenden von Plugins
Fazit
Einstieg in Zend_Layout
Einführung
Zend_Layout verwenden
Zend_Layout: Fazit
Einstieg in Zend_View Platzhalter
Einführung
Grundsätzliche Verwendung von Platzhaltern
Standard Platzhalter
View Platzhalter: Fazit
Zend_Form's Gestalter (Decorator) verstehen und verwenden
Einführung
Decorator Grundlagen
Layeraufbau von Decorators
Darstellung individueller Decorators
Erstellung und Darstellung von kombinierten Elementen
Fazit
Einstieg in Zend_Session, Zend_Auth, und Zend_Acl
Erstellung von Multi-User Anwendungen mit Zend Framework
User Session im Zend Framework managen
Benutzer im Zend Framework authentifizieren
Erstellung eines Authorisations Systems in Zend Framework
Einstieg in Zend_Search_Lucene
Einführung in Zend_Search_Lucene
Lucene Index Struktur
Indezes öffnen und erstellen
Indizierung
Suchen
Unterstützte Abfragen
Seitendarstellung von Suchergebnissen
Einstieg in Zend_Paginator
Einführung
Einfaches Beispiel
Seitenkontrolle und ScrollingStyles
Alles zusammenfügen
Zend Framework's Referenz
Zend_Acl
Einführung
Verfeinern der Zugriffskontrolle
Fortgeschrittene Verwendung
Zend_Amf
Einführung
Zend_Amf_Server
Zend_Application
Einführung
Zend_Application Quick Start
Theorie der Funktionsweise
Beispiele
Kern Funktionalität
Vorhandene Ressource Plugins
Zend_Auth
Einführung
Datenbanktabellen Authentifizierung
Digest Authentication
HTTP Authentication Adapter
LDAP Authentifizierung
Open ID Authentifikation
Zend_Barcode
Einführung
Barcodes mit Hilfe der Zend_Barcode Klasse erstellen
Zend_Barcode Objekte
Zend_Barcode Renderer
Zend_Cache
Einführung
Die Theorie des Cachens
Zend_Cache Frontends
Zend_Cache Backends
Der Cache Manager
Zend_Captcha
Einführung
Captcha Anwendung
CAPTCHA Adapter
Zend_CodeGenerator
Einführung
Zend_CodeGenerator Beispiele
Zend_CodeGenerator Referenz
Zend_Config
Einleitung
Theory of Operation
Zend_Config_Ini
Zend_Config_Xml
Zend_Config_Writer
Zend_Config_Writer
Zend_Console_Getopt
Einführung
Definieren von Getopt Regeln
Holen von Optionen und Argumenten
Konfigurieren von Zend_Console_Getopt
Zend_Controller
Zend_Controller Schnellstart
Zend_Controller Grundlagen
Der Front Controller
Das Request Objekt
Der Standard Router
Der Dispatcher
Action Controller
Action Helfer
Das Response Objekt
Plugins
Eine konventionelle modulare Verzeichnis Struktur verwenden
MVC Ausnahmen
Zend_Currency
Einführung in Zend_Currency
Zend_Currency verwenden
Optionen für Währungen
Was macht eine Währung aus?
Wo ist die Währung?
Wie sieht die Währung aus?
Wie viel Währung habe ich?
Rechnen mit Währungen
Währungen wechseln
Zusätzliche Informationen für Zend_Currency
Zend_Date
Einführung
Theorie der Arbeitsweise
Basis Methoden
Zend_Date API Übersicht
Erstellen von Datumswerten
Konstanten für generelle Datums Funktionen
Funktionierende Beispiele
Zend_Db
Zend_Db_Adapter
Zend_Db_Statement
Zend_Db_Profiler
Zend_Db_Select
Zend_Db_Table
Zend_Db_Table_Row
Zend_Db_Table_Rowset
Zend_Db_Table Relationships
Zend_Db_Table_Definition
Zend_Debug
Variablen ausgeben
Zend_Dojo
Einführung
Zend_Dojo_Data: dojo.data Envelopes
Dojo View Helfer
Formular Elemente und Dekoratore für Dojo
Support für den Build Layer von Zend_Dojo
Zend_Dom
Einführung
Zend_Dom_Query
Zend_Exception
Verwenden von Ausnahmen
Grundsätzliche Verwendung
Vorherige Exceptions
Zend_Feed
Einführung
Feeds importieren
Feeds von Websites abrufen
Einen RSS Feed konsumieren
Einen Atom Feed konsumieren
Einen einzelnen Atom Eintrag konsumieren
Verändern der Feed- und Eintragsstruktur
Eigene Klassen für Feeds und Einträge
Zend_Feed_Reader
Zend_Feed_Writer
Zend_Feed_Pubsubhubbub
Zend_File
Zend_File_Transfer
Prüfungen für Zend_File_Transfer
Filter für Zend_File_Transfer
Zend_Filter
Einführung
Standard Filter Klassen
Filter Ketten
Filter schreiben
Zend_Filter_Input
Zend_Filter_Inflector
Zend_Form
Zend_Form
Schnellstart mit Zend_Form
Erstellen von Form Elementen mit Hilfe von Zend_Form_Element
Erstellen von Form durch Verwendung von Zend_Form
Erstellen von eigenem Form Markup durch Zend_Form_Decorator
Standard Form Elemente die mit dem Zend Framework ausgeliefert werden
Standard Formular Dekoratoren die mit dem Zend Framework ausgeliefert werden
Internationalisierung von Zend_Form
Fortgeschrittene Verwendung von Zend_Form
Zend_Gdata
Einführung
Authentifizierung mit AuthSub
Die Buchsuche Daten API verwenden
Authentifizieren mit ClientLogin
Google Kalender verwenden
Verwenden der Google Dokumente Listen Daten API
Verwenden von Google Health
Google Tabellenkalkulation verwenden
Google Apps Provisionierung verwenden
Google Base verwenden
Picasa Web Alben verwenden
Verwenden der YouTube Daten API
Gdata Ausnahmen auffangen
Zend_Http
Einführung
Zend_Http_Client - Fortgeschrittende Nutzung
Zend_Http_Client - Verbindungsadapter
Zend_Http_Cookie und Zend_Http_CookieJar
Zend_Http_Response
Zend_InfoCard
Einführung
Zend_Json
Einführung
Grundlegende Verwendung
Fortgeschrittene Verwendung von Zend_Json
XML zu JSON Konvertierung
Zend_Json_Server - JSON-RPC Server
Zend_Layout
Einführung
Zend_Layout Schnellstart
Zend_Layout Konfigurations Optionen
Erweiterte Verwendung von Zend_Layout
Zend_Ldap
Einführung
API Übersicht
Szenarien der Verwendung
Tools
Objektorientierter Zugriff auf den LDAP Baum durch Verwendung von Zend_Ldap_Node
Informationen vom LDAP Server erhalten
Serialisieren von LDAP Daten von und zu LDIF
Zend_Loader
Dynamisches Laden von Dateien und Klassen
Der Autoloader
Ressource Autoloader
Plugins laden
Zend_Locale
Einführung
Zend_Locale verwenden
Normalisierung und Lokalisierung
Arbeiten mit Daten und Zeiten
Unterstützte Gebietsschemata
Zend_Log
Übersicht
Writer
Formatter
Filter
Die Factory verwenden um ein Log zu erstellen
Zend_Mail
Einführung
Versand über SMTP
Versand von mehreren E-Mails über eine SMTP Verbindung
Verwendung von unterschiedlichen Versandwegen
HTML E-Mail
Anhänge
Empfänger hinzufügen
Die MIME Abgrenzung kontrollieren
Zusätzliche Kopfzeilen
Zeichensätze
Kodierung
SMTP Authentifizierung
SMTP Übertragungen sichern
Lesen von Mail Nachrichten
Zend_Markup
Einführung
Beginnen mit Zend_Markup
Zend_Markup Parser
Zend_Markup Renderer
Zend_Measure
Einführung
Erstellung einer Maßeinheit
Ausgabe von Maßeinheiten
Manipulation von Maßeinheiten
Arten von Maßeinheiten
Zend_Memory
Übersicht
Memory Manager
Memory Objekte
Zend_Mime
Zend_Mime
Zend_Mime_Message
Zend_Mime_Part
Zend_Navigation
Einführung
Seiten
Container
Zend_Oauth
Einführung zu OAuth
Zend_OpenId
Einführung
Zend_OpenId_Consumer Grundlagen
Zend_OpenId_Provider
Zend_Paginator
Einführung
Verwendung
Konfiguration
Advanced usage
Zend_Pdf
Einführung
Erstellen und Laden von PDF Dokumenten
Änderungen an PDF Dokumenten speichern
Arbeiten mit Seiten
Zeichnen
Interaktive Features
Dokument Informationen und Metadaten
Anwendungsbeispiel für die Zend_Pdf Komponente
Zend_ProgressBar
Zend_ProgressBar
Zend_Queue
Einführung
Beispiel der Verwendung
Framework
Adapter
Anpassen von Zend_Queue
Stomp
Zend_Reflection
Einführung
Zend_Reflection Beispiele
Zend_Reflection Referenz
Zend_Registry
Die Registry verwenden
Zend_Rest
Einführung
Zend_Rest_Client
Zend_Rest_Server
Zend_Search_Lucene
Überblick
Indexerstellung
Einen Index durchsuchen
Abfragesprache
Abfrage Erzeugungs API
Zeichensätze
Erweiterbarkeit
Zusammenarbeit Mit Java Lucene
Erweitert
Die besten Anwendungen
Zend_Serializer
Einführung
Zend_Serializer_Adapter
Zend_Server
Einführung
Zend_Server_Reflection
Zend_Service
Einführung
Zend_Service_Akismet
Zend_Service_Amazon
Zend_Service_Amazon_Ec2
Zend_Service_Amazon_Ec2: Instanzen
Zend_Service_Amazon_Ec2: Windows Instanzen
Zend_Service_Amazon_Ec2: Reservierte Instanzen
Zend_Service_Amazon_Ec2: CloudWatch Monitoring
Zend_Service_Amazon_Ec2: Amazon Maschinen Images (AMI)
Zend_Service_Amazon_Ec2: Elastischer Block Speicher (EBS)
Zend_Service_Amazon_Ec2: Elastische IP Adressen
Zend_Service_Amazon_Ec2: Schlüsselpaare
Zend_Service_Amazon_Ec2: Regionen und Availability Zones
Zend_Service_Amazon_Ec2: Sicherheitsgruppen
Zend_Service_Amazon_S3
Zend_Service_Amazon_Sqs
Zend_Service_Audioscrobbler
Zend_Service_Delicious
Zend_Service_DeveloperGarden
Zend_Service_Flickr
Zend_Service_LiveDocx
Zend_Service_Nirvanix
Zend_Service_ReCaptcha
Zend_Service_Simpy
Zend_Service_SlideShare
Zend_Service_StrikeIron
Zend_Service_StrikeIron: Mitgelieferte Services
Zend_Service_StrikeIron: Erweiterte Verwendung
Zend_Service_Technorati
Zend_Service_Twitter
Zend_Service_WindowsAzure
Zend_Service_Yahoo
Zend_Session
Einführung
Grundsätzliche Verwendung
Fortgeschrittene Benutzung
Globales Session Management
Zend_Session_SaveHandler_DbTable
Zend_Soap
Zend_Soap_Server
Zend_Soap_Client
WSDL Zugriffsmethoden
AutoDiscovery
Zend_Tag
Einführung
Zend_Tag_Cloud
Zend_Test
Einführung
Zend_Test_PHPUnit
Zend_Test_PHPUnit_Db
Zend_Text
Zend_Text_Figlet
Zend_Text_Table
Zend_TimeSync
Einführung
Arbeiten mit Zend_TimeSync
Zend_Tool
Verwendung von Zend_Tool auf der Kommandozeile
Zend_Tool erweitern
Zend_Tool_Framework
Einführung
Verwenden des CLI Tools
Architektur
Erstellen von Providern für die Verwendung mit Zend_Tool_Framework
Mitgelieferte System Provider
Extending and Configuring Zend_Tool_Framework
Zend_Tool_Project
Einführung
Ein Projekt erstellen
Project Provider für Zend_Tool
Zend_Tool_Project Internas
Zend_Translate
Einführung
Adapter für Zend_Translate
Verwendung der Übersetzungsadapter
Erstellen von Quelldateien
Zusätzliche Features für Übersetzungen
Schreibweisen von Pluralformen für Übersetzungen
Zend_Uri
Zend_Uri
Zend_Validate
Einführung
Standard Prüfklassen
Kettenprüfungen
Schreiben von Prüfern
Prüfungsmeldungen
Zend_Version
Die Version des Zend Frameworks erhalten
Zend_View
Einführung
Controller Skripte
View Scripte
View Helfer
Zend_View_Abstract
Zend_Wildfire
Zend_Wildfire
Zend_XmlRpc
Einführung
Zend_XmlRpc_Client
Zend_XmlRpc_Server
ZendX_Console_Process_Unix
ZendX_Console_Process_Unix
ZendX_JQuery
Introduction
ZendX_JQuery View Helpers
ZendX_JQuery Form Elements and Decorators
Zend Framework Voraussetzungen
Einführung
Zend Framework's Migrationshinweise
Zend Framework 1.10
Zend Framework 1.9
Zend Framework 1.8
Zend Framework 1.7
Zend Framework 1.6
Zend Framework 1.5
Zend Framework 1.0
Zend Framework 0.9
Zend Framework 0.8
Zend Framework 0.6
Zend Framework Coding Standard für PHP
Übersicht
PHP Dateiformatierung
Namens Konventionen
Code Stil
Zend Framework Dokumentations Standard
Übersicht
Formatierung von Dokumentationsdateien
Empfehlungen
Vorgeschlagene Struktur für die Projekt Struktur von Zend Framework MVC Anwendungen
Übersicht
Vorgeschlagene Verzeichnis Struktur für Projekte
Modul Struktur
Leitfaden für die Rewrite Konfiguration
Zend Framework's Performanceratgeber
Einführung
Laden von Klassen
Zend_Db Performance
Internationalisierung (I18n) und Lokalisierung (L10n)
Darstellen der View
Urheberrecht Informationen