Node实现socket通讯

server.js

var net = require("net");
var clientList = [];

var server = net.createServer(function (socket) {

    console.log("a client connectioned...");
    clientList.push(socket);

    socket.write("connection success!");
    socket.on("data", function (data) {
        broadcast(data);
    });

    socket.on("end", function () {
        console.log("a client closed...");
        clientList.splice(clientList.indexOf(socket), 1);
    })
});

function broadcast(data) {
    for (var i = 0; i < clientList.length; i++) {
        clientList[i].write(data);
    }


}

server.listen(2588, "127.0.0.1");

client.js

var net = require("net");
var hostname = process.argv[2];
var port = process.argv[3];

var client = net.connect({host: hostname, port: port}, function () {

    process.stdin.setEncoding("utf8");
    process.stdin.on("readable", function () {
        var chunk = process.stdin.read();
        if (chunk !== null) {
            client.write(chunk);
        }
    });

});

client.on("data", function (data) {
    console.log("data:", data.toString());
});

client.on("end", function () {
    console.log("client close...");
});