php+swoole

<?php
// establish WebSocket Server object , monitor 0.0.0.0:9502 port
$ws = new Swoole\WebSocket\Server('0.0.0.0', 9502);

$redis = new Redis();
$redis->connect('127.0.0.1','6379');
// monitor WebSocket Connection open event
$ws->on('Open', function ($ws, $request) {
    echo $request->fd." Successful connection ";
});

// monitor WebSocket News events
$ws->on('Message', function ($ws, $frame)use($redis) {
    $data = json_decode($frame->data,true);
    switch ($data['type']) {
        case 'open':
            $redis->set($data['my'],$frame->fd);
            break;
        case 'send':
            $to = $redis->get($data['to']);
            $msg = [
                'msg'=>$data['msg']
            ];
            $ws->push($to,json_encode($msg,true));
            break;
        default:
            // code...
            break;
    }
});

// monitor WebSocket Connection close event
$ws->on('Close', function ($ws, $fd) {
    echo "client-{$fd} is closed\n";
});

$ws->start();