andreybolonin/ratchet-multi-instance

Ratchet multi instance

QuickStart

0) Check, do you install high perfomance ext-event extension (libevent)

http://socketo.me/docs/deploy#evented-io-extensions, _(*1)

https://github.com/reactphp/event-loop#exteventloop, _(*2)

https://bitbucket.org/osmanov/pecl-event/src/530d542a9e828ad23063a483164e6ff15aee157b/INSTALL.md?fileviewer=file-view-default, _(*3)

https://www.pigo.idv.tw/archives/589, _(*4)

1) Define your pool (config/services.yaml)

wampserver_broadcast: ['127.0.0.1:8095', '127.0.0.1:8097', '127.0.0.1:8099'], _(*5)

2) Exclude this node

$key = array_search($this->websocket_this_node, $this->wampserver_broadcast);, _(*6)

unset($this->wampserver_broadcast[$key]);, _(*7)

3) Run your nodes

bin/console server:run --port=8095, _(*8)

bin/console server:run --port=8097, _(*9)

bin/console server:run --port=8099, _(*10)

4) Setup NGINX (as load balancer)

upstream socket {
    server 127.0.0.1:8095;
    server 127.0.0.1:8097;
    server 127.0.0.1:8099;
}

map $http_upgrade $connection_upgrade {
    default upgrade;
    ''      close;
}

server {
    server_name 127.0.0.1;
    listen 8090;

    proxy_next_upstream error;
    proxy_set_header X-Real-IP $remote_addr;
    proxy_set_header X-Scheme $scheme;
    proxy_set_header Host $http_host;

    location / {
        proxy_pass http://socket;
                proxy_http_version 1.1;
                proxy_set_header Upgrade $http_upgrade;
                proxy_set_header Connection "upgrade";
                proxy_set_header Host $host;

                proxy_set_header X-Real-IP $remote_addr;
                proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
                proxy_set_header X-Forwarded-Proto https;
                proxy_read_timeout 86400; # neccessary to avoid websocket timeout disconnect
                proxy_redirect off;
    }
}

http://nginx.org/en/docs/http/load_balancing.html http://nginx.org/en/docs/http/websocket.html, _(*11)

Installation

1) composer req andreybolonin/ratchet-multi-instance, _(*12)

2) Inject use RatchetMultiInstanceTrait; into your Topic class, _(*13)

3) Add broadcast/channel into you Topic class, _(*14)

public function onPublish(ConnectionInterface $connection, $topic, $event, array $exclude, array $eligible)
{
    switch ($topic->getId()) {
     case 'counter/channel':
         $this->CounterTopic($connection, $topic, $event, $exclude, $eligible);
         break;

     case 'price/channel':
         $this->PriceTopic($connection, $topic, $event, $exclude, $eligible);
         break;

     case 'broadcast/channel':
         $this->BroadcastTopic($connection, $topic, $event, $exclude, $eligible);
         break;
    }
}

4) Send the $topic->broadcast($event) with $this->broadcast($event) for broadcasting in another WampServer nodes, _(*15)

Arch

, _(*16)

5) Symfony Bundle

https://github.com/andreybolonin/RatchetBundle, _(*17)