HTTPClient
class HTTPClient extends Client
Der HTTPClient stellt die Verbindung über einen Stream-Socket zum Webserver her und kümmert sich um die Kommunikation.
$httpClient = new \Alvine\Net\Http\HTTPClient(new \Alvine\Net\Resource\URI('http://www.exampe.com/'));
$formdata = new FormData();
$formdata->setValue('key', 'value');
$response = $httpClient->post('/post.php', $formdata);
if($response->getHeader()->getStatusCode()->getCode()==200) {
echo (string) $response->getBody();
};
Um die Kommunikation mit dem Server zu überprüfen und Fehler zu suchen, kann der Logger zurHilfe genommen werden.
// Log in Datei schreiben
$handler = new \Alvine\Util\Logging\Handler\File('alvine.log');
// instanz des HTTP-Logger holen
$logger = \Alvine\Util\Logging\Logger::getInstance(\Alvine\Util\Logging\LoggerDefaultName::HTTP);
// Plaintextausgabe
$formatter = new \Alvine\Util\Logging\Formatter\Plain();
// Handler setzen
$logger->addHandler($handler);
$handler->setFormatter($formatter);
// Treshold auf TRACE setzen
$handler->setThreshold(\Alvine\Util\Logging\Level::TRACE);
// Verbindung
$client = new HTTPClient(...);
Traits
Constants
VERSION |
Generelle Alvine-Version |
APIVERSION |
Version der API-Version der Klasse. |
IDENTIFICATION |
Identifizierung der Alvine API |
SERIALVERSION |
Version der Klasse (wird für die Serialisierung verwendet. Ändert sich der interne Aufbau der Klasse, so muss dieser Wert nach oben gesetzt werden. Die Serialisierung muss diesen Wert abfragen und bei Bedarf einen Wrapper für das Arbeiten mit veralteten Objekten implmenetieren. |
NONBLOCKING |
Verhalten der Zugriff ist nicht blockierend (es wird auf Daten gewartet) |
BLOCKING |
Verhalten der Zugriff ist blockierend (es wird auf Daten gewartet) |
FWRITEERROR_STRATEGY_DONOTHING |
Fehler ignorieren. |
FWRITEERROR_STRATEGY_EXCEPTION |
Abbrechen und Exception werfen |
FWRITEERROR_STRATEGY_BREAKQUEUEANDFORWARD |
Die Queue abbrechen, aber im Ablauf fortfahren keine Exception werfen. |
DEFAULTPORT |
Standard HTTP-Port |
DEFAULTSSLPORT |
Standard HTTPS-Port |
Properties
protected boolean | $hasAssociatedProperties | from SerializableImplementation | |
protected boolean | $hasVolatileProperties | from SerializableImplementation | |
protected array | $properties | from Alvine | |
protected string | $hash | Eindeutige ID | from Alvine |
protected string | $protocol | from Socket | |
protected string | $host | from Socket | |
protected int | $port | from Socket | |
protected string | $receiveBuffer | from Socket | |
protected string | $path | Optionaler Pfad um z.B. mehrere Verbindungen zu einem Host:Port aufmachen zu können tcp://mysql.example.com:3306/root Oder um einen Pfad zu einem UNIX-Socket anzugeben unix:///full/path/to/my/socket.sock | from Socket |
protected int | $timeout | from Socket | |
protected int | $connectionMode | from Socket | |
protected State | $state | from Socket | |
protected Resource | $socket | from Socket | |
protected boolean | $logFlag | from Socket | |
protected string | $log | from Socket | |
protected int | $flags | from Socket | |
protected Context | $context | from Socket | |
protected int | $blockSize | from Socket | |
static protected array | $availableTransports | Unterstütze Protokolle | from Socket |
protected URI | $uri | ||
protected Credentials | $credential | ||
protected boolean | $proxy |
Methods
Serialisierung des Objekts und der Daten. In dem serialisierten Objekt werden auch Meta-Informationen zum Abgleich gespeichert.
Prüfen ob das Objekt associative Eigenschaften besitzt
Prüfen ob das Objekt volatile Eigenschaften besitzt
Umgang mit Versionen
Diese Methode wird in der Folge durch \unserialize aufgerufen und initialisert das neue Objekt. Diese Methode sollte so nicht selber aufgerufen werden.
Jede von der Alvine-Klasse abgeleitete Klasse besitzt die Fähigkeit beliebige Werte und Lambda-Funktionen an das Objekt zu hängen.
Wird aufgerufen, wenn isset() auf ein internes Property angewendet wird.
Diese Methode wird inplizit aufgerufen wenn eine nicht definierte Eigenschaft abgefragt wird. Ist die Eigenschaft eine Anonyme-Funktion (Closure), so wird diese Funktion aufgerufen und die Klasse als Parameter übergeben.
Closure über den definierten Namen holen. Ist keine Eigenschaft mit dem Namen definiert, so wird eine BadPropertyException geworfen. Gibt es eine Eigenchaft mit dem Namen, ist diese aber kein Closure, so wird eine NotFoundException geworfen.
Prüfen ob eine Eigenschaft als dynamische Eigenschaft verfügbar ist, die über $obj->property abgefragt werden kann.
Ein Closures das dem Objekt übergeben wurde, kann entweder als Property oder als Funktion aufgerufen werden.
Mit dieser Methode kann geprüft werden, ob eine Methode aufrufbar ist. Das gilt für echte und eingehängte DI-Methoden (Lambda).
Diese Methode gibt eine eindeutige ID des Objektes zurück. Bei der ID handelt es sich um eine Zeichenkette in der Form einer UUID.
Diese Methode entfernt alle Minuszeichen aus der UUID des Hash. Wird eine Länge definiert, so wird nach dem entfernen der Minuszeichen die ersten $length Zeichen zurückgegeben.
Diese Funktion vergleicht zwei Objekte. Dazu wird von beiden der
Wert, der von Alvine::getID()
zurückgeliefert wird ermittelt und das
Ergebnis verglichen. Vererbte Klassen können diese Methode überschreiben.
Diese Methode gibt ein geklontes Objekt von sich selber zurück.
Interne Hook für das Clonen des Objektes. Wenn das zu klonende Objekt bereits eine eindeutige ID hat, dann wird auch für das neue Objekt eine eindeutige ID erstellt.
Prüft ob das übergebene Objekt eine Instanz dieses Objektes ist. Allerdings ist darauf zu achten, das vorher definiert wurde, das das neue Objekt von Alvine abgeleitet wurde.
Neuen HTTP-Client erstellen
Netzwerkverbindung öffnen. Ist bereits eine Verbindung aktiv, so wird diese Verbindung geschlossen und eine neue Verbindung geöffnet.
Diese Methode entfernt einen Beobachter von der Liste der Status-Beobchter.
Prüfen auf Ende der Übertragung
Ermöglicht das überarbeiten der empfangenen Daten, insbesondere bei Clients die ein Long-Polling verwenden.
Gekapselter Funktionsaufruf für socket_get_status
Gekapselter Funktionsaufruf für stream_get_contents
Diese Funktion kann von abgeleiteten Klassen überschrieben werden, um zu entscheiden ob man im Falle eines fwrite-Errors abbricht, fortfährt oder eine Exception wirft.
Absolute URI senden
Protokoll
Port
Ein Request senden
Diese Methode schneidet einen möglichen HTTP/1.1 100 Continue Header aus dem Datenstrom.
Details
in SerializableImplementation at line 122
string
serialize()
Serialisierung des Objekts und der Daten. In dem serialisierten Objekt werden auch Meta-Informationen zum Abgleich gespeichert.
Soll eine abgeleitete Klasse nicht serialisierbar sein, so muss diese Methode überschrieben werden und eine Exception werfen.
Eigenschaften die mit volatile oder associated beginnen werden gesonder behandelt. Eigenschaften mit Prefix volatile werde nicht serialisiert. Bei Eigenschaften mit der Vorsilbe associated wird nur die ID des Objektes serialisiert. Wird in der Eigenschaft kein Objekt gespeichert wird eine TypeException geworfen.
in SerializableImplementation at line 193
bool
hasAssociatedProperties()
Prüfen ob das Objekt associative Eigenschaften besitzt
in SerializableImplementation at line 205
bool
hasVolatileProperties()
Prüfen ob das Objekt volatile Eigenschaften besitzt
in SerializableImplementation at line 228
protected
checkAndAdjustSerialisation(array $serialization)
Umgang mit Versionen
Diese Methode überprüft ein Objekt und repariert im idealfall ältere Kopien. Kann eine alte Kopie nicht wieder hergestellt werden, so wird eine Exeption geworfen.
Diese Methode muss von den abgeleiteten Klassen überschrieben werden. In der abgeleiteten Klasse sollte die Parent-Methode aufgerufen werden.
in SerializableImplementation at line 252
void
unserialize(string $serialized)
Diese Methode wird in der Folge durch \unserialize aufgerufen und initialisert das neue Objekt. Diese Methode sollte so nicht selber aufgerufen werden.
in Alvine at line 177
string
__toString()
Standardumwandlung des Inhalts der Klasse in eine Zeichenkette
echo (string) new MyObect();
in Alvine at line 211
void
__set(string $name, mixed $value)
Jede von der Alvine-Klasse abgeleitete Klasse besitzt die Fähigkeit beliebige Werte und Lambda-Funktionen an das Objekt zu hängen.
Diese Methode wird indirekt aufgerufen, sobald ein Wert oder eine Funktion einem Objekt zugeordnet wird, die nicht definiert wurde.
class MyObject extends Alvine {
}
$obj = new MyObject();
$obj->myValue = 4;
in Alvine at line 222
boolean
__isset(string $name)
Wird aufgerufen, wenn isset() auf ein internes Property angewendet wird.
in Alvine at line 231
__unset(string $name)
Zurücksetzen von Werten
in Alvine at line 256
mixed
__get(string $name)
Diese Methode wird inplizit aufgerufen wenn eine nicht definierte Eigenschaft abgefragt wird. Ist die Eigenschaft eine Anonyme-Funktion (Closure), so wird diese Funktion aufgerufen und die Klasse als Parameter übergeben.
Vor der Abfrage sollte, damit keine Exception geworfen wird, die Existenz der Eigenschaft geprüft werden.
if($obj->propertyExists('myproperty')) {
$value = $obj->myproperty;
}
in Alvine at line 281
Closure
getClosure(string $name)
Closure über den definierten Namen holen. Ist keine Eigenschaft mit dem Namen definiert, so wird eine BadPropertyException geworfen. Gibt es eine Eigenchaft mit dem Namen, ist diese aber kein Closure, so wird eine NotFoundException geworfen.
in Alvine at line 307
boolean
propertyExists(string $name)
Prüfen ob eine Eigenschaft als dynamische Eigenschaft verfügbar ist, die über $obj->property abgefragt werden kann.
if($obj->propertyExists('myproperty')) {
$value = $obj->myproperty;
}
in Alvine at line 339
mixed
__call(string $name, array $arguments)
Ein Closures das dem Objekt übergeben wurde, kann entweder als Property oder als Funktion aufgerufen werden.
Achtung: Wird das Closure in einem Objekt definiert, so ist die Variable $this nicht das Objekt des Closures, sondern des, in dem das Closure definiert wurde.
// als erster Parameter wird immer das Objekt übergeben
$a->myfunction = function($obj, $b) { echo $b.'!'; };
// Aufruf als Eigenschaft ohne Parameter
$a->myfunction; // Ausgabe ist ein !
//
// Aufruf als Methode mit Parametern
$a->myfunction('OK'); // Ausgabe ist OK!
in Alvine at line 362
boolean
isCallable(type $name)
Mit dieser Methode kann geprüft werden, ob eine Methode aufrufbar ist. Das gilt für echte und eingehängte DI-Methoden (Lambda).
if($obj->isCallable('myfunction')) {
$obj->myfunction();
}
in Alvine at line 376
string
getHashCode()
deprecated
deprecated
Die Methode Alvine::getID() verwenden!
in Alvine at line 396
string
getID()
Diese Methode gibt eine eindeutige ID des Objektes zurück. Bei der ID handelt es sich um eine Zeichenkette in der Form einer UUID.
Objekte haben bei der Erstellung noch keine eindeutige ID, erst mit dem expliziten Aufruf der ID wird diese einmalig erstellt und im Objekt gepseichert.
Diese Methode wird implizit beim Serialisieren aufgerufen.
Die UUID ist dabei vom Type4 (Random)
in Alvine at line 416
string
getShortID(int|null $length = null)
Diese Methode entfernt alle Minuszeichen aus der UUID des Hash. Wird eine Länge definiert, so wird nach dem entfernen der Minuszeichen die ersten $length Zeichen zurückgegeben.
Diese Methode ist hilfreich um Platz zu sparen.
Je kürzer die ID ist, um so größer ist die Wahrscheinlichkeit einer Kollision mit anderen Hash vergleichbarer Objekte.
in Alvine at line 442
boolean
equals(Alvine $object)
Diese Funktion vergleicht zwei Objekte. Dazu wird von beiden der
Wert, der von Alvine::getID()
zurückgeliefert wird ermittelt und das
Ergebnis verglichen. Vererbte Klassen können diese Methode überschreiben.
class MyObject extends Alvine {};
$objA = new MyObject();
$objB = new MyObject();
if($objA->equals($objB)) {
// ...
}
in Alvine at line 463
Alvine
getClone(boolean $deepClone = false)
Diese Methode gibt ein geklontes Objekt von sich selber zurück.
Wenn eine abgeleitete Klasse diese Methode nicht unterstützt, so muss diese die Methode überschreiben und eine CloneNotSupportedException werfen. Die Standardmethode klont eine seichte Kopie der Eigenschaften. Das bedeutet das Objekte in den Eigenschaften nicht geclont werden. Sollen diese auch geclont werden muss true übergeben werden.
Wenn weitere Funktionen implementiert werden sollen, so muss __clone überschrieben werden
in Alvine at line 475
__clone()
Interne Hook für das Clonen des Objektes. Wenn das zu klonende Objekt bereits eine eindeutige ID hat, dann wird auch für das neue Objekt eine eindeutige ID erstellt.
Alvine-Objekte werden rekursive geclont, so das ein vollständiger Clone vorhanden ist.
in Alvine at line 493
string
getClass()
Name der Klasse
class MyObject extends Alvine {};
$obj = new MyObject();
echo $obj->getClass();
in Alvine at line 518
boolean
isInstanceOf(object $object)
Prüft ob das übergebene Objekt eine Instanz dieses Objektes ist. Allerdings ist darauf zu achten, das vorher definiert wurde, das das neue Objekt von Alvine abgeleitet wurde.
if($obj instanceof Alvine &&
$obj->isInstanceOf($object)) { };
Die Prüfung entspricht
$this instanceof $object
at line 105
__construct($uri, int $timeout = null)
Neuen HTTP-Client erstellen
in Socket at line 184
__destruct()
Netzwerkverbindung schliessen
in Client at line 68
Socket
connect()
Netzwerkverbindung öffnen. Ist bereits eine Verbindung aktiv, so wird diese Verbindung geschlossen und eine neue Verbindung geöffnet.
in Socket at line 208
integer
getStateCode()
Gibt den aktuellen Status des Objekts zurück
in Socket at line 220
Socket
attachObserver(Observer $observer)
Fügt einen Beobachter zum Status-Objekt hinzu
in Socket at line 233
Socket
detachObserver(Observer $observer)
Diese Methode entfernt einen Beobachter von der Liste der Status-Beobchter.
in Socket at line 279
Client
dispose()
Netzwerkverbindung beenden
Beendet eine Netzwerkverbindung. Wichtiger Hinweis: Die Funktion schreibt den Verlauf der Kommunikation mit dem Level Trace in den networking-Logger. Dabei ist zu beachten, das eine Weiterleitung der Nachrichten nicht mit Logger-Handlern die dies Klasse verwenden (z.B. MailHandler) funktionieren. Optimalerweise wird ein Dateihandler verwendet.
in Socket at line 309
string
getLog()
Gibt die Logdaten, falls Socket::enableLog() aufgerufen wurde, zurück.
at line 431
protected boolean
isReceivedFinished()
Prüfen auf Ende der Übertragung
Prüft, ob die Empfangenen Daten ausreichen und gibt false oder true zurück. Wird true zurückgegeben beendet der Socket das Empfangen der Daten.
in Socket at line 342
string
receive()
Empfang der Daten
$client = new Alvine\Net\Client('mailserver', 25);
$client->connect();
echo $client->receive();
$client->send("QUIT\r\n");
in Socket at line 386
protected Socket
processReceiveBuffer()
Ermöglicht das überarbeiten der empfangenen Daten, insbesondere bei Clients die ein Long-Polling verwenden.
Wichtig: Diese Funktion wird innerhalb der receive-Queue und vor Socket::isReceivedFinished() aufgerufen. Wird Socket::receiveBuffer bearbeitet, so muss unter Umständen Socket::isReceivedFinished() darauf abgestimmt werden.
in Socket at line 430
protected array
getInternalSocketStatus(Resource $socket)
Gekapselter Funktionsaufruf für socket_get_status
Diese Methode kann in den Unit-Tests für das mocking überschrieben werden.
in Socket at line 453
protected string
getInternalSocketContents(resource $handle, integer $maxlength)
Gekapselter Funktionsaufruf für stream_get_contents
Diese Methode kann in den Unit-Tests für das mocking überschrieben werden.
at line 309
protected int
dealWithFwriteError(IOException $e)
Diese Funktion kann von abgeleiteten Klassen überschrieben werden, um zu entscheiden ob man im Falle eines fwrite-Errors abbricht, fortfährt oder eine Exception wirft.
Im Falle von HTTP kann zum Beispiel der Server die Verbinfung abbrechen und die Fehlermldung 413 to large schicken. Diese sollte dann aber eingelesen werden.
In dieser Klasse wird der auftretende Fehler nicht betrachtet und es wird versucht fortzufahren. Ggf muss man in einer abgeleiteten Klasse noch auf die Exception prüfen.
in Socket at line 546
boolean
isConnected()
Status
Ist der Socket verbunden?
in Socket at line 573
Socket
setConnectionMode(integer $mode)
Modus des Sockets
Setzt den Verbindungsmodus entweder auf Socket::NONBLOCKING (nicht blockierend) oder auf Socket::BLOCKING (blockierend)
in Socket at line 586
string
getProtocol()
Protokoll
in Socket at line 595
string
getHost()
Host
in Socket at line 604
integer
getPort()
Port
in Socket at line 613
string
getPath()
Path
in Socket at line 622
integer
getTimeout()
Timeout
at line 635
static static
getInstanceFromURI(URI $uri, integer $timeout = null)
Erstellen einer Sockeresourche über eine URI
// Web-Client
new Client('http://www.example.com:80/path/to/my/api');
in Client at line 108
void
update(Observeable $observeable)
Ist für diese Klasse ohne Funktion
at line 137
HTTPClient
setProxy(string $host, integer $port)
Absolute URI senden
Im Standard wird im Request eine absolute URI in der Requestzeile gesendet. Dies ist insbesondere für Anfragen die über einen Proxy erfolgen notwendig.
at line 150
setURI(URI $uri)
URL setzen
at line 176
protected string
determineProtocol()
Protokoll
Protokoll aus der URL ermitteln
at line 193
protected integer
determinePort()
Port
Port aus der URL oder den Standards ermitteln.
at line 218
protected URI
prepareURI(URI|string $uri)
URI überprüfen
Macht aus einer Zeichenkette ein Objekt und gibt dieses zurück. Wird eine relative URI übergeben, so wird zusammen mit der in der Klasse definierten URI eine absulote URI erstellt.
at line 260
HTTPClient
setCredential(Credentials $credential)
setCredential
Über diese Methoden kann die Authentifizierung des Requests gesetzt werden.
at line 281
protected HTTPClient
convertAndSendRequest(Request $request)
Datenübertragung
Request in Daten umwandeln und senden.
protected function convertAndSendRequest(Request $request) {
// Request bearbeiten
parent::convertAndSendRequest($request);
}
at line 340
Response
sendRequest(string $method, string|URI $uri, RequestHeader $header = null, string|Body $body = null)
Ein Request senden
Ein aus einem Header und Body zusammengesetzten Request senden. Wird als URI ein relativer Pfand angegeben, so wird dieser in Bezug zur Basis URI verwendet.
$httpClient = new \Alvine\Net\Http\HTTPClient(new \Alvine\Net\Resource\URI('http://www.exampe.com/'));
$formdata = new FormData();
$formdata->setValue('key', 'value');
// Relative URI
$response = $httpClient->post('/post.php', $formdata);
// Absolute URI
$response = $httpClient->post('http://www.exampe.com/post.php', $formdata);
Die Aufrufe über HTTPClient::sendRequest() können über den HTTP-Logger mit Level::TRACE nachverfolgt werden. Sie Codebeispiel im Klassenkopf.
at line 392
protected URI
getRequestURI(URI $prepareURI)
URI für den Request und bei Proxies die URI des Proxies
at line 408
protected string
trim100Continue(string $data)
Diese Methode schneidet einen möglichen HTTP/1.1 100 Continue Header aus dem Datenstrom.
at line 495
Response
post(string|URI $uri, FormData $content, string|MIMEType $mimetyp = null)
POST-Request durchführen
Die POST-Methode wurde für die Übertragung von Formulardaten entwickelt. Sie dient dazu Fomulardaten vom Client an den Server zu übermitteln.
at line 526
Response
patch(string|URI $uri, FormData $content, string|MIMEType $mimetyp = null)
PATCH-Request durchführen
Die PATCH-Methode wurde für die Übertragung von Formulardaten entwickelt. Sie dient dazu partiellen Daten vom Client an den Server zu übermitteln.
at line 558
Response
put(string|URI $uri, string $content, string|MIMEType $mimetype = null)
PUT-Abfrage durchführen
Die PUT-Methode ähnelt der POST-Methode. Sie ermöglicht es eine neue Resource auf dem Server anzulegen. Im Gegensatz zur POST-Methode ist der Server nicht angewiesen die übertragene Datei an ein Script zu übergeben, sondern vielmehr die Resource an der benannten Stelle zu plazieren.
Über ein URL-Routing können so aber auch Datensätze in einer Datenbank angelegt werden.