cydrickn / socketio
PHP Websocket Server that is compatible with socket.io
Requires
- php: >=8.1
Requires (Dev)
- openswoole/ide-helper: ^4.11
README
PHP Websocket Server that is compatible with socket.io
So far the function use in this package is almost same with the naming in socket.io
Installation
composer require cydrickn/socketio
Then in your main php code add
require __DIR__ . '/../vendor/autoload.php';
Usage
Initializing your server
To initialize
$server = new \Cydrickn\SocketIO\Server([ 'host' => '0.0.0.0', 'port' => 8000, 'mode' => SWOOLE_PROCESS, 'settings' => [ \Swoole\Constant::OPTION_WORKER_NUM => swoole_cpu_num() * 2, \Swoole\Constant::OPTION_ENABLE_STATIC_HANDLER => true, ] ]); $server->on('Started', function (\Cydrickn\SocketIO\Server $server) { echo 'Websocket is now listening in ' . $server->getHost() . ':' . $server->getPort() . PHP_EOL; }); $server->on('connection', function (\Cydrickn\SocketIO\Socket $socket) { // ... }); $server->start();
Server Options
Server Instance
This is the server \Cydrickn\SocketIO\Server, it also inherited all methods of \Cydrickn\SocketIO\Socket
Events
Basic Emit
To emit, just need to call the \Cydrickn\SocketIO\Socket::emit
$server->on('connection', function (\Cydrickn\SocketIO\Socket $socket) { $socket->emit('hello', 'world'); });
You can also pass as many as you want for the parameters
$socket->emit('hello', 'world', 1, 2, 3, 'more');
There is no need to run json_encode on objects/arrays as it will be done for you.
// BAD $socket->emit('hi', json_encode(['name' => 'Juan'])); // GOOD $socket->emit('hi', ['name' => 'Juan']);
Broadcasting
Broadcast is like just the simple emit, but it will send to all connected client except the current client
$socket->broadcast()->emit('hi', ['name' => 'Juan']);
Sending to all clients
The toAll will emit a message to all connected clients including the current client
$socket->toAll()->emit('hi', ['name' => 'Juan']);
Acknowledgements
Same with the socket io for nodejs, you just need to add a callable as the last argument in the emit
Server
$socket->emit('hi', function () { //... });
Client
socket.on('hi', (callback) => { callback('hello'); });
With Timeout
Assign a timeout to each emit:
// timeout for 5 seconds $socket->timeout(5000)->emit('hi', function (bool $err) { if ($err) { // the other side did not acknowledge the event in the given delay } });
Add callback default arguments value for timeout
// timeout for 5 seconds $socket->timeout(5000, 'Juan')->emit('hi', function (bool $err, string $name) { var_dump($name); // if the other side did not acknowledge the event the $name will be 'Juan' if ($err) { // the other side did not acknowledge the event in the given delay } });
Listening
To listen to any event
$server->on('hello', function (\Cydrickn\SocketIO\Socket $socket, string $world) { // ... }); $server->on('hi', function (\Cydrickn\SocketIO\Socket $socket, array $name) { // ... });
Server Event
This event can't be use for the route Since this event are Swoole Websocket Event All Event with * should not be used
- Request - When you use it for http
- *WorkerStart - You must not replace this event since this is the worker start logic for this package
- *Start - You must not replace this event since this is the start logic for this package
- *Open - You must not replace this event since this is the connection logic for this package
- *Message - You must not replace this event since this is the message logic for this package
- *Close - You must not replace this event since this is the message logic for this package
Rooms
In this package it was already included the rooms
To join to group just call the function join
$socket->join('room1');
To emit a message
$socket->to('room1')->emit('hi', ['name' => 'Juan']);
Emit to multiple room
$socket->to('room1')->to('room2')->emit('hi', ['name' => 'Juan']);
Leaving the room
$socket->leave('room1');
Sending to specific user
In socket.io javascript, the user was automatically created a new room for each client sid.
But currently in this package it will not create a new room for each client.
In this package you just need to specify if its a room or a sid
use Cydrickn\SocketIO\Message\Response; $socket->on('private message', (\Cydrickn\SocketIO\Socket $socket, $anotherSocketId, $msg) => { $socket->($anotherSocketId, Response::TO_TYPE_SID).emit('private message', $socket->sid, $msg); });
Middleware
You can add an middleware for the server
$server->use(function (\Cydrickn\SocketIO\Socket $socket, callable $next) { // ... $next(); });
To not continue the connection you just pass \Error in the $next
$server->use(function (\Cydrickn\SocketIO\Socket $socket, callable $next) { // ... $next(new \Error('Something went wrong')); });
You can also add middleware for handshake event of Swoole Server. Just passed true to the second argument.
Also in callback it will pass the response for you to modify if you need it
$server->use(function (\Cydrickn\SocketIO\Socket $socket, \Swoole\Http\Response $response, callable $next) { // ... }, true);
If you want to create a middleware as a class we recommend to implement the Cydrickn\SocketIO\Middleware\MiddlewareInterface
and if for handshake use Cydrickn\SocketIO\Middleware\HandshakeMiddlewareInterface
Example of middleware that use in handshake is the Cydrickn\SocketIO\Middleware\CookieSessionMiddleware. This middleware will create a session that uses the cookie and if the client did not send the session cookie then it will create a cookie and response it from the handshake.
Session
In this package the there is already session storage that you can use,
- SessionsTable - Uses the Swoole\Table as the storage
- SessionsNative - Uses the file storage
Using Swoole, session_start, $_SESSION should not be use since this function are global it stores the data in the process itself.
The session that provided here does not use this predefined session extensions. Currently, the session is define per connection so you can take the session via.
$socket->getSession();
This getSession can return null if you don't have any middleware that creating the session.
To set a session
$session = $server->getSessionStorage()->get('123456'); // This will automatically created once it does not exists $socket->setSession($session);
You can also customize your session storage, just implement the Cydrickn\SocketIO\Session\SessionStorageInterface
<?php class CustomeStorage implements SessionStorageInterface { // ... }
After creating your storage
You need to pass this in your server constructor
$server = new \Cydrickn\SocketIO\Server([ 'host' => '0.0.0.0', 'port' => 8000, 'mode' => SWOOLE_PROCESS, 'serve_http' => true, 'settings' => [ \Swoole\Constant::OPTION_WORKER_NUM => swoole_cpu_num() * 2, \Swoole\Constant::OPTION_ENABLE_STATIC_HANDLER => true, \Swoole\Constant::OPTION_DOCUMENT_ROOT => dirname(__DIR__).'/examples' ] ], sessionStorage: new CustomeStorage());
Example
TODO
- Leaving room
- Fix disconnection event
- Emit Acknowledgement
- Implement with timeout emit
- Implement Catch all listeners
- Implement once, off, removeAllListeners