DeepQA websocket 并发测试

Posted 2020-09-20 极客堂

var client = new Array();
var W3CWebSocket = new Array();

var concurrent = 2;
for (var i = 0; i < concurrent; i++) {
    W3CWebSocket[i] = require(‘websocket‘).w3cwebsocket;
    client[i] = new W3CWebSocket[i](‘ws://115.29.199.8:8000/chat‘);
    client[i].onerror = function () {
        console.log(‘Connection Error‘);
    };

    client[i].onopen = function () {
        console.log(‘WebSocket Client Connected‘);
        sendNumber(i);
    };

    client[i].onclose = function () {
        console.log(‘Client Closed‘);
    };

    client[i].onmessage = function (e) {
        if (typeof e.data === ‘string‘) {
            console.log("Received: ‘" + e.data + "‘");
        }
    };

}

function sendNumber(i) {
    console.log("client " + i + " is " + client[i]);
    if (client[i].readyState === client.OPEN) {
        var number = Math.round(Math.random() * 0xFFFFFF);
        client[i].send(‘{"message":"how are you?"}‘);
        setTimeout(sendNumber(i), 1000);
    }
}