First commit

practicalnode-master/.gitignore

@@ -0,0 +1,2 @@
+.DS_Store
+*.zip

practicalnode-master/ch1/hello-debug.js

@@ -0,0 +1,8 @@
+var http = require('http');
+debugger;
+http.createServer(function (req, res) {
+  res.writeHead(200, {'Content-Type': 'text/plain'});
+  debugger;
+  res.end('Hello World\n');
+}).listen(1337, '127.0.0.1');
+console.log('Server running at http://127.0.0.1:1337/');

practicalnode-master/ch1/hello.js

@@ -0,0 +1,6 @@
+var http = require('http');
+http.createServer(function (req, res) {
+  res.writeHead(200, {'Content-Type': 'text/plain'});
+  res.end('Hello World\n');
+}).listen(1337, '127.0.0.1');
+console.log('Server running at http://127.0.0.1:1337/');

practicalnode-master/ch10/cluster.js

@@ -0,0 +1,24 @@
+var cluster = require('cluster');
+var numCPUs = require('os').cpus().length;
+var express = require('express');
+
+if (cluster.isMaster) {
+  console.log (' Fork %s worker(s) from master', numCPUs);
+  for (var i = 0; i < numCPUs; i++) {
+    cluster.fork();
+  }
+  cluster.on('online', function(worker) {
+    console.log ('worker is running on %s pid', worker.process.pid);
+  });
+  cluster.on('exit', function(worker, code, signal) {
+    console.log('worker with %s is closed', worker.process.pid );
+  });
+} else if (cluster.isWorker) {
+  var port = 3000;
+  console.log('worker (%s) is now listening to http://localhost:%s', cluster.worker.process.pid, port);
+  var app = express();
+  app.get('*', function(req, res) {
+    res.send(200, 'cluser ' + cluster.worker.process.pid + ' responded \n');
+  });
+  app.listen(port);
+}

practicalnode-master/ch10/domains/app.js

@@ -0,0 +1,43 @@
+var express = require('express');
+var routes = require('./routes');
+var http = require('http');
+var path = require('path');
+var errorHandler = require('errorhandler');
+
+var app = express();
+
+app.set('port', process.env.PORT || 3000);
+app.set('views', __dirname + '/views');
+app.set('view engine', 'jade');
+app.use(express.static(path.join(__dirname, 'public')));
+
+var domain = require('domain');
+var defaultHandler = errorHandler();
+app.get('/', routes.index);
+
+app.get('/e', function (req, res, next) {
+  var d = domain.create();
+  d.on('error', function (error) {
+    console.error(error.stack);
+    res.send(500, {'error': error.message});
+  });
+  d.run(function () {
+    //error prone code goes here
+    throw new Error('Database is down.');
+    // next(new Error('Database is down.'));
+  });
+});
+
+app.use(function (error, req, res, next) {
+  if (domain.active) {
+    console.info('caught with domain', domain.active);
+    domain.active.emit('error', error);
+  } else {
+    console.info('no domain');
+    defaultHandler(error, req, res, next);
+  }
+});
+
+http.createServer(app).listen(app.get('port'), function () {
+  console.log('Express server listening on port ' + app.get('port'));
+});