[SockJS单个客户端中的多个连接

Question

我正在尝试从单个客户端连接多个套接字。问题是我的脚本每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();   
        }

    }

Answer 1

场景：每个连接应听2秒，然后移交给下一个连接

目前，您要做的是以2秒的间隔初始化每个连接，然后...当然，所有连接都会或多或少地同时检查传入的数据。因此，您应该在接收事件时有一个例程（如果想要的话）：

// Global part
var socket1;
....
 var socket5;

 // on doc ready run once
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
 }

 // 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 ...
}