DeepQA websocket 并发测试

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);
}
}
上一篇:0428数字口袋精灵app优化


下一篇:jQuery的Promise 这里介绍的很详细