接続を開いている間、ブラウザからWebSocketサーバーにユーザーIDを送信します

この質問をする前に、私はSOに関する厳しい質問を読んで最善を尽くしました（タグ付きのラチェットと同様の問題に対処しましたが、役に立ちませんでした。注目されなかった質問もしたので、別の質問を書くために削除しました（うまくいけばより明確に）。

私の最終的な目標は、ラチェットを使用して1対1のプライベートチャットアプリケーションを構築することです。特定のユーザーにメッセージを送信できないことを除いて、すべてが正常に機能しています。

ログインしたすべてのユーザーは、Webサイトの保護された領域にアクセスしながら、WebSocketサーバーに接続します。

$(document).ready(function() { 

    var conn = new WebSocket('ws://localhost:8080');
        conn.onopen = function(e) {
            console.log("Connection established!");

            // Here I need to send the logged in user_id to websocket server
            // and get it in onOpen method so that I can index my array 
            // of connections with user_id instead of
            //$connection->ResourceId, I explain more below

        };

        conn.onmessage = function(e) {
            console.log(e.data);
        };

});

ユーザーがチャットボックスにメッセージを書き込むと、メッセージはAJAXを介してWebサーバーに送信され、ZeroMQを使用してWebsocketにプッシュされます。コントローラ内：

// Persistence of Message(message_id, sender_id, receiver_id, message_text)
                .....

                $context = new \ZMQContext();
                $socket = $context->getSocket(\ZMQ::SOCKET_PUSH, 'my pusher');
                $socket->connect("tcp://localhost:5555");

                $pushData = array(
                       'receiver_id' => $receiver_id,
                       'sender_id'  => $user->getId(),
                       'message'  => $message->getMessageText(),
                    );
                $socket->send(json_encode($pushData));

したがって、最後に、私のWebSocketサーバーは、JSONを使用して受信者のIDがどれであるかを知ることができます。しかし、彼はどのようにしてそのユーザーの接続がどれであるかを知るのでしょうか？つまり、ユーザーIDでインデックス付けされた配列にWebSocket接続を格納する必要があります。

<?php
namespace RealTime;

use Ratchet\MessageComponentInterface;
use Ratchet\ConnectionInterface;
use Ratchet\Wamp\WampServerInterface;

class Pusher implements WampServerInterface, MessageComponentInterface{

    private $clients;

    public function onOpen(ConnectionInterface $conn) {

        $this->clients[$conn->resourceId] = $conn;
        // I need here to get the user_id received from browser while opening connection
    }

    public function onMessageEntry($entry) {
        $entryData = json_decode($entry, true);

        //This is not what I need (It sends to all users in array)
        foreach ($this->clients as $key => $client) {

        $client->send($entryData['message']); 
        }
    }
    public function onMessage(ConnectionInterface $from, $msg) {
        echo $msg; 
    }
}

そして、WebSocketサーバー：

  <?php
        require dirname(__DIR__) . '/vendor/autoload.php';
        use RealTime\Pusher;

        $loop   = React\EventLoop\Factory::create();
        $pusher = new Pusher;

        $context = new React\ZMQ\Context($loop);
        $pull = $context->getSocket(ZMQ::SOCKET_PULL);
        $pull->bind('tcp://127.0.0.1:5555'); 
        $pull->on('message', array($pusher, 'onMessageEntry'));


        $webSock = new React\Socket\Server($loop);
        $webSock->listen(8080, '0.0.0.0'); 
        $webServer = new Ratchet\Server\IoServer(
            new Ratchet\Http\HttpServer(
                new Ratchet\WebSocket\WsServer(
                    new Ratchet\Wamp\WampServer(
                        $pusher
                    )
                )
            ),
            $webSock
        );
        $loop->run();

        ?>

質問：

1. user_id接続を開いているときにクライアント側からログインを送信する方法。クライアントの配列に（$client[user_id]=$connではなく$client[recourceId]=$conn）インデックスを付けることができるように、WebSocketサーバーに値を設定する必要があります。javascript関数を試しましたsendが、送信されたデータをどこで受信するかわかりません（onMessage何も印刷していません）。

2. onMessageメソッドがMessageComponentInterface実装されていても実行されないのはなぜですか（onMessageEntryメソッド+$pull->on('message', array($pusher, 'onMessageEntry'));コード行があるためですか？

ありがとうございました。