t4web/websocket

ZF2 Module. Websocket server

Maintainers

Details

github.com/t4web/Websocket

Homepage

Source

Issues

Installs: 22

Dependents: 0

Suggesters: 0

Security: 0

Stars: 0

Watchers: 4

Forks: 1

Open Issues: 0

dev-master 2016-07-26 10:43 UTC

Requires

Requires (Dev)

BSD-3-Clause 785bcb84170ffb1b5295b3a721439dfc46795f69

websocketzf2modulezf2 module

This package is auto-updated.

Last update: 2024-11-26 18:23:21 UTC

README

ZF2 Module. Websocket server build on Ratchet

Instalation

Just require t4web/websocket and add to your application.config.php T4web\Websocket.

Run

In console run

$ php public/index.php websocket start

Configuration

Add in your global.config.php :

't4web-websocket' => [
    'server' => [
        // required
        'port' => 8088,

        // not required, default 0
        'debug-enable' => 1,
    ],
];

Quick usage

For testing create html (or copy from https://github.com/t4web/Websocket/blob/master/ws-test.html):

<html lang="en">
    <body>
        <input type="text" id="input" placeholder="Message…" />
        <hr />
        <pre id="output"></pre>

        <script>
            var host   = 'ws://127.0.0.1:8088';
            var socket = null;
            var input  = document.getElementById('input');
            var output = document.getElementById('output');
            var print  = function (message) {
                var samp       = document.createElement('samp');
                samp.innerHTML = message + '\n';
                output.appendChild(samp);
                return;
            };

            input.addEventListener('keyup', function (evt) {
                if (13 !== evt.keyCode) {
                    return;
                }

                var msg = {
                    'event' : 'ping',
                    'data': {message: input.value}
                };

                if (!msg) {
                    return;
                }

                try {
                    print('Send: ' + JSON.stringify(msg, null, 4));
                    socket.send(JSON.stringify(msg));
                    input.value = '';
                    input.focus();
                } catch (e) {
                    console.log(e);
                }

                return;
            });

            try {
                socket = new WebSocket(host);
                socket.onopen = function () {
                    print('connection is opened');
                    input.focus();
                    return;
                };
                socket.onmessage = function (msg) {
                    print('Receive: ' + JSON.stringify(JSON.parse(msg.data), null, 4));
                    return;
                };
                socket.onclose = function () {
                    print('connection is closed');
                    return;
                };
            } catch (e) {
                console.log(e);
            }
        </script>
    </body>
</html>

Or from PHP:

/** @var \T4web\Websocket\WebsocketClient $wsClient */
$wsClient = $this->getServiceLocator()->get(\T4web\Websocket\Client::class);
$wsClient->send('ping', ['message' => 'Hello World']);

Proposed architecture

Each websocket request message must be json object:

{
    "event": "event-name",
    "data": { "field": "value" }
}

Websocket response message:

{
    "event": "event-name",
    "data": { "field": "value" },
    "error": "string|null"
}

Each websocket request mesage - you can handle. Just describe own handlers in t4web-websocket[event-handlers] module.config.php:

't4web-websocket' => [
    'event-handlers' => [
        // event name => handler - Callable object
        'ping' => Handler\Ping::class,
    ],
],

Handler\Ping :

use SplObjectStorage;
use Ratchet\ConnectionInterface;

class Ping implements T4web\Websocket\Handler\HandlerInterface
{
    public function handle($eventName, array $data, ConnectionInterface $connection, SplObjectStorage $connections)
    {
        $response = [
            'event' => 'pong',
            'data' => $data,
            'error' => null,
        ];
        $connection->send(json_encode($response));
    }
}