Cette bibliothèque contient le client et le serveur WebSocket pour PHP. Remplace textalk/websocket .
Le client et le serveur fournit des méthodes pour la lecture et l'écriture sur WebSocket.
Ce repo remplace le repo textalk/websocket abandonné et est maintenu par Sören Jensen, qui maintient l'original depuis v1.3 .
La façon préférée d'installer est avec compositeur.
composer require phrity/websocket
Le client peut lire et écrire sur un flux WebSocket. Il prend en charge en interne la mise à niveau de mise à niveau et les opérations implicites de fermeture et de ping / pong.
Configurez un client WebSocket pour la stratégie de demande / réponse.
$ client = new WebSocket Client ( " wss://echo.websocket.org/ " );
$ client
// Add standard middlewares
-> addMiddleware ( new WebSocket Middleware CloseHandler ())
-> addMiddleware ( new WebSocket Middleware PingResponder ())
;
// Send a message
$ client -> text ( " Hello WebSocket.org! " );
// Read response (this is blocking)
$ message = $ client -> receive ();
echo " Got message: { $ message -> getContent ()} n" ;
// Close connection
$ client -> close ();Configurez un client WebSocket pour un abonnement continu
$ client = new WebSocket Client ( " wss://echo.websocket.org/ " );
$ client
// Add standard middlewares
-> addMiddleware ( new WebSocket Middleware CloseHandler ())
-> addMiddleware ( new WebSocket Middleware PingResponder ())
// Listen to incoming Text messages
-> onText ( function ( WebSocket Client $ client , WebSocket Connection $ connection , WebSocket Message Message $ message ) {
// Act on incoming message
echo " Got message: { $ message -> getContent ()} n" ;
// Possibly respond to server
$ client -> text ( " I got your your message " );
})
-> start ();Le serveur est une connexion multi-connexion, le serveur d'écoute. Il prend en charge en interne la mise à niveau de mise à niveau et les opérations implicites de fermeture et de ping / pong.
Configurez un serveur WebSocket pour une écoute continue
$ server = new WebSocket Server ();
$ server
// Add standard middlewares
-> addMiddleware ( new WebSocket Middleware CloseHandler ())
-> addMiddleware ( new WebSocket Middleware PingResponder ())
// Listen to incoming Text messages
-> onText ( function ( WebSocket Server $ server , WebSocket Connection $ connection , WebSocket Message Message $ message ) {
// Act on incoming message
echo " Got message: { $ message -> getContent ()} n" ;
// Possibly respond to client
$ connection -> text ( " I got your your message " );
})
-> start ();Licence ISC