var net=require('net');
function getConnection(connName){
var client=net.connect({port:8017,host:'127.0.0.1'},function(){
console.log(connName+' connected: ');
console.log(' local=%s:%s',this.localAddress,this.localPort);
console.log( ' remote=%s:%s',this.remoteAddress,this.remotePort);
this.setTimeout(500);
this.setEncoding('utf8');
this.on('data',function(data){
console.log(connName+' From Server: '+data.toString());
this.end();
});
this.on('end',function(){
console.log(connName+' Client disnected');
});
this.on('error',function(err){
console.log('Socket Error: ',JSON.stringify(err));
});
this.on('timeout',function(){
console.log('Socket Time Out');
});
this.on('close',function(){
console.log('Socket Closed');
});
});
return client;
}
function writeData(socket,data){
var success=!socket.write(data);
if(!success){
(function (socket,data){
socket.once('drain',function(){
writeData(socket,data);
});
})(socket,data);
}
}
var example1=getConnection('example1');
var example2=getConnection('example2');
writeData(example1,'This is example1');
writeData(example2,'This is example2');
var server=net.createServer(function(client){
console.log('Client connection: ');
console.log(' local=%s:%s',client.localAddress,client.localPort);
console.log( ' remote=%s:%s',client.remoteAddress,client.remotePort);
client.setTimeout(500);
client.setEncoding('utf8');
client.on('data',function(data){
console.log('Received data from client on port %d:%s',client.remotePort,data.toString());
console.log(' Bytes received:'+data.toString());
writeData(client,'Sending: '+data.toString());
console.log(' Bytes sent: '+client.bytesWritten)
});
client.on('end',function(){
console.log('Client disconnected');
server.getConnections(function(err,count){
console.log('Remaining Connections: '+count);
});
});
client.on('error',function(err){
console.log('Socket Error: '+JSON.stringify(err));
});
client.on('timeout',function(){
console.log('Socket Time Out');
});
});
server.listen(8017,function(){
console.log('Server listening: '+JSON.stringify(server.address()));
server.on('close',function(){
console.log('Server Terminated');
});
server.on('error',function(err){
console.log('Server Error: ',JSON.stringify(err));
});
});
希望本文所述对大家nodejs程序设计有所帮助。
