server.js 464 B

1234567891011121314151617181920212223
  1. 'use strict';
  2. var freemem = require('os').freemem;
  3. var codec = require('../codec');
  4. var id = Math.random();
  5. var recv = 0;
  6. var sub = require('redis').createClient()
  7. .on('ready', function() {
  8. this.subscribe('timeline');
  9. })
  10. .on('message', function(channel, message) {
  11. var self = this;
  12. if (message) {
  13. message = codec.decode(message);
  14. ++recv;
  15. }
  16. });
  17. setInterval(function() {
  18. console.error('id', id, 'received', recv, 'free', freemem());
  19. }, 2000);