Как закрыть старое соединение в WebSocket()?

Question

[Galdar Turin]

Получается так, что по сокету используя Workerman создается websocket сокет, который отслеживает входящие переменные в tcp-server, после чего обрабатывает их передает по 'ws://192.168.2.163:1000/?user='+id на определённый id. Так вот, есть кнопки их может быть любое количество, есть отслеживание нажатия, при нажатии на кнопку 1 - id меняется на 1, при нажатии на 2 - id меняется на 2 и т.д., при кажном нажатии открывается соединение по новому адресу ws://192.168.2.163:1000/?user=1 > ws://192.168.2.163:1000/?user=2 и т.д. по каждому соединению передается текст, но вот есть трабл, если 1 было открыто после этого было открыто соединение 2, то передается текст сразу с двух соединений. Так вот, не могу сообразить, как при кажном новом нажатии на кнопку с id старые соединения закрывались. Пробовал через ws.close(); но что-то не то делаю(

spoiler

var id = data['id'],
                            url = 'ws://192.168.2.163:1000/?user='+id, 
                            ws = new WebSocket(url);
                        ws.addEventListener('message', (event) => {
                            console.log(event.data);
                        });

Answer 1

[Robur]

ws.close() должен сработать. видимо действительно что-то не то делаете.
Возможно надо подождать пока на самом деле закроется. Но вообще вопрос почему у вас текст сразу в оба соединения отправляется - так не должно быть даже если вы старый сокет вообще не закрываете.

Comments

[Galdar Turin]

Robur, если не сложно, можно попросить посмотреть вот эти файлы и дать ответ в чем может быть ошибка

socket.php

<?php
require_once __DIR__ . '/vendor/autoload.php';
use Workerman\Worker;
use Workerman\Connection\AsyncTcpConnection;
// create a ws-server. all your users will connect to it
$ws_worker = new Worker("websocket://192.168.2.163:1000");
$ws_worker->count = 4;// it will create 4 process
// storage of user-connection link
$users = [];
$ws_worker->onConnect = function($connection) use (&$users)
{
    $connection->onWebSocketConnect = function($connection) use (&$users)
    {
        // поместите get-параметр в коллекцию $users при подключении нового пользователя
        // на странице сайта можно задать любой параметр. например client.html: ws = new WebSocket("ws://127.0.0.1:8000/?user=tester01");
        $users[$_GET['user']] = $connection;
        // or you can use another parameter for user identification, for example $_COOKIE['PHPSESSID']
    };
};
$ws_worker->onClose = function($connection) use(&$users)
{
    if(isset($users[$connection->uid]))
    {
        // unset parameter when user is disconnected
        unset($users[$connection->uid]);
    }
};
// it will start once for each of the 4 ws-servers when you start server.php:
$ws_worker->onWorkerStart = function() use (&$users)
{
    //each ws-server connects to the local tcp-server
    $connection = new AsyncTcpConnection("tcp://127.0.0.1:1005");
    $connection->onMessage = function($connection, $data) use (&$users) {
        // you have to use json_decode for $data because send.php uses json_encode
        $data = json_decode($data); // but you can use another protocol for send data send.php to local tcp-server
        // отправить сообщение пользователю по Имя пользователя
        if (isset($users[$data->user])) {
            $webconnection = $users[$data->user];
            $webconnection->send($data->message);
        }
    };
    $connection->connect();
};
// создайте локальный tcp-сервер. он будет получать сообщения с вашего кода сайта (например, от send.РНР)
$tcp_worker = new Worker("tcp://127.0.0.1:1005");
// создайте обработчик, который будет вызываться, когда локальный tcp-сокет получает сообщение (например, от send.РНР)
$tcp_worker->onMessage = function($connection, $data) use ($tcp_worker)
{
    // переадресация сообщения на все остальные процессы (у вас есть 4 ws-сервера)
    foreach ($tcp_worker->connections as $id => $webconnection) {
        if ($connection->id != $id) {
            $webconnection->send($data);
        }
    }
};
// Run worker
Worker::runAll();

send.php

<?php
$localsocket = 'tcp://127.0.0.1:1005';
$user = $_POST['id'];
$message = $_POST['text'];

// соединяемся с локальным tcp-сервером
$instance = stream_socket_client($localsocket);
// отправляем сообщение
fwrite($instance, json_encode([
    user => $user, 
    message => $message
]));

chat-manager.js

function choiceNotific(){
        $("a.notif-list").on("click", function(){
            var id = $(this).attr("id");
            // Вывод существующих сообщений
                $.ajax({
                    type: 'POST',
                    url: 'chat-manager.php',
                    data:{
                        idNotific: id,
                        key: 2
                    },
                    success:function(response){
                        data = JSON.parse(response);
                        $('#messages').html(data['m']);

                        var idClient = data['idClient'],
                            url = 'ws://192.168.2.163:1000/?user='+idClient, 
                            ws = new WebSocket(url); // Подключение к серверу

                        // Работа с Веб сокетом 
                        ws.addEventListener('message', (event) => {
                            console.log(event.data);
                        });
                    }
                });
}

chat-client.js

function webSocket(){
        var text = $('#text-client').val(),
            id = getCookie('idClient');
        $.ajax({
            type: 'POST',
            url: 'send.php',
            data:{
                id: id,
                text: text
            }
        });
    }

[Robur]

Я не вижу где вы там закрываете сокет на клиенте. В том коде что вы привели - вы на каждую кнопку открываете новое соединение, оставляя старое работать. Если сервер что-то пошлет в оба сокета - получите два сообщения.
PHP я забыл лет 10 назад так что по нему ничего не скажу.