Re: [nodejs] Is it a right thing to do, to use Node.JS as a TCP Server?

[Kaveh Shahbazian]

Node.JS TCP Server:

var net = require('net');
var fs   = require('fs');

var HOST = '127.0.0.1';
var PORT = 3000;
var timeout = 420000; // msec

var lg = function(message) {
console.log(message);
};

var server = net.createServer();

server.on('listening', function() {
lg('Server listening on ' + HOST +':'+ PORT);
});

server.on('connection', function(sock) {
sock.setTimeout(timeout, function() {
try {
sock.end();
}
catch(x) {
lg('on end' + x);
}
});
 sock.setNoDelay(true);
    sock.setEncoding('ascii');
    
    sock.on('data', function(data) {
try {
sock.write(data);
}
catch(x) {
lg(x);
}
    });
 sock.on('end', function(data) {
try {
sock.end();
}
catch(x) {
lg('on end' + x);
}
    });
 sock.on('error', function(err) {
lg(err);
});
    
    sock.on('close', function(data) {
 try {
sock.end();
}
catch(x) {
lg(x);
}
 try {
sock.destroy();
}
catch(x) {
lg('on close' + x);
}
    });
 sock.on('timeout', function() {
});
});

server.on('error', function(err) {
});

server.on('close', function() {
});

server.listen(PORT, HOST);

Go TCP Server:

package main

import (
"log"
"net"
"os"
"runtime"
)

func main() {
ln, err := net.Listen("tcp", ":3000")

if err != nil {
log.Fatal(err)
}

for {
conn, err := ln.Accept()

if err != nil {
log.Println(err)
continue
}

go handleConn(conn)
}
}

func handleConn(c net.Conn) {
buf := make([]byte, 65536)

for {
n, err := c.Read(buf)

if err != nil || n == 0 {
c.Close()
break
}

n, err = c.Write(buf[0:n])

if err != nil {
c.Close()
break
}
}

log.Printf("conn %v closed", c.RemoteAddr())
}

func init() {
runtime.GOMAXPROCS(1110)

flags := log.Flags()
log.SetFlags(flags | log.Lmicroseconds | log.Llongfile | log.Lshortfile)

fn := "log.log"
f, err := os.OpenFile(fn, os.O_CREATE|os.O_APPEND|os.O_RDWR, os.ModeAppend)
if err != nil {
log.Println(err)
}
log.SetOutput(f)
}

And the client is in C#:

//...
namespace TestClient
{
    static partial class Program
    {
        static void Main(string[] args)
        {
            ThreadPool.SetMaxThreads(10000, 5000);
            ThreadPool.SetMinThreads(2000, 2500);

            var taskCount = 10000;

            var time = new Stopwatch();

            time.Start();
            for (int i = 0; i < taskCount; i++)
            {
                SampleSend();
            }

            var lastLogAt = DateTime.Now.AddMinutes(-1);
            while (TaskCount < taskCount)
            {
                Thread.Sleep(10);

                if ((DateTime.Now - lastLogAt).TotalSeconds > 0.5)
                {
                    Console.WriteLine(Interlocked.Read(ref TaskCount));
                    lastLogAt = DateTime.Now;
                }
            }
            time.Stop();

            var l = string.Format("sent: {0}% rcvd: {1}%, fail: {2}%, 
count: {3}", 100d * SentCount / taskCount, 100d * RcvdCount / taskCount, 
100d * FailCount / taskCount, taskCount);
            var l2 = string.Format("{0} op/sec", taskCount / 
time.Elapsed.TotalSeconds);

            Log(l);
            Log(l2);

            Console.WriteLine("press any key to exit");
            Console.ReadKey();
        }

        public static long SentCount = 0;
        public static long RcvdCount = 0;
        public static long FailCount = 0;
        public static long TaskCount = 0;

        static async void SampleSend()
        {
            await Task.Delay(0);

            Interlocked.Increment(ref TaskCount);

            TcpClient client = null;
            var enc = new ASCIIEncoding();

            try
            {
                client = new TcpClient();
                client.SendTimeout = TimeSpan.FromSeconds(0.5).Milliseconds;
                client.ReceiveTimeout = 
TimeSpan.FromSeconds(0.5).Milliseconds;
                client.Connect(IPAddress.Parse("127.0.0.1"), 3000);

                var strm = client.GetStream();

                try
                {
                    var message = "ping";

                    var bytes = enc.GetBytes(message);

                    strm.Write(bytes, 0, bytes.Length);
                    strm.Flush();

                    Interlocked.Increment(ref SentCount);

                    int b = 0;
                    var rcvdBytes = new List<byte>();
                    while ((b = strm.ReadByte()) > -1)
                    {
                        rcvdBytes.Add((byte)(b & 0xFF));

                        if (Encoding.ASCII.GetString(rcvdBytes.ToArray()) 
== message) break;
                    }

                    Interlocked.Increment(ref RcvdCount);
                }
                finally
                {
                    strm.Close();
                }
            }
            catch (Exception x)
            {
                LogError(x);

                Interlocked.Increment(ref FailCount);
            }
            finally { try { client.Close(); } catch { } }
        }
 //...
}
}

-- 
-- 
Job Board: http://jobs.nodejs.org/
Posting guidelines: 
https://github.com/joyent/node/wiki/Mailing-List-Posting-Guidelines
You received this message because you are subscribed to the Google
Groups "nodejs" group.
To post to this group, send email to nodejs@googlegroups.com
To unsubscribe from this group, send email to
nodejs+unsubscr...@googlegroups.com
For more options, visit this group at
http://groups.google.com/group/nodejs?hl=en?hl=en

--- 
You received this message because you are subscribed to the Google Groups 
"nodejs" group.
To unsubscribe from this group and stop receiving emails from it, send an email 
to nodejs+unsubscr...@googlegroups.com.
For more options, visit https://groups.google.com/groups/opt_out.