oleh-ozimok / php-centrifugo
PHP client for Centrifugo real-time messaging server
Installs: 473 660
Dependents: 1
Suggesters: 0
Security: 0
Stars: 39
Watchers: 5
Forks: 16
Open Issues: 2
Requires
- php: >=5.4.0
- ext-curl: *
Requires (Dev)
- predis/predis: ^1.1
Suggests
- predis/predis: Enable Predis support
This package is not auto-updated.
Last update: 2024-11-09 19:04:46 UTC
README
PHP client for Centrifugo real-time messaging server
Features
- Support publishing messages via Redis engine API listener (publish, broadcast, unsubscribe, disconnect methods only)
- Support client chain (Redis -> HTTP -> ...) as failover. If Redis down or method not supported by Redis engine API, client try send message via HTTP
- Support batch requests
- Support Predis
Quick Examples
Create Centrifugo client
<?php use Centrifugo\Centrifugo; use Centrifugo\Clients\HttpClient; $centrifugo = new Centrifugo('http://example.com/api/', 'secret api key', new HttpClient());
Create Centrifugo client with Redis API support
<?php use Centrifugo\Centrifugo; use Centrifugo\Clients\RedisClient; use Centrifugo\Clients\HttpClient; use Centrifugo\Clients\Redis\RedisTransport; use Centrifugo\Clients\Redis\PredisTransport; // Create Redis transport $redis = new \Redis(); $redis->connect('localhost'); $redisTransport = new RedisTransport($redis); // Or Predis transport $predis = new Predis\Client(['host' => 'localhost']); $redisTransport = new PredisTransport($predis); // Create Centrifugo RedisClient $centrifugoRedisClient = new RedisClient($redisTransport); $centrifugoRedisClient->setShardsNumber(12); // Add Centrifugo HttpClient as failover $centrifugoHttpClient = new HttpClient(); $centrifugoRedisClient->setFailover($centrifugoHttpClient); $centrifugo = new Centrifugo('http://example.com/api/', 'secret api key', $centrifugoRedisClient);
Send request to Centrifugo
<?php use Centrifugo\Centrifugo; use Centrifugo\Exceptions\CentrifugoException; $userId = 1; $channel = '#chan_1'; $messageData = ['message' => 'Hello, world!']; try { //Send message into channel. $response = $centrifugo->publish($channel, $messageData); //Very similar to publish but allows to send the same data into many channels. $response = $centrifugo->broadcast([$channel], $messageData); //Unsubscribe user from channel. $response = $centrifugo->unsubscribe($channel, $userId); //Disconnect user by user ID. $response = $centrifugo->disconnect($userId); //Get channel presence information (all clients currently subscribed on this channel). $response = $centrifugo->presence($channel); //Get channel history information (list of last messages sent into channel). $response = $centrifugo->history($channel); //Get channels information (list of currently active channels). $response = $centrifugo->channels(); //Get stats information about running server nodes. $response = $centrifugo->stats(); //Get information about single Centrifugo node. $response = $centrifugo->node('http://node1.example.com/api/'); } catch (CentrifugoException $e) { // invalid response }
Send batch request
<?php use Centrifugo\Centrifugo; use Centrifugo\Exceptions\CentrifugoException; $userId = '1'; //must be a string $channel = '#chan_1'; $messageData = ['message' => 'Hello, world!']; try { $requests[] = $centrifugo->request('publish', ['channel' => $channel, 'data' => $messageData]); $requests[] = $centrifugo->request('broadcast', ['channel' => $channel, 'data' => $messageData]); $requests[] = $centrifugo->request('unsubscribe', ['channel' => $channel, 'user' => $userId]); $requests[] = $centrifugo->request('disconnect', ['user' => $userId]); $batchResponse = $centrifugo->sendBatchRequest($requests); foreach ($batchResponse as $response) { if ($response->isError()) { // get error info $error = $response->getError(); } else { // get response data as array $responseData = $response->getDecodedBody(); } } } catch (CentrifugoException $e) { // invalid response }
Related Projects
centrifugo-bundle (under development)