signaling-server/node_modules/socket.io/node_modules/redis/benches/stress/pubsub/server.js


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

'use strict';

var freemem = require('os').freemem;
var codec = require('../codec');

var id = Math.random();
var recv = 0;

var sub = require('redis').createClient()
	.on('ready', function() {
		this.subscribe('timeline');
	})
	.on('message', function(channel, message) {
		var self = this;
		if (message) {
			message = codec.decode(message);
			++recv;
		}
	});

setInterval(function() {
	console.error('id', id, 'received', recv, 'free', freemem());
}, 2000);