nodejs_unix_socket.js

var net   = require("net");
var fs    = require("fs");
 
// server
var port = "/tmp/stream";
 
var sockets = [];
var server = net.createServer(function(socket) {
  sockets.push(socket);
  
  socket.on("close", function() {
    sockets.splice(sockets.indexOf(socket), 1);
  });
});

fs.stat(port, function(err, stats) {
  // prevent EADDRINUSE error
  if (!err) {
    fs.unlinkSync(port);
  }

  server.listen(port);
});
 
// server:broadcast
sockets.forEach(function(socket) {
  var buffer = new Buffer("broadcast message", "utf-8");
  socket.write(buffer);
});
 
// client
var client = net.connect("/tmp/stream");
client.on("data", function(data) {
  console.log(data.toString("utf-8"));
});