PHP and NATS.io Example

nats.php

<?php

require_once 'vendor/autoload.php';

// Yeni bağlantı nesnesi oluşturma ve bağlanma
$client = new \Nats\Connection();
$client->connect();

// Subscriber
$callback = function($payload)
{
    printf("Data: <strong>%s</strong>", $payload);
};
$sid = $client->subscribe("foo", $callback);

// Publisher
$client->publish('foo', 'Erhan Yakut');

// 1 mesaj gelene kadar bekletme
$client->wait(1);
?>