websocket chatroom stress test

2012-10-22 16:01:02 -07:00 · 2012-10-22 16:01:02 -07:00 · 6b529f81c7
--- a/test/functional/node_modules/faye-websocket/CHANGELOG.txt
+++ b/test/functional/node_modules/faye-websocket/CHANGELOG.txt
--- a/test/functional/node_modules/faye-websocket/README.markdown
+++ b/test/functional/node_modules/faye-websocket/README.markdown
--- a/test/functional/node_modules/faye-websocket/examples/autobahn_client.js
+++ b/test/functional/node_modules/faye-websocket/examples/autobahn_client.js
--- a/test/functional/node_modules/faye-websocket/examples/client.js
+++ b/test/functional/node_modules/faye-websocket/examples/client.js
--- a/test/functional/node_modules/faye-websocket/examples/haproxy.conf
+++ b/test/functional/node_modules/faye-websocket/examples/haproxy.conf
--- a/test/functional/node_modules/faye-websocket/examples/server.js
+++ b/test/functional/node_modules/faye-websocket/examples/server.js
--- a/test/functional/node_modules/faye-websocket/examples/sse.html
+++ b/test/functional/node_modules/faye-websocket/examples/sse.html
--- a/test/functional/node_modules/faye-websocket/examples/ws.html
+++ b/test/functional/node_modules/faye-websocket/examples/ws.html
--- a/test/functional/node_modules/faye-websocket/lib/faye/eventsource.js
+++ b/test/functional/node_modules/faye-websocket/lib/faye/eventsource.js
--- a/test/functional/node_modules/faye-websocket/lib/faye/websocket.js
+++ b/test/functional/node_modules/faye-websocket/lib/faye/websocket.js
--- a/test/functional/node_modules/faye-websocket/lib/faye/websocket/api.js
+++ b/test/functional/node_modules/faye-websocket/lib/faye/websocket/api.js
--- a/test/functional/node_modules/faye-websocket/lib/faye/websocket/api/event.js
+++ b/test/functional/node_modules/faye-websocket/lib/faye/websocket/api/event.js
--- a/test/functional/node_modules/faye-websocket/lib/faye/websocket/api/event_target.js
+++ b/test/functional/node_modules/faye-websocket/lib/faye/websocket/api/event_target.js
--- a/test/functional/node_modules/faye-websocket/lib/faye/websocket/client.js
+++ b/test/functional/node_modules/faye-websocket/lib/faye/websocket/client.js
--- a/test/functional/node_modules/faye-websocket/lib/faye/websocket/draft75_parser.js
+++ b/test/functional/node_modules/faye-websocket/lib/faye/websocket/draft75_parser.js
--- a/test/functional/node_modules/faye-websocket/lib/faye/websocket/draft76_parser.js
+++ b/test/functional/node_modules/faye-websocket/lib/faye/websocket/draft76_parser.js
--- a/test/functional/node_modules/faye-websocket/lib/faye/websocket/hybi_parser.js
+++ b/test/functional/node_modules/faye-websocket/lib/faye/websocket/hybi_parser.js
--- a/test/functional/node_modules/faye-websocket/lib/faye/websocket/hybi_parser/handshake.js
+++ b/test/functional/node_modules/faye-websocket/lib/faye/websocket/hybi_parser/handshake.js
--- a/test/functional/node_modules/faye-websocket/lib/faye/websocket/hybi_parser/stream_reader.js
+++ b/test/functional/node_modules/faye-websocket/lib/faye/websocket/hybi_parser/stream_reader.js
--- a/test/functional/node_modules/faye-websocket/package.json
+++ b/test/functional/node_modules/faye-websocket/package.json
--- a/test/functional/node_modules/faye-websocket/spec/faye/websocket/client_spec.js
+++ b/test/functional/node_modules/faye-websocket/spec/faye/websocket/client_spec.js
--- a/test/functional/node_modules/faye-websocket/spec/faye/websocket/draft75parser_spec.js
+++ b/test/functional/node_modules/faye-websocket/spec/faye/websocket/draft75parser_spec.js
--- a/test/functional/node_modules/faye-websocket/spec/faye/websocket/draft76parser_spec.js
+++ b/test/functional/node_modules/faye-websocket/spec/faye/websocket/draft76parser_spec.js
--- a/test/functional/node_modules/faye-websocket/spec/faye/websocket/hybi_parser_spec.js
+++ b/test/functional/node_modules/faye-websocket/spec/faye/websocket/hybi_parser_spec.js
--- a/test/functional/node_modules/faye-websocket/spec/runner.js
+++ b/test/functional/node_modules/faye-websocket/spec/runner.js
--- a/test/functional/node_modules/faye-websocket/spec/server.crt
+++ b/test/functional/node_modules/faye-websocket/spec/server.crt
--- a/test/functional/node_modules/faye-websocket/spec/server.key
+++ b/test/functional/node_modules/faye-websocket/spec/server.key
--- a/test/stress/130_websocket_chat/index.html
+++ b/test/stress/130_websocket_chat/index.html
@ -0,0 +1,125 @@
+<html>
+<head>
+    <title>130_websocket_chat</title>
+    <script src="http://code.jquery.com/jquery-latest.js"></script>
+</head>
+<body>
+    <h1>130_websocket_chat</h1>
+    <table>
+        <tr>
+            <td>Running time:</td>
+            <td id="time">&nbsp;</td>
+        </tr>
+        <tr>
+            <td>Messages sent:</td>
+            <td id="sent">&nbsp;</td>
+        </tr>
+        <tr>
+            <td>Messages received:</td>
+            <td id="received">&nbsp;</td>
+        </tr>
+        <tr>
+            <td>Websockets created:</td>
+            <td id="wscount">&nbsp;</td>
+        </tr>
+        <tr>
+            <td>Websocket errors:</td>
+            <td id="errors">&nbsp;</td>
+        </tr>
+        <tr>
+            <td>Distinct node.exe PIDs:</td>
+            <td id="pids">&nbsp;</td>
+        </tr>
+        <tr>
+            <td>Last RSS of node.exe:</td>
+            <td id="rss">&nbsp;</td>
+        </tr>
+        <tr>
+            <td>Last heap total of node.exe:</td>
+            <td id="heaptotal">&nbsp;</td>
+        </tr>
+        <tr>
+            <td>Last heap used of node.exe:</td>
+            <td id="heapused">&nbsp;</td>
+        </tr>
+    </table>
+    <script>
+        var start = new Date().getTime();
+        var protocol = window.location.protocol === 'http:' ? 'ws://' : 'wss://';
+        var address = protocol + window.location.host + window.location.pathname + '/server.js';
+        var errors = 0;
+        var wscount = 0;
+        var sent = 0;
+        var received = 0;
+        var lastPID = -1;
+        var pids = 0;
+        var sendFrequency = 200;
+        var maxErrors = 100;
+        var maxWebSockets = 50;
+
+        function openSocket() {
+            var socket = new WebSocket(address);
+            wscount++;
+            $('#wscount').html(wscount);
+            if (wscount > maxWebSockets) {
+                clearInterval(elapsedTime);
+                return;
+            }
+
+            socket.onmessage = function (msg) {
+                var json = JSON.parse(msg.data);
+                received++;
+                $('#received').html(received);
+                if (json.pid != lastPID) {
+                    pids++;
+                    lastPID = json.pid;
+                    $('#pids').html(pids);
+                }                
+                $('#rss').html(json.memory.rss);
+                $('#heaptotal').html(json.memory.heapTotal);
+                $('#heapused').html(json.memory.heapUsed);
+            };
+
+            socket.onerror = function (e) {
+                errors++;
+                $('#errors').html(errors);
+                if (errors > maxErrors) {
+                    clearInterval(sendTimer);
+                    clearInterval(elapsedTime);
+                }
+            };
+
+            socket.onclose = function () {
+                socket = null;
+                openSocket();
+            };
+
+            var sendTimer = setInterval(function () {
+                if (socket) {
+                    socket.send('Check out the Websockets through iisnode!');
+                    sent++;
+                    $('#sent').html(sent);
+                }
+                else {
+                    clearInterval(sendTimer);
+                }
+            }, sendFrequency);
+        }
+
+        var elapsedTime = setInterval(function () {
+            var diff = new Date().getTime() - start;
+            var days = Math.floor(diff / (24 * 3600 * 1000));
+            diff %= (24 * 3600 * 1000);
+            var hours = Math.floor(diff / (3600 * 1000));
+            diff %= (3600 * 1000);
+            var minutes = Math.floor(diff / (60 * 1000));
+            diff %= (60 * 1000);
+            var seconds = Math.floor(diff / 1000);
+            $('#time').html(days + 'd ' + hours + 'h ' + minutes + 'm ' + seconds + 's');
+        }, 1000);
+
+        openSocket();
+
+    </script>
+</body>
+</html>
--- a/test/stress/130_websocket_chat/server.js
+++ b/test/stress/130_websocket_chat/server.js
@ -0,0 +1,44 @@
+
+var WebSocket = require('faye-websocket')
+    , http = require('http');
+
+var server = http.createServer(function (req, res) {
+    res.writeHead(400);
+    res.end();
+});
+
+var clients = {};
+var clientId = 0;
+
+server.addListener('upgrade', function (request, socket, head) {
+    var ws = new WebSocket(request, socket, head);
+    ws.clientId = clientId++;
+    clients[ws.clientId] = ws;
+
+    ws.onmessage = function (event) {
+        var deadClients = [];
+        for (var id in clients) {
+            var ws = clients[id];
+            try {
+                ws.send(JSON.stringify({ 
+                    message: event.data,
+                    pid: process.pid,
+                    memory: process.memoryUsage() 
+                }));
+            }
+            catch (e) {
+                deadClients.push(id);
+            }
+        }
+
+        deadClients.forEach(function (id) {
+            delete clients[id];
+        });
+    };
+
+    ws.onclose = function (event) {
+        delete clients[ws.clientId];
+    };
+});
+
+server.listen(process.env.PORT || 8888);
--- a/test/stress/130_websocket_chat/setup.bat
+++ b/test/stress/130_websocket_chat/setup.bat
@ -0,0 +1 @@
+%systemroot%\system32\inetsrv\appcmd.exe add app /site.name:"Default Web Site" /path:/130_websocket_chat /physicalPath:%~dp0 /applicationPool:DefaultAppPool
--- a/test/stress/130_websocket_chat/web.config
+++ b/test/stress/130_websocket_chat/web.config
@ -0,0 +1,8 @@
+<configuration>
+  <system.webServer>
+    <handlers>
+      <add name="iisnode" path="server.js" verb="*" modules="iisnode" />
+    </handlers>
+    <webSocket enabled="false" />
+  </system.webServer>
+</configuration>
				`@ -0,0 +1 @@`
				`%systemroot%\system32\inetsrv\appcmd.exe add app /site.name:"Default Web Site" /path:/130_websocket_chat /physicalPath:%~dp0 /applicationPool:DefaultAppPool`