Sock JS несколько соединений в одном клиенте - PullRequest
Новая
       22

Sock JS несколько соединений в одном клиенте

0 голосов
/ 25 марта 2020

Я пытаюсь подключить несколько сокетов от одного клиента. Проблема в том, что мой скрипт инициализирует новое соединение каждые 2 секунды, но (всего 5 соединений) через 10 секунд это соединение пытается соединиться с сокетом все вместе. То, что я хочу:

Инициализация соединения 1 ->
Соединение 1, подключенное к сокету ->
Соединение 1, прослушивающее сообщения ->

Инициализировать Соединение 2 ->
Соединение 2, подключенное к разъему ->
Соединение 2, прослушивающее сообщения ->

Инициализировать Соединение 3 ->
Соединение 3, подключенное к сокет ->
Соединение 3, прослушивание сообщений ->

и т. д. Я хочу, чтобы они подключались по одному. Но я не смог этого сделать. 

    'use strict'

    let stompClient
    class Socket{
        constructor(ip,ith) {  // Constructor
        this.ipAddress = ip;
        this.ith = ith;
        this.connected = false;
      }

    async connect(){
        const connect = (event) => {
        document.getElementById("insideText" + this.ith).innerHTML = "Connecting..";
        const socket = new SockJS('http://'+ this.ipAddress +':8081/server')
        stompClient = Stomp.over(socket)
        stompClient.connect({}, onConnected, onError)
        //event.preventDefault()
    }

    const onConnected = () => {
        stompClient.subscribe('/topic/public', onMessageReceived)
        stompClient.send("/app/chat.newUser",
            {},
            JSON.stringify({sender: "client", type: 'CONNECT'})
        )
    }

    const onError = (error) => {
        document.getElementById("insideText" + this.ith).innerHTML = "Connection failed!";
        document.getElementById("img" + this.ith).src = "Dead.png"
        //const status = document.querySelector('#status')
        //status.innerHTML = 'Could not find the connection you were looking for. Move along. Or, Refresh the page!'
        //status.style.color = 'red'
    }

    const onMessageReceived = (payload) => {
        const message = JSON.parse(payload.body);
        var date = new Date().getTime();
        var number = new Number(message.startTime);
        var difference = date - number;

        if(message.status === "BUSY"){
            document.getElementById("img" + this.ith).src = "Busy.png"
            document.getElementById("insideText" + this.ith).innerHTML = message.crawler + ", " + msToTime(difference);
        }
        if(message.status === "FREE"){
            document.getElementById("img" + this.ith).src = "Free.png"
            document.getElementById("insideText" + this.ith).innerHTML = message.crawler;
        }
    }

        connect();
    }
    }

    function msToTime(duration) {
      var milliseconds = parseInt((duration % 1000) / 100),
        seconds = Math.floor((duration / 1000) % 60),
        minutes = Math.floor((duration / (1000 * 60)) % 60),
        hours = Math.floor((duration / (1000 * 60 * 60)) % 24);

      hours = (hours < 10) ? "0" + hours : hours;
      minutes = (minutes < 10) ? "0" + minutes : minutes;
      seconds = (seconds < 10) ? "0" + seconds : seconds;

      return hours + ":" + minutes + ":" + seconds;
    }

    function sleep(ms) {
      var start = new Date().getTime(), expire = start + ms;
      while (new Date().getTime() < expire) { }
      return;
    }

    for (var i = 1; i < 6; i++) {
sleep(2000)
        if(i === 1){
            var socket = new Socket("10.10.10.43",i);
            socket.connect();
        }else if(i === 2){
            var socket = new Socket("10.10.10.43",i);
            socket.connect();
        }
        else if(i === 3){
            var socket = new Socket("10.10.10.43",i);
            socket.connect();
        }
        else if(i === 4){
            var socket = new Socket("10.10.10.43",i);
            socket.connect();
        }else{
            var socket = new Socket("10.10.10.43",i);
            socket.connect();   
        }

    }

1 Ответ

0 голосов
/ 25 марта 2020

Сценарий: каждое соединение должно прослушивать в течение 2 секунд, а затем передавать следующее

В данный момент вы инициализируете каждое соединение с интервалом в 2 секунды, а затем ...
Затем, конечно, все соединения более или менее одновременно проверяют наличие входящих данных.
Таким образом, у вас должна быть процедура, подобная (если вы этого хотите) при получении события: 

// Global part
socketInit = 0;
var socket1;
....
 var socket5;

 // on doc ready run once
 if(socketInit  == 0){
socketInit = 1;
for (var i = 1; i < 6; i++) {
    var socket = "socket"+i;
    var socket = new Socket("10.10.10.43",i);
    socket.connect();
     sleep(2000);// if you need this here already
    }
 } // end run once

 // on doc ready run contiously
  for (var i = 1; i < 6; i++) {
  socketAction (i);   
  sleep(2000);
   }

// Function to be called
function action(socketNum) {
        var socket = "socket" + socketNum;
        if(socket.data != null) {   //I dont know your lib so replace it with the appropriate data receive event/ indicator
   .... do something ...
}
...