<?php

use Centrifugo\Centrifugo;

$endpoint = "http://example.com/api/";
$secret = "secret api key";

$centrifugo = new Centrifugo($endpoint, $secret, [
    "redis" => [
        "host"         => "localhost",
        // additional params
        "port"         => 6379
        "db"           => 0,
        "timeout"      => 0.0,
        "shardsNumber" => 0,
    ],
    "http" => [
        // Curl options
        CURLOPT_TIMEOUT => 5
    ]
]);

<?php

use Centrifugo\Centrifugo;
use Centrifugo\Exceptions\CentrifugoException;

$userId = 1;
$channle = "#chan_1"
$messageData = ["message" => "Hello, world!"];

try {
    //Send message into channel.
    $response = $centrifugo->publish($channle, $messageData);
    
    //Very similar to publish but allows to send the same data into many channels.
    $response = $centrifugo->broadcast($channle, $messageData);
    
    //Unsubscribe user from channel.
    $response = $centrifugo->unsubscribe($channle, $userId);
    
    //Disconnect user by user ID.
    $response = $centrifugo->disconnect($userId);
    
    //Get channel presence information (all clients currently subscribed on this channel).
    $response = $centrifugo->presence($channle);
    
    //Get channel history information (list of last messages sent into channel).
    $response = $centrifugo->history($channle);
    
    //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
}

<?php

use Centrifugo\Centrifugo;
use Centrifugo\Exceptions\CentrifugoException;

$userId = "1"; //must be a string
$channle = "#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
}